xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2026-03-30 14:13:29 +00:00
Code Issues Projects Releases Wiki Activity

Properly await async pushes to async queue

Browse Source
This commit is contained in:
Jarrod Johnson
2026-03-20 16:24:35 -04:00
parent 7f80a4d5aa
commit 8e508ee858
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
confluent_server/confluent/plugins/hardwaremanagement/redfish.py
View File

@@ -682,15 +682,15 @@ class IpmiHandler:
async def handle_nets(self):
if len(self.element) == 3:
if self.op != 'read':
self.output.put(
await self.output.put(
msg.ConfluentNodeError(self.node, 'Unsupported operation'))
return
self.output.put(msg.ChildCollection('management'))
await self.output.put(msg.ChildCollection('management'))
elif len(self.element) == 4 and self.element[-1] == 'management':
if self.op == 'read':
lancfg = await self.ipmicmd.get_net_configuration()
v6cfg = await self.ipmicmd.get_net6_configuration()
self.output.put(msg.NetworkConfiguration(
await self.output.put(msg.NetworkConfiguration(
self.node, ipv4addr=lancfg['ipv4_address'],
ipv4gateway=lancfg['ipv4_gateway'],
ipv4cfgmethod=lancfg['ipv4_configuration'],
@@ -713,16 +713,16 @@ class IpmiHandler:
v6gw = config.get('static_v6_gateway', None)
await self.ipmicmd.set_net6_configuration(static_addresses=v6addrs, static_gateway=v6gw)
except socket.error as se:
self.output.put(msg.ConfluentNodeError(self.node,
await self.output.put(msg.ConfluentNodeError(self.node,
se.message))
except ValueError as e:
if e.message == 'negative shift count':
self.output.put(msg.ConfluentNodeError(
await self.output.put(msg.ConfluentNodeError(
self.node, 'Invalid prefix length given'))
else:
raise
elif len(self.element) == 4 and self.element[-1] != 'management':
self.output.put(
await self.output.put(
msg.ConfluentTargetNotFound(self.node,
'Interface not found'))