Revision d385a174 test/ganeti.mcpu_unittest.py
| b/test/ganeti.mcpu_unittest.py | ||
|---|---|---|
| 26 | 26 |
|
| 27 | 27 |
from ganeti import mcpu |
| 28 | 28 |
from ganeti import opcodes |
| 29 |
from ganeti.constants import \ |
|
| 30 |
LOCK_ATTEMPTS_TIMEOUT, \ |
|
| 31 |
LOCK_ATTEMPTS_MAXWAIT, \ |
|
| 32 |
LOCK_ATTEMPTS_MINWAIT |
|
| 29 | 33 |
|
| 30 | 34 |
import testutils |
| 31 | 35 |
|
| ... | ... | |
| 33 | 37 |
class TestLockAttemptTimeoutStrategy(unittest.TestCase): |
| 34 | 38 |
def testConstants(self): |
| 35 | 39 |
tpa = mcpu.LockAttemptTimeoutStrategy._TIMEOUT_PER_ATTEMPT |
| 36 |
self.assert_(len(tpa) > 10)
|
|
| 37 |
self.assert_(sum(tpa) >= 150.0)
|
|
| 40 |
self.assert_(len(tpa) > LOCK_ATTEMPTS_TIMEOUT / LOCK_ATTEMPTS_MAXWAIT)
|
|
| 41 |
self.assert_(sum(tpa) >= LOCK_ATTEMPTS_TIMEOUT)
|
|
| 38 | 42 |
|
| 39 | 43 |
def testSimple(self): |
| 40 | 44 |
strat = mcpu.LockAttemptTimeoutStrategy(_random_fn=lambda: 0.5, |
| ... | ... | |
| 45 | 49 |
timeout = strat.NextAttempt() |
| 46 | 50 |
self.assert_(timeout is not None) |
| 47 | 51 |
|
| 48 |
self.assert_(timeout <= 10.0)
|
|
| 49 |
self.assert_(timeout >= 0.0)
|
|
| 52 |
self.assert_(timeout <= LOCK_ATTEMPTS_MAXWAIT)
|
|
| 53 |
self.assert_(timeout >= LOCK_ATTEMPTS_MINWAIT)
|
|
| 50 | 54 |
self.assert_(prev is None or timeout >= prev) |
| 51 | 55 |
|
| 52 | 56 |
prev = timeout |
Also available in: Unified diff