diff --git a/electrum/lnpeer.py b/electrum/lnpeer.py index 2809a7909..f10d556c0 100644 --- a/electrum/lnpeer.py +++ b/electrum/lnpeer.py @@ -199,7 +199,8 @@ class Peer(Logger, EventListener): return chan def diagnostic_name(self): - return self.lnworker.__class__.__name__ + ', ' + self.transport.name() + lnw_name = self.lnworker.diagnostic_name() or self.lnworker.__class__.__name__ + return lnw_name + ', ' + self.transport.name() async def ping_if_required(self): if time.time() - self.last_message_time > 30: diff --git a/electrum/lnworker.py b/electrum/lnworker.py index 453de6da2..4270dad72 100644 --- a/electrum/lnworker.py +++ b/electrum/lnworker.py @@ -225,7 +225,6 @@ class LNPeerManager(Logger, EventListener, NetworkRetryManager[LNPeerAddr]): features: LnFeatures, config: 'SimpleConfig', ): - Logger.__init__(self) NetworkRetryManager.__init__( self, max_retry_delay_normal=3600, @@ -236,6 +235,7 @@ class LNPeerManager(Logger, EventListener, NetworkRetryManager[LNPeerAddr]): self.lock = threading.RLock() self.node_keypair = node_keypair self._lnwallet_or_lngossip = lnwallet_or_lngossip + Logger.__init__(self) self._peers = {} # type: Dict[bytes, Peer] # pubkey -> Peer # needs self.lock self._channelless_incoming_peers = set() # type: Set[bytes] # node_ids # needs self.lock self.taskgroup = OldTaskGroup() @@ -246,6 +246,10 @@ class LNPeerManager(Logger, EventListener, NetworkRetryManager[LNPeerAddr]): self.stopping_soon = False # whether we are being shut down self.register_callbacks() + def diagnostic_name(self): + lnw = self._lnwallet_or_lngossip + return lnw.diagnostic_name() or lnw.__class__.__name__ + @property def channel_db(self) -> 'ChannelDB': return self.network.channel_db if self.network else None