fix race between lnwatcher/lnworker

channels were sometimes not getting re-established
This commit is contained in:
SomberNight 2018-10-05 19:11:24 +02:00
parent 8a14993f9b
commit 3e1862bb94
No known key found for this signature in database
GPG key ID: B33B5F232C6271E9

View file

@ -93,7 +93,8 @@ class LNWatcher(PrintError):
e_tx2 = EncumberedTransaction.from_json(e_tx)
self.sweepstore[funding_outpoint][ctx_txid].add(e_tx2)
self.network.register_callback(self.on_network_update, ['network_updated', 'blockchain_updated', 'verified'])
self.network.register_callback(self.on_network_update,
['network_updated', 'blockchain_updated', 'verified', 'wallet_updated'])
def write_to_disk(self):
# FIXME: json => every update takes linear instead of constant disk write
@ -128,7 +129,7 @@ class LNWatcher(PrintError):
@aiosafe
async def on_network_update(self, event, *args):
if event == 'verified':
if event in ('verified', 'wallet_updated'):
wallet = args[0]
if wallet != self.addr_sync:
return