Revision 0d5a0b96 lib/mcpu.py
| b/lib/mcpu.py | ||
|---|---|---|
| 300 | 300 |
# Acquiring locks |
| 301 | 301 |
needed_locks = lu.needed_locks[level] |
| 302 | 302 |
|
| 303 |
acquired = self._AcquireLocks(level, needed_locks, share,
|
|
| 304 |
calc_timeout(), priority)
|
|
| 303 |
self._AcquireLocks(level, needed_locks, share, |
|
| 304 |
calc_timeout(), priority) |
|
| 305 | 305 |
else: |
| 306 | 306 |
# Adding locks |
| 307 | 307 |
add_locks = lu.add_locks[level] |
| ... | ... | |
| 315 | 315 |
" with another job, who added them first" % add_locks, |
| 316 | 316 |
errors.ECODE_FAULT) |
| 317 | 317 |
|
| 318 |
acquired = add_locks |
|
| 319 |
|
|
| 320 | 318 |
try: |
| 321 |
lu.acquired_locks[level] = acquired |
|
| 322 |
|
|
| 323 | 319 |
result = self._LockAndExecLU(lu, level + 1, calc_timeout, priority) |
| 324 | 320 |
finally: |
| 325 | 321 |
if level in lu.remove_locks: |
Also available in: Unified diff