LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-08-28 07:51:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

redundant: you subscribed only to 'updated'

Browse source
This commit is contained in:
ThomasV 2018-04-21 14:53:25 +02:00 • committed by SomberNight
parent 8ee71b623f
commit ea41d6f0f3
No known key found for this signature in database
GPG key ID: B33B5F232C6271E9
1 changed files with 11 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
lib/lnbase.py
View file

@ -797,20 +797,17 @@ class Peer(PrintError):
assert success assert success
# wait until we see confirmations # wait until we see confirmations
def on_network_update(event, *args): def on_network_update(event, *args):
if event == 'updated': conf = wallet.get_tx_height(funding_txid)[1]
conf = wallet.get_tx_height(funding_txid)[1] if conf >= funding_txn_minimum_depth:
if conf >= funding_txn_minimum_depth: async def set_local_funding_locked_result():
async def set_local_funding_locked_result(): try:
try: self.local_funding_locked[channel_id].set_result(1)
self.local_funding_locked[channel_id].set_result(1) except (asyncio.InvalidStateError, KeyError) as e:
except (asyncio.InvalidStateError, KeyError) as e: # FIXME race condition if updates come in quickly, set_result might be called multiple times
# FIXME race condition if updates come in quickly, set_result might be called multiple times # or self.local_funding_locked[channel_id] might be deleted already
# or self.local_funding_locked[channel_id] might be deleted already self.print_error('local_funding_locked.set_result error for channel {}: {}'.format(channel_id, e))
self.print_error('local_funding_locked.set_result error for channel {}: {}'.format(channel_id, e)) asyncio.run_coroutine_threadsafe(set_local_funding_locked_result(), asyncio.get_event_loop())
asyncio.run_coroutine_threadsafe(set_local_funding_locked_result(), asyncio.get_event_loop()) self.network.unregister_callback(on_network_update)
self.network.unregister_callback(on_network_update)
else:
self.print_error("unexpected network message:", event, args)
self.network.register_callback(on_network_update, ['updated']) # thread safe self.network.register_callback(on_network_update, ['updated']) # thread safe
try: try: