Revision a13e1743 lib/mcpu.py
b/lib/mcpu.py | ||
---|---|---|
33 | 33 |
import random |
34 | 34 |
import time |
35 | 35 |
import itertools |
36 |
import threading |
|
37 | 36 |
import traceback |
38 | 37 |
|
39 | 38 |
from ganeti import opcodes |
... | ... | |
309 | 308 |
self.hmclass = hooksmaster.HooksMaster |
310 | 309 |
self._enable_locks = enable_locks |
311 | 310 |
self.wconfd = wconfd # Indirection to allow testing |
312 |
self._wconfdcontext = (ec_id, |
|
313 |
threading.current_thread().ident, |
|
314 |
self.context.livelock.lockfile.name) |
|
311 |
self._wconfdcontext = context.GetWConfdContext(ec_id) |
|
312 |
|
|
315 | 313 |
|
316 | 314 |
def _CheckLocksEnabled(self): |
317 | 315 |
"""Checks if locking is enabled. |
Also available in: Unified diff