midefos/basicswap
1
0
Fork 0
mirror of https://github.com/basicswap/basicswap.git synced 2025-11-05 18:38:09 +01:00
Code Issues Packages Projects Releases Wiki Activity

ZMQ remove time.sleep(0.1) (#341)

Browse Source
This commit is contained in:
Gerlof van Ek
2025-07-28 21:43:25 +02:00
committed by GitHub
parent 02ceb89d14
commit b6e9118797
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
basicswap/basicswap.py
View File

@@ -10528,15 +10528,19 @@ class BasicSwap(BaseApp, UIApp):
if Coins.PART not in self.coin_clients: if Coins.PART not in self.coin_clients:
return return
self.thread_pool.submit(self._processZmqHashwtxAsync)
except Exception as e:
self.log.warning(f"Error processing PART wallet transaction: {e}")
if self.debug:
self.log.error(traceback.format_exc())
def _processZmqHashwtxAsync(self) -> None:
try:
ci = self.ci(Coins.PART) ci = self.ci(Coins.PART)
cc = self.coin_clients[Coins.PART] cc = self.coin_clients[Coins.PART]
current_height = cc.get("chain_height", 0) current_height = cc.get("chain_height", 0)
import time
time.sleep(0.1)
checkAndNotifyBalanceChange(self, Coins.PART, ci, cc, current_height, "zmq") checkAndNotifyBalanceChange(self, Coins.PART, ci, cc, current_height, "zmq")
except Exception as e: except Exception as e: