Revision e4e59de8 test/ganeti.jqueue_unittest.py
| b/test/ganeti.jqueue_unittest.py | ||
|---|---|---|
| 554 | 554 |
self._before_start = before_start |
| 555 | 555 |
self._after_start = after_start |
| 556 | 556 |
|
| 557 |
def __call__(self, op, cbs, timeout=None, priority=None):
|
|
| 557 |
def __call__(self, op, cbs, timeout=None): |
|
| 558 | 558 |
assert isinstance(op, opcodes.OpTestDummy) |
| 559 | 559 |
assert not self._queue.IsAcquired(), \ |
| 560 | 560 |
"Queue lock not released when executing opcode" |
| 561 | 561 |
|
| 562 | 562 |
if self._before_start: |
| 563 |
self._before_start(timeout, priority)
|
|
| 563 |
self._before_start(timeout, cbs.CurrentPriority())
|
|
| 564 | 564 |
|
| 565 | 565 |
cbs.NotifyStart() |
| 566 | 566 |
|
Also available in: Unified diff