mirror of
https://github.com/xcat2/confluent.git
synced 2026-05-16 11:24:17 +00:00
More async changes for confluent
This commit is contained in:
@@ -306,7 +306,6 @@ async def recv(handle):
|
||||
msg.msg_control = ctypes.addressof(cmsg)
|
||||
msg.msg_controllen = ctypes.sizeof(cmsg)
|
||||
i = await recv_fds(handle, 2048, 4)
|
||||
print(repr(i))
|
||||
data = i[0]
|
||||
filehandles = i[1]
|
||||
data = json.loads(bytes(data))
|
||||
|
||||
@@ -502,7 +502,7 @@ class IpmiHandler:
|
||||
await self.ipmicmd.detach_remote_media()
|
||||
|
||||
async def handle_list_media(self):
|
||||
for media in self.ipmicmd.list_media():
|
||||
async for media in self.ipmicmd.list_media():
|
||||
await self.output.put(msg.Media(self.node, media))
|
||||
|
||||
async def handle_configuration(self):
|
||||
|
||||
Reference in New Issue
Block a user