Revision 557838c1 lib/mcpu.py

b/lib/mcpu.py
38 38 
from ganeti import rpc
39 39 
from ganeti import cmdlib
40 40 
from ganeti import locking
41 
from ganeti import utils
41 42 

  		





  42
  43
  
    

  		





  43
  44
  
    
class LockAcquireTimeout(Exception):


  		





  ......




  368
  369
  
    
    if timeout is None:


  		





  369
  370
  
    
      calc_timeout = lambda: None


  		





  370
  371
  
    
    else:


  		





  371
  
  
    
      calc_timeout = locking.RunningTimeout(timeout, False).Remaining


  		





  
  372
  
    
      calc_timeout = utils.RunningTimeout(timeout, False).Remaining


  		





  372
  373
  
    

  		





  373
  374
  
    
    self._cbs = cbs


  		





  374
  375
  
    
    try:


  		












Also available in:
  Unified diff