CAT_TOM/pyasic
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bug: fix a bug where whatsminers could raise a cascading TimeoutError.

Browse Source
This commit is contained in:
Brett Rowan
2024-08-25 09:28:27 -06:00
parent a0daf37f80
commit 501e290839
1 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
pyasic/rpc/base.py
View File

@@ -215,14 +215,18 @@ If you are sure you want to use this command please use API.send_command("{comma
return b"{}" return b"{}"
# send the command # send the command
data_task = asyncio.create_task(self._read_bytes(reader, timeout=timeout)) try:
logging.debug(f"{self} - ([Hidden] Send Bytes) - Writing") data_task = asyncio.create_task(self._read_bytes(reader, timeout=timeout))
writer.write(data) logging.debug(f"{self} - ([Hidden] Send Bytes) - Writing")
logging.debug(f"{self} - ([Hidden] Send Bytes) - Draining") writer.write(data)
await writer.drain() logging.debug(f"{self} - ([Hidden] Send Bytes) - Draining")
await writer.drain()
await data_task await data_task
ret_data = data_task.result() ret_data = data_task.result()
except TimeoutError:
logging.warning(f"{self} - ([Hidden] Send Bytes) - Read timeout expired.")
return b"{}"
# close the connection # close the connection
logging.debug(f"{self} - ([Hidden] Send Bytes) - Closing") logging.debug(f"{self} - ([Hidden] Send Bytes) - Closing")