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