Revision 6f14fc27 lib/mcpu.py
b/lib/mcpu.py | ||
---|---|---|
381 | 381 |
if acquired is None: |
382 | 382 |
raise _LockAcquireTimeout() |
383 | 383 |
|
384 |
lu.acquired_locks[level] = acquired |
|
385 |
|
|
386 | 384 |
else: |
387 | 385 |
# Adding locks |
388 | 386 |
add_locks = lu.add_locks[level] |
... | ... | |
395 | 393 |
"Couldn't add locks (%s), probably because of a race condition" |
396 | 394 |
" with another job, who added them first" % add_locks) |
397 | 395 |
|
398 |
lu.acquired_locks[level] = add_locks |
|
396 |
acquired = add_locks |
|
397 |
|
|
399 | 398 |
try: |
399 |
lu.acquired_locks[level] = acquired |
|
400 |
|
|
400 | 401 |
result = self._LockAndExecLU(lu, level + 1, calc_timeout) |
401 | 402 |
finally: |
402 | 403 |
if level in lu.remove_locks: |
Also available in: Unified diff