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 fe7d1ccd7f
commit 4615b9134d
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
electrum/network.py
View File

@ -1109,6 +1109,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()
@ -1121,7 +1122,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: