Statistics
| Branch: | Tag: | Revision:

root / test / ganeti.mcpu_unittest.py @ 407339d0

History | View | Annotate | Download (1.5 kB)

1
#!/usr/bin/python
2
#
3

    
4
# Copyright (C) 2009 Google Inc.
5
#
6
# This program is free software; you can redistribute it and/or modify
7
# it under the terms of the GNU General Public License as published by
8
# the Free Software Foundation; either version 2 of the License, or
9
# (at your option) any later version.
10
#
11
# This program is distributed in the hope that it will be useful, but
12
# WITHOUT ANY WARRANTY; without even the implied warranty of
13
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14
# General Public License for more details.
15
#
16
# You should have received a copy of the GNU General Public License
17
# along with this program; if not, write to the Free Software
18
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
19
# 02110-1301, USA.
20

    
21

    
22
"""Script for unittesting the mcpu module"""
23

    
24

    
25
import unittest
26

    
27
from ganeti import mcpu
28

    
29

    
30
class TestLockTimeoutStrategy(unittest.TestCase):
31
  def testConstants(self):
32
    self.assert_(mcpu._LockTimeoutStrategy._MAX_ATTEMPTS > 0)
33
    self.assert_(mcpu._LockTimeoutStrategy._ATTEMPT_FACTOR > 1.0)
34

    
35
  def testSimple(self):
36
    strat = mcpu._LockTimeoutStrategy(_random_fn=lambda: 0.5)
37

    
38
    self.assertEqual(strat._attempts, 0)
39

    
40
    prev = None
41
    for _ in range(strat._MAX_ATTEMPTS):
42
      timeout = strat.CalcRemainingTimeout()
43
      self.assert_(timeout is not None)
44

    
45
      self.assert_(timeout <= 10.0)
46
      self.assert_(prev is None or timeout >= prev)
47

    
48
      strat.NextAttempt()
49

    
50
      prev = timeout
51

    
52
    self.assert_(strat.CalcRemainingTimeout() is None)
53

    
54

    
55
if __name__ == "__main__":
56
  unittest.main()