From: Brian Warner <warner@allmydata.com>
Date: Wed, 6 Feb 2008 21:05:11 +0000 (-0700)
Subject: test_system: deferred-handling logic in test_upload_and_download was broken
X-Git-Tag: allmydata-tahoe-0.8.0~123
X-Git-Url: https://git.rkrishnan.org/pf/content/en/service?a=commitdiff_plain;h=4d4073fb16c6e8f9c1ef05614a634e58972c8638;p=tahoe-lafs%2Ftahoe-lafs.git

test_system: deferred-handling logic in test_upload_and_download was broken
---

diff --git a/src/allmydata/test/test_system.py b/src/allmydata/test/test_system.py
index c307ef9d..59bc9112 100644
--- a/src/allmydata/test/test_system.py
+++ b/src/allmydata/test/test_system.py
@@ -380,20 +380,18 @@ class SystemTest(testutil.SignalMixin, testutil.PollMixin, unittest.TestCase):
                     self.failIf(os.path.exists(incdir) and os.listdir(incdir))
             d.addCallback(_disconnected)
 
-            def _wait_for_reconnect(res):
-                # then we need to give the reconnector a chance to
-                # reestablish the connection to the helper.
-                d.addCallback(lambda res:
-                              log.msg("wait_for_connections", level=log.NOISY,
-                                      facility="tahoe.test.test_system"))
-                d.addCallback(lambda res: self.wait_for_connections())
-            d.addCallback(_wait_for_reconnect)
-
-            def _upload_again(res):
-                log.msg("uploading again", level=log.NOISY,
-                        facility="tahoe.test.test_system")
-                return self.extra_node.upload(u2)
-            d.addCallbacks(_upload_again)
+            # then we need to give the reconnector a chance to
+            # reestablish the connection to the helper.
+            d.addCallback(lambda res:
+                          log.msg("wait_for_connections", level=log.NOISY,
+                                  facility="tahoe.test.test_system"))
+            d.addCallback(lambda res: self.wait_for_connections())
+
+
+            d.addCallback(lambda res:
+                          log.msg("uploading again", level=log.NOISY,
+                                  facility="tahoe.test.test_system"))
+            d.addCallback(lambda res: self.extra_node.upload(u2))
 
             def _uploaded(results):
                 uri = results.uri