tstart channel verifier in network.start() - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit 5a081b2131e7e90b472b191d73ae6204704ade28
DIR parent 626d09b35806a74d9a2a3c3cda04e6f404eb2971
HTML Author: ThomasV <thomasv@electrum.org>
Date: Sun, 14 Oct 2018 15:42:05 +0200
start channel verifier in network.start()
Diffstat:
M electrum/daemon.py | 6 +++++-
M electrum/lnrouter.py | 2 --
2 files changed, 5 insertions(+), 3 deletions(-)
---
DIR diff --git a/electrum/daemon.py b/electrum/daemon.py
t@@ -166,7 +166,11 @@ class Daemon(DaemonThread):
self.watchtower = WatchTower(self.config, self.network.lnwatcher) if self.config.get('watchtower_host') else None
# client-side
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()
def init_server(self, config: SimpleConfig, fd):
DIR diff --git a/electrum/lnrouter.py b/electrum/lnrouter.py
t@@ -281,8 +281,6 @@ class ChannelDB(JsonDB):
self._last_good_address = {} # node_id -> LNPeerAddr
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()