mirror of
https://github.com/LBRYFoundation/LBRY-Vault.git
synced 2025-08-31 01:11:35 +00:00
start channel verifier in network.start()
This commit is contained in:
parent
d4527b84c1
commit
1a108b86f8
2 changed files with 5 additions and 3 deletions
|
@ -160,7 +160,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):
|
||||
|
|
|
@ -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()
|
||||
|
||||
|
|
Loading…
Add table
Reference in a new issue