Revision a7770f03 test/ganeti.mcpu_unittest.py
b/test/ganeti.mcpu_unittest.py | ||
---|---|---|
31 | 31 |
|
32 | 32 |
class TestLockAttemptTimeoutStrategy(unittest.TestCase): |
33 | 33 |
def testConstants(self): |
34 |
tpa = mcpu._LockAttemptTimeoutStrategy._TIMEOUT_PER_ATTEMPT
|
|
34 |
tpa = mcpu.LockAttemptTimeoutStrategy._TIMEOUT_PER_ATTEMPT |
|
35 | 35 |
self.assert_(len(tpa) > 10) |
36 | 36 |
self.assert_(sum(tpa) >= 150.0) |
37 | 37 |
|
38 | 38 |
def testSimple(self): |
39 |
strat = mcpu._LockAttemptTimeoutStrategy(_random_fn=lambda: 0.5, |
|
40 |
_time_fn=lambda: 0.0) |
|
41 |
|
|
42 |
self.assertEqual(strat._attempt, 0) |
|
39 |
strat = mcpu.LockAttemptTimeoutStrategy(_random_fn=lambda: 0.5, |
|
40 |
_time_fn=lambda: 0.0) |
|
43 | 41 |
|
44 | 42 |
prev = None |
45 |
for i in range(len(mcpu._LockAttemptTimeoutStrategy._TIMEOUT_PER_ATTEMPT)):
|
|
46 |
timeout = strat.CalcRemainingTimeout()
|
|
43 |
for i in range(len(strat._TIMEOUT_PER_ATTEMPT)):
|
|
44 |
timeout = strat.NextAttempt()
|
|
47 | 45 |
self.assert_(timeout is not None) |
48 | 46 |
|
49 | 47 |
self.assert_(timeout <= 10.0) |
50 | 48 |
self.assert_(timeout >= 0.0) |
51 | 49 |
self.assert_(prev is None or timeout >= prev) |
52 | 50 |
|
53 |
strat = strat.NextAttempt() |
|
54 |
self.assertEqual(strat._attempt, i + 1) |
|
55 |
|
|
56 | 51 |
prev = timeout |
57 | 52 |
|
58 | 53 |
for _ in range(10): |
59 |
self.assert_(strat.CalcRemainingTimeout() is None)
|
|
54 |
self.assert_(strat.NextAttempt() is None)
|
|
60 | 55 |
|
61 | 56 |
|
62 | 57 |
if __name__ == "__main__": |
Also available in: Unified diff