Revision 506cff12
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