20 |
def getQuality(self): |
def getQuality(self): |
21 |
return self.qual |
return self.qual |
22 |
|
|
23 |
def waitFor(f): |
def waitFor(f, dontStop = 0): |
24 |
for i in range(0,20): |
for i in range(0,20): |
25 |
java.lang.Thread.sleep(50) |
java.lang.Thread.sleep(50) |
26 |
if f(): |
if f(): |
27 |
pool.stop() |
if not dontStop: pool.stop() |
28 |
return |
return |
29 |
pool.stop() |
pool.stop() |
30 |
failUnless(0) |
failUnless(0) |
54 |
|
|
55 |
waitFor(lambda: b.rese == 230 and d.rese == 230 and 1 < c.rese < 220 ) |
waitFor(lambda: b.rese == 230 and d.rese == 230 and 1 < c.rese < 220 ) |
56 |
|
|
57 |
|
def testChange(): |
58 |
|
"""Test that the partitioner reacts to new requests. |
59 |
|
""" |
60 |
|
b = Reserver() |
61 |
|
c = Reserver() |
62 |
|
d = Reserver() |
63 |
|
|
64 |
|
pool.request(b, .5, 1, None) |
65 |
|
pool.request(c, .25, 1, None) |
66 |
|
pool.request(d, .5, 1, None) |
67 |
|
|
68 |
|
waitFor(lambda: b.rese == 230 and d.rese == 230 and 1 < c.rese < 220, dontStop=1 ) |
69 |
|
|
70 |
|
pool.request(c, 1, 1, None) |
71 |
|
waitFor(lambda: c.rese == 230 and b.rese + d.rese <= 500 - 230 ) |
72 |
|
|