ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-01-18 18:56:28 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

test_introducer.py: increase timeouts on poll() calls

Browse Source
This commit is contained in:
Brian Warner 2008-02-05 16:37:58 -07:00
parent 8ae6795e91
commit a7ea39e626
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/allmydata/test/test_introducer.py
View File

@ -122,7 +122,7 @@ class TestIntroducer(unittest.TestCase, testutil.PollMixin):
if len(c.get_all_connections()) < NUMCLIENTS: if len(c.get_all_connections()) < NUMCLIENTS:
return False return False
return True return True
d = self.poll(_wait_for_all_connections, timeout=5) d = self.poll(_wait_for_all_connections)
def _check1(res): def _check1(res):
log.msg("doing _check1") log.msg("doing _check1")
@ -148,12 +148,12 @@ class TestIntroducer(unittest.TestCase, testutil.PollMixin):
# noticing the loss # noticing the loss
def _compare(): def _compare():
return current_counter != origin_c.counter return current_counter != origin_c.counter
return self.poll(_compare, timeout=5) return self.poll(_compare)
d.addCallback(_disconnect_somebody_else) d.addCallback(_disconnect_somebody_else)
# and wait for them to reconnect # and wait for them to reconnect
d.addCallback(lambda res: self.poll(_wait_for_all_connections, timeout=5)) d.addCallback(lambda res: self.poll(_wait_for_all_connections))
def _check2(res): def _check2(res):
log.msg("doing _check2") log.msg("doing _check2")
for c in clients: for c in clients:
@ -171,10 +171,10 @@ class TestIntroducer(unittest.TestCase, testutil.PollMixin):
def _compare(): def _compare():
return current_counter != origin_c.counter return current_counter != origin_c.counter
return self.poll(_compare, timeout=5) return self.poll(_compare)
d.addCallback(_disconnect_yourself) d.addCallback(_disconnect_yourself)
d.addCallback(lambda res: self.poll(_wait_for_all_connections, timeout=5)) d.addCallback(lambda res: self.poll(_wait_for_all_connections))
def _check3(res): def _check3(res):
log.msg("doing _check3") log.msg("doing _check3")
for c in clients: for c in clients:
@ -194,7 +194,7 @@ class TestIntroducer(unittest.TestCase, testutil.PollMixin):
if c.connected_to_introducer(): if c.connected_to_introducer():
return False return False
return True return True
d.addCallback(lambda res: self.poll(_wait_for_introducer_loss, timeout=5)) d.addCallback(lambda res: self.poll(_wait_for_introducer_loss))
def _check4(res): def _check4(res):
log.msg("doing _check4") log.msg("doing _check4")