LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-08-23 17:47:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

add lnworker.main_loop to network.futures so it gets cancelled on exit. fix aiosafe verbosity.

Browse source
This commit is contained in:
ThomasV 2018-07-14 18:42:11 +02:00 • committed by SomberNight
parent e7a1f6b7cb
commit 2fd3a1ca72
No known key found for this signature in database
GPG key ID: B33B5F232C6271E9
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
electrum/lnbase.py
View file

@ -275,7 +275,7 @@ def aiosafe(f):
try: try:
return await f(*args, **kwargs) return await f(*args, **kwargs)
except BaseException as e: except BaseException as e:
self.print_msg("Exception in", f.__name__, ":", e.__class__.__name__, str(e)) self.print_error("Exception in", f.__name__, ":", e.__class__.__name__, str(e))
self.exception = e self.exception = e
return f2 return f2

2
electrum/lnworker.py
View file

@ -46,7 +46,7 @@ class LNWorker(PrintError):
# wait until we see confirmations # wait until we see confirmations
self.network.register_callback(self.on_network_update, ['updated', 'verified']) # thread safe self.network.register_callback(self.on_network_update, ['updated', 'verified']) # thread safe
self.on_network_update('updated') # shortcut (don't block) if funding tx locked and verified self.on_network_update('updated') # shortcut (don't block) if funding tx locked and verified
asyncio.run_coroutine_threadsafe(self.main_loop(), asyncio.get_event_loop()) self.network.futures.append(asyncio.run_coroutine_threadsafe(self.main_loop(), asyncio.get_event_loop()))
def channels_for_peer(self, node_id): def channels_for_peer(self, node_id):
assert type(node_id) is bytes assert type(node_id) is bytes