nurazhar/xch-blockchain
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

server: Don't pass the queue into WSChiaConnection._wait_and_retry (#13877)

Browse source
This commit is contained in:
dustinface 2022-11-09 21:57:59 +01:00 committed by GitHub
parent 8394857ca2
commit 50b630aee9
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
chia/server/ws_connection.py
View file

@ -383,10 +383,10 @@ class WSChiaConnection:
for message in messages:
await self.outgoing_queue.put(message)
async def _wait_and_retry(self, msg: Message, queue: asyncio.Queue):
async def _wait_and_retry(self, msg: Message):
try:
await asyncio.sleep(1)
await queue.put(msg)
await self.outgoing_queue.put(msg)
except Exception as e:
self.log.debug(f"Exception {e} while waiting to retry sending rate limited message")
return None
@ -406,7 +406,7 @@ class WSChiaConnection:
# TODO: fix this special case. This function has rate limits which are too low.
if ProtocolMessageTypes(message.type) != ProtocolMessageTypes.respond_peers:
asyncio.create_task(self._wait_and_retry(message, self.outgoing_queue))
asyncio.create_task(self._wait_and_retry(message))
return None
else: