From: Brian Warner <warner@lothar.com>
Date: Mon, 17 Sep 2007 09:25:31 +0000 (-0700)
Subject: test_runner.py: add tests for startstop_node.py
X-Git-Tag: allmydata-tahoe-0.6.0~80
X-Git-Url: https://git.rkrishnan.org/components/com_hotproperty/COPYING.TGPPL.html?a=commitdiff_plain;h=f72ef4d8f9e0940f54db656cbacf5326ccdb551e;p=tahoe-lafs%2Ftahoe-lafs.git

test_runner.py: add tests for startstop_node.py
---

diff --git a/src/allmydata/test/test_runner.py b/src/allmydata/test/test_runner.py
index c7a8aedb..8696e8c6 100644
--- a/src/allmydata/test/test_runner.py
+++ b/src/allmydata/test/test_runner.py
@@ -1,6 +1,8 @@
 
 from twisted.trial import unittest
+from twisted.python.runtime import platformType
 
+import time
 from cStringIO import StringIO
 from twisted.python import usage
 import os.path
@@ -9,7 +11,7 @@ from allmydata.util import fileutil
 
 class CreateNode(unittest.TestCase):
     def workdir(self, name):
-        basedir = os.path.join("test_runner", name)
+        basedir = os.path.join("test_runner", "CreateNode", name)
         fileutil.make_dirs(basedir)
         return basedir
 
@@ -97,3 +99,43 @@ class Diagnostics(unittest.TestCase):
         output = s.getvalue()
         self.failUnless("unable to read root dirnode file from" in output)
         self.failIfEqual(rc, 0)
+
+class RunNode(unittest.TestCase):
+    def workdir(self, name):
+        basedir = os.path.join("test_runner", "RunNode", name)
+        fileutil.make_dirs(basedir)
+        return basedir
+
+    def test_client(self):
+        if platformType == "win32":
+            raise unittest.SkipTest("twistd does not fork under windows")
+        basedir = self.workdir("test_client")
+        c1 = os.path.join(basedir, "c1")
+        argv = ["--quiet", "create-client", "--basedir", c1]
+        out,err = StringIO(), StringIO()
+        rc = runner.runner(argv, stdout=out, stderr=err)
+        self.failUnlessEqual(rc, 0)
+        open(os.path.join(c1, "suicide_prevention_hotline_file"), "w").write("")
+        open(os.path.join(c1, "introducer.furl"), "w").write("pb://xrndsskn2zuuian5ltnxrte7lnuqdrkz@127.0.0.1:55617/introducer\n")
+        # now it's safe to start the node
+
+        argv = ["--quiet", "start", c1]
+        out,err = StringIO(), StringIO()
+        rc = runner.runner(argv, stdout=out, stderr=err)
+        self.failUnlessEqual(rc, 0)
+        time.sleep(0.1) # the child process needs a moment to write the pidfile
+        self.failUnless(os.path.exists(os.path.join(c1, "twistd.pid")))
+
+        argv = ["--quiet", "restart", c1]
+        out,err = StringIO(), StringIO()
+        rc = runner.runner(argv, stdout=out, stderr=err)
+        self.failUnlessEqual(rc, 0)
+        time.sleep(0.1)
+        self.failUnless(os.path.exists(os.path.join(c1, "twistd.pid")))
+
+        argv = ["--quiet", "stop", c1]
+        out,err = StringIO(), StringIO()
+        rc = runner.runner(argv, stdout=out, stderr=err)
+        self.failUnlessEqual(rc, 0)
+        self.failIf(os.path.exists(os.path.join(c1, "twistd.pid")))
+