RanchiMall/flo-electrum
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix asyncio loop

Browse Source
This commit is contained in:
ThomasV 2018-04-11 11:39:59 +02:00 committed by Janus
parent a8320ef6f5
commit 48dae8fadf
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
lib/network.py
View File

@ -1081,6 +1081,7 @@ class Network(util.DaemonThread):
privkey = b"\x21"*32 + b"\x01" privkey = b"\x21"*32 + b"\x01"
peer = Peer(privkey, host, port, pubkey) peer = Peer(privkey, host, port, pubkey)
self.futures.append(asyncio.run_coroutine_threadsafe(peer.main_loop(loop), loop)) self.futures.append(asyncio.run_coroutine_threadsafe(peer.main_loop(loop), loop))
loop.run_forever()
threading.Thread(target=asyncioThread).start() threading.Thread(target=asyncioThread).start()
networkAndWalletLock.acquire() networkAndWalletLock.acquire()
@ -1093,7 +1094,7 @@ class Network(util.DaemonThread):
networkAndWalletLock.release() networkAndWalletLock.release()
networkAndWalletLock.acquire() networkAndWalletLock.acquire()
# cancel tasks # cancel tasks
[f.cancel for f in self.futures] [f.cancel() for f in self.futures]
loop.stop() loop.stop()
if loop.is_running(): time.sleep(0.1) if loop.is_running(): time.sleep(0.1)
try: try: