Browse Source

start channel verifier in network.start()

dependabot/pip/contrib/deterministic-build/ecdsa-0.13.3
ThomasV 6 years ago
parent
commit
5a081b2131
  1. 6
      electrum/daemon.py
  2. 2
      electrum/lnrouter.py

6
electrum/daemon.py

@ -166,7 +166,11 @@ class Daemon(DaemonThread):
self.watchtower = WatchTower(self.config, self.network.lnwatcher) if self.config.get('watchtower_host') else None self.watchtower = WatchTower(self.config, self.network.lnwatcher) if self.config.get('watchtower_host') else None
# client-side # client-side
if self.network: if self.network:
self.network.start([self.fx.run, self.network.lnwatcher.watchtower_task]) self.network.start([
self.fx.run,
self.network.lnwatcher.watchtower_task,
self.network.channel_db.ca_verifier.main
])
self.start() self.start()
def init_server(self, config: SimpleConfig, fd): def init_server(self, config: SimpleConfig, fd):

2
electrum/lnrouter.py

@ -281,8 +281,6 @@ class ChannelDB(JsonDB):
self._last_good_address = {} # node_id -> LNPeerAddr self._last_good_address = {} # node_id -> LNPeerAddr
self.ca_verifier = LNChannelVerifier(network, self) self.ca_verifier = LNChannelVerifier(network, self)
# FIXME if the channel verifier raises, it kills network.main_taskgroup
asyncio.run_coroutine_threadsafe(self.network.add_job(self.ca_verifier.main), network.asyncio_loop)
self.load_data() self.load_data()

Loading…
Cancel
Save