1022 |
1022 |
|
1023 |
1023 |
for node_i in nodeinfo:
|
1024 |
1024 |
node = node_i.name
|
1025 |
|
nresult = all_nvinfo[node].data
|
1026 |
1025 |
|
1027 |
1026 |
if node_i.offline:
|
1028 |
1027 |
feedback_fn("* Skipping offline node %s" % (node,))
|
... | ... | |
1040 |
1039 |
ntype = "regular"
|
1041 |
1040 |
feedback_fn("* Verifying node %s (%s)" % (node, ntype))
|
1042 |
1041 |
|
1043 |
|
if all_nvinfo[node].failed or not isinstance(nresult, dict):
|
1044 |
|
feedback_fn(" - ERROR: connection to %s failed" % (node,))
|
|
1042 |
msg = all_nvinfo[node].RemoteFailMsg()
|
|
1043 |
if msg:
|
|
1044 |
feedback_fn(" - ERROR: while contacting node %s: %s" % (node, msg))
|
1045 |
1045 |
bad = True
|
1046 |
1046 |
continue
|
1047 |
1047 |
|
|
1048 |
nresult = all_nvinfo[node].payload
|
1048 |
1049 |
node_drbd = {}
|
1049 |
1050 |
for minor, instance in all_drbd_map[node].items():
|
1050 |
1051 |
if instance not in instanceinfo:
|
... | ... | |
2336 |
2337 |
result = self.rpc.call_node_verify(node_verify_list, node_verify_param,
|
2337 |
2338 |
self.cfg.GetClusterName())
|
2338 |
2339 |
for verifier in node_verify_list:
|
2339 |
|
if result[verifier].failed or not result[verifier].data:
|
2340 |
|
raise errors.OpExecError("Cannot communicate with %s's node daemon"
|
2341 |
|
" for remote verification" % verifier)
|
2342 |
|
if result[verifier].data['nodelist']:
|
2343 |
|
for failed in result[verifier].data['nodelist']:
|
|
2340 |
msg = result[verifier].RemoteFailMsg()
|
|
2341 |
if msg:
|
|
2342 |
raise errors.OpExecError("Cannot communicate with node %s: %s" %
|
|
2343 |
(verifier, msg))
|
|
2344 |
nl_payload = result[verifier].payload['nodelist']
|
|
2345 |
if nl_payload:
|
|
2346 |
for failed in nl_payload:
|
2344 |
2347 |
feedback_fn("ssh/hostname verification failed %s -> %s" %
|
2345 |
|
(verifier, result[verifier].data['nodelist'][failed]))
|
|
2348 |
(verifier, nl_payload[failed]))
|
2346 |
2349 |
raise errors.OpExecError("ssh/hostname verification failed.")
|
2347 |
2350 |
|
2348 |
2351 |
if self.op.readd:
|