Revision 72737a7f lib/mcpu.py
| b/lib/mcpu.py | ||
|---|---|---|
| 97 | 97 |
self.context = context |
| 98 | 98 |
self._feedback_fn = None |
| 99 | 99 |
self.exclusive_BGL = False |
| 100 |
self.rpc = rpc.RpcRunner(context.cfg) |
|
| 100 | 101 |
|
| 101 | 102 |
def _ExecLU(self, lu): |
| 102 | 103 |
"""Logical Unit execution sequence. |
| ... | ... | |
| 104 | 105 |
""" |
| 105 | 106 |
write_count = self.context.cfg.write_count |
| 106 | 107 |
lu.CheckPrereq() |
| 107 |
hm = HooksMaster(rpc.call_hooks_runner, self, lu) |
|
| 108 |
hm = HooksMaster(self.rpc.call_hooks_runner, self, lu)
|
|
| 108 | 109 |
h_results = hm.RunPhase(constants.HOOKS_PHASE_PRE) |
| 109 | 110 |
lu.HooksCallBack(constants.HOOKS_PHASE_PRE, h_results, |
| 110 | 111 |
self._feedback_fn, None) |
| ... | ... | |
| 202 | 203 |
shared=not lu_class.REQ_BGL) |
| 203 | 204 |
try: |
| 204 | 205 |
self.exclusive_BGL = lu_class.REQ_BGL |
| 205 |
lu = lu_class(self, op, self.context) |
|
| 206 |
lu = lu_class(self, op, self.context, self.rpc)
|
|
| 206 | 207 |
lu.ExpandNames() |
| 207 | 208 |
assert lu.needed_locks is not None, "needed_locks not set by LU" |
| 208 | 209 |
result = self._LockAndExecLU(lu, locking.LEVEL_INSTANCE) |
Also available in: Unified diff