xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2026-02-19 14:14:26 +00:00
Code Issues Projects Releases Wiki Activity

Apply formatting changes

Browse Source
This commit is contained in:
Jarrod Johnson
2024-08-13 15:29:15 -04:00
parent 45b17ba855
commit 21f68bb212
1 changed files with 31 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
confluent_server/confluent/plugins/hardwaremanagement/ipmi.py
View File

@@ -421,38 +421,38 @@ async def perform_requests(operator, nodes, element, cfg, inputdata, realop):
pass
async def perform_request(operator, node, element,
configdata, inputdata, cfg, results, realop):
try:
ih = await IpmiHandler.create(operator, node, element, configdata, inputdata,
cfg, results, realop)
return await ih.handle_request()
except pygexc.IpmiException as ipmiexc:
excmsg = str(ipmiexc)
if excmsg in ('Session no longer connected', 'timeout'):
await results.put(msg.ConfluentTargetTimeout(node))
else:
await results.put(msg.ConfluentNodeError(node, excmsg))
#raise
except exc.TargetEndpointUnreachable as tu:
await results.put(msg.ConfluentTargetTimeout(node, str(tu)))
except ssl.SSLEOFError:
await results.put(msg.ConfluentNodeError(
node, 'Unable to communicate with the https server on '
'the target BMC'))
except exc.PubkeyInvalid:
await results.put(msg.ConfluentNodeError(
node,
'Mismatch detected between target certificate fingerprint '
'and pubkeys.tls_hardwaremanager attribute'))
except pygexc.InvalidParameterValue as e:
await results.put(msg.ConfluentNodeError(node, str(e)))
except Exception as e:
await results.put(msg.ConfluentNodeError(node, 'Unexpected Error: {0}'.format(str(e))))
traceback.print_exc()
finally:
await results.put('Done')
configdata, inputdata, cfg, results, realop):
try:
ih = await IpmiHandler.create(
operator, node, element, configdata, inputdata, cfg, results,
realop)
return await ih.handle_request()
except pygexc.IpmiException as ipmiexc:
excmsg = str(ipmiexc)
if excmsg in ('Session no longer connected', 'timeout'):
await results.put(msg.ConfluentTargetTimeout(node))
else:
await results.put(msg.ConfluentNodeError(node, excmsg))
#raise
except exc.TargetEndpointUnreachable as tu:
await results.put(msg.ConfluentTargetTimeout(node, str(tu)))
except ssl.SSLEOFError:
await results.put(msg.ConfluentNodeError(
node, 'Unable to communicate with the https server on '
'the target BMC'))
except exc.PubkeyInvalid:
await results.put(msg.ConfluentNodeError(
node,
'Mismatch detected between target certificate fingerprint '
'and pubkeys.tls_hardwaremanager attribute'))
except pygexc.InvalidParameterValue as e:
await results.put(msg.ConfluentNodeError(node, str(e)))
except Exception as e:
await results.put(msg.ConfluentNodeError(node, 'Unexpected Error: {0}'.format(str(e))))
traceback.print_exc()
finally:
await results.put('Done')
persistent_ipmicmds = {}