Revision 4b5e8271 lib/mcpu.py
| b/lib/mcpu.py | ||
|---|---|---|
| 117 | 117 |
""" |
| 118 | 118 |
write_count = self.context.cfg.write_count |
| 119 | 119 |
lu.CheckPrereq() |
| 120 |
hm = HooksMaster(self.rpc.call_hooks_runner, self, lu)
|
|
| 120 |
hm = HooksMaster(self.rpc.call_hooks_runner, lu) |
|
| 121 | 121 |
h_results = hm.RunPhase(constants.HOOKS_PHASE_PRE) |
| 122 | 122 |
lu.HooksCallBack(constants.HOOKS_PHASE_PRE, h_results, |
| 123 | 123 |
self._feedback_fn, None) |
| ... | ... | |
| 282 | 282 |
which behaves the same works. |
| 283 | 283 |
|
| 284 | 284 |
""" |
| 285 |
def __init__(self, callfn, proc, lu):
|
|
| 285 |
def __init__(self, callfn, lu): |
|
| 286 | 286 |
self.callfn = callfn |
| 287 |
self.proc = proc |
|
| 288 | 287 |
self.lu = lu |
| 289 | 288 |
self.op = lu.op |
| 290 | 289 |
self.env, node_list_pre, node_list_post = self._BuildEnv() |
| ... | ... | |
| 361 | 360 |
continue |
| 362 | 361 |
msg = res.RemoteFailMsg() |
| 363 | 362 |
if msg: |
| 364 |
self.proc.LogWarning("Communication failure to node %s: %s",
|
|
| 365 |
node_name, msg)
|
|
| 363 |
self.lu.LogWarning("Communication failure to node %s: %s",
|
|
| 364 |
node_name, msg) |
|
| 366 | 365 |
continue |
| 367 | 366 |
for script, hkr, output in res.payload: |
| 368 | 367 |
if hkr == constants.HKR_FAIL: |
Also available in: Unified diff