Revision 506cff12 daemons/ganeti-noded

b/daemons/ganeti-noded
54 54 
  """
55 55 
  def wrapper(*args, **kwargs):
56 56 
    # Locking in exclusive, blocking mode because there could be several
57 
    # children running at the same time.
58 
    # TODO: Implement nonblocking locking with retries?
59 
    queue_lock.Exclusive(blocking=True)
57 
    # children running at the same time. Waiting up to 10 seconds.
58 
    queue_lock.Exclusive(blocking=True, timeout=10)
60 59 
    try:
61 60 
      return fn(*args, **kwargs)
62 61 
    finally:

Also available in: Unified diff