AaronFiore/electrum
1
0
Fork 0
Code Activity

Merge pull request #10422 from SomberNight/202601_lnpeer_diag_name

Browse Source 
lnpeer: log name of wallet file in each line
This commit is contained in:
ghost43
2026-01-19 17:11:34 +00:00
committed by GitHub
parent 64f6ae829d 0ae10b2a7b
commit 4394231d89
2 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
electrum/lnpeer.py
View File

@@ -199,7 +199,8 @@ class Peer(Logger, EventListener):
return chan return chan
def diagnostic_name(self): 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): async def ping_if_required(self):
if time.time() - self.last_message_time > 30: if time.time() - self.last_message_time > 30:

6
electrum/lnworker.py
View File

@@ -225,7 +225,6 @@ class LNPeerManager(Logger, EventListener, NetworkRetryManager[LNPeerAddr]):
features: LnFeatures, features: LnFeatures,
config: 'SimpleConfig', config: 'SimpleConfig',
): ):
Logger.__init__(self)
NetworkRetryManager.__init__( NetworkRetryManager.__init__(
self, self,
max_retry_delay_normal=3600, max_retry_delay_normal=3600,
@@ -236,6 +235,7 @@ class LNPeerManager(Logger, EventListener, NetworkRetryManager[LNPeerAddr]):
self.lock = threading.RLock() self.lock = threading.RLock()
self.node_keypair = node_keypair self.node_keypair = node_keypair
self._lnwallet_or_lngossip = lnwallet_or_lngossip self._lnwallet_or_lngossip = lnwallet_or_lngossip
Logger.__init__(self)
self._peers = {} # type: Dict[bytes, Peer] # pubkey -> Peer # needs self.lock 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._channelless_incoming_peers = set() # type: Set[bytes] # node_ids # needs self.lock
self.taskgroup = OldTaskGroup() self.taskgroup = OldTaskGroup()
@@ -246,6 +246,10 @@ class LNPeerManager(Logger, EventListener, NetworkRetryManager[LNPeerAddr]):
self.stopping_soon = False # whether we are being shut down self.stopping_soon = False # whether we are being shut down
self.register_callbacks() self.register_callbacks()
def diagnostic_name(self):
lnw = self._lnwallet_or_lngossip
return lnw.diagnostic_name() or lnw.__class__.__name__
@property @property
def channel_db(self) -> 'ChannelDB': def channel_db(self) -> 'ChannelDB':
return self.network.channel_db if self.network else None return self.network.channel_db if self.network else None