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

test_util: improve ConcurrencyLimiter tests

Browse Source
This commit is contained in:
Brian Warner 2008-05-07 17:00:47 -07:00
parent c7e441309d
commit 15a9f3d01b
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/allmydata/test/test_util.py
View File

@ -453,7 +453,7 @@ class Limiter(unittest.TestCase):
d = defer.Deferred()
def _done():
self.simultaneous -= 1
d.callback("done")
d.callback("done %d" % i)
reactor.callLater(1.0, _done)
return d
@ -489,6 +489,14 @@ class Limiter(unittest.TestCase):
d2 = l.add(self.bad_job, 21, "21")
d = defer.DeferredList(dl, fireOnOneErrback=True)
def _most_done(res):
results = []
for (success, result) in res:
self.failUnlessEqual(success, True)
results.append(result)
results.sort()
expected_results = ["done %d" % i for i in range(20)]
expected_results.sort()
self.failUnlessEqual(results, expected_results)
self.failUnless(self.peak_simultaneous <= 10)
self.failUnlessEqual(len(self.calls), 20)
for i in range(20):