mirror of
https://github.com/LBRYFoundation/LBRY-Vault.git
synced 2025-09-03 02:35:20 +00:00
lnworker.reestablish_peer_for_given_channel: give each addr a chance
follow-up fa0ef9c548
This commit is contained in:
parent
b36e9a6451
commit
35a8812534
1 changed files with 9 additions and 1 deletions
|
@ -1336,7 +1336,15 @@ class LNWallet(LNWorker):
|
||||||
peer_addresses.append(LNPeerAddr(host, port, chan.node_id))
|
peer_addresses.append(LNPeerAddr(host, port, chan.node_id))
|
||||||
# will try addresses stored in channel storage
|
# will try addresses stored in channel storage
|
||||||
peer_addresses += list(chan.get_peer_addresses())
|
peer_addresses += list(chan.get_peer_addresses())
|
||||||
# now select first one that has not failed recently
|
# Now select first one that has not failed recently.
|
||||||
|
# Use long retry interval to check. This ensures each address we gathered gets a chance.
|
||||||
|
for peer in peer_addresses:
|
||||||
|
last_tried = self._last_tried_peer.get(peer, 0)
|
||||||
|
if last_tried + PEER_RETRY_INTERVAL < now:
|
||||||
|
await self._add_peer(peer.host, peer.port, peer.pubkey)
|
||||||
|
return
|
||||||
|
# Still here? That means all addresses failed ~recently.
|
||||||
|
# Use short retry interval now.
|
||||||
for peer in peer_addresses:
|
for peer in peer_addresses:
|
||||||
last_tried = self._last_tried_peer.get(peer, 0)
|
last_tried = self._last_tried_peer.get(peer, 0)
|
||||||
if last_tried + PEER_RETRY_INTERVAL_FOR_CHANNELS < now:
|
if last_tried + PEER_RETRY_INTERVAL_FOR_CHANNELS < now:
|
||||||
|
|
Loading…
Add table
Reference in a new issue