Croc/croccybot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix (shardtalk): Fix broadcast peerlist.

Browse Source
This commit is contained in:
Conatum
2023-08-23 09:44:55 +03:00
parent d93f31d295
commit 4e8cba2037
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/meta/ipc/client.py
View File

@@ -126,12 +126,12 @@ class AppClient:
@log_wrap(action="Broadcast") @log_wrap(action="Broadcast")
async def requestall(self, payload, except_self=True, only_my_peers=True): async def requestall(self, payload, except_self=True, only_my_peers=True):
peerlist = self.my_peers if only_my_peers else self.peers peerlist = list((self.my_peers if only_my_peers else self.peers).keys())
results = await asyncio.gather( results = await asyncio.gather(
*(self.request(appid, payload) for appid in peerlist if (appid != self.appid or not except_self)), *(self.request(appid, payload) for appid in peerlist if (appid != self.appid or not except_self)),
return_exceptions=True return_exceptions=True
) )
return dict(zip(self.peers.keys(), results)) return dict(zip(peerlist, results))
async def handle_request(self, reader, writer): async def handle_request(self, reader, writer):
set_logging_context(action="SERV") set_logging_context(action="SERV")