mab122
/
radicle-heartwood-lfs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

node: use term 'session' over 'peer' 

Keep up to date with recent changes of renaming service.peers to
service.sessions.

Signed-off-by: Slack Coder <slackcoder@server.ky>
This commit is contained in:
Slack Coder 2022-11-07 07:50:09 -05:00
parent a91dcfb100
commit ff045e0813
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
radicle-node/src/service.rs
View File

@ -544,11 +544,11 @@ where
debug!("Disconnected from {} ({})", ip, reason); debug!("Disconnected from {} ({})", ip, reason);
if let Some(peer) = self.sessions.get_mut(&ip) { if let Some(session) = self.sessions.get_mut(&ip) {
peer.state = session::State::Disconnected { since }; session.state = session::State::Disconnected { since };
// Attempt to re-connect to persistent peers. // Attempt to re-connect to persistent peers.
if self.config.is_persistent(&address) && peer.attempts() < MAX_CONNECTION_ATTEMPTS { if self.config.is_persistent(&address) && session.attempts() < MAX_CONNECTION_ATTEMPTS {
if reason.is_dial_err() { if reason.is_dial_err() {
return; return;
} }
@ -559,7 +559,11 @@ where
} }
// TODO: Eventually we want a delay before attempting a reconnection, // TODO: Eventually we want a delay before attempting a reconnection,
// with exponential back-off. // with exponential back-off.
debug!("Reconnecting to {} (attempts={})...", ip, peer.attempts()); debug!(
"Reconnecting to {} (attempts={})...",
ip,
session.attempts()
);
// TODO: Try to reconnect only if the peer was attempted. A disconnect without // TODO: Try to reconnect only if the peer was attempted. A disconnect without
// even a successful attempt means that we're unlikely to be able to reconnect. // even a successful attempt means that we're unlikely to be able to reconnect.