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

node: Connect to peers on startup 

We run `maintain_connections` on initialization so that we're
immediately connected to some peers from our address book.
This commit is contained in:
cloudhead 2023-08-07 13:41:09 +02:00
parent 27865a26b2
commit 508cf4f68c
No known key found for this signature in database
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -428,6 +428,8 @@ where
.repo_policies()? .repo_policies()?
.filter_map(|t| (t.policy == tracking::Policy::Track).then_some(t.id)), .filter_map(|t| (t.policy == tracking::Policy::Track).then_some(t.id)),
); );
// Try to establish some connections.
self.maintain_connections();
// Start periodic tasks. // Start periodic tasks.
self.outbox.wakeup(IDLE_INTERVAL); self.outbox.wakeup(IDLE_INTERVAL);

5
radicle-node/src/tests.rs
View File

@ -1015,7 +1015,6 @@ fn test_maintain_connections() {
]; ];
let mut alice = Peer::new("alice", [7, 7, 7, 7]); let mut alice = Peer::new("alice", [7, 7, 7, 7]);
alice.import_addresses(&unconnected);
for peer in connected.iter() { for peer in connected.iter() {
alice.connect_to(peer); alice.connect_to(peer);
@ -1023,8 +1022,10 @@ fn test_maintain_connections() {
assert_eq!( assert_eq!(
connected.len(), connected.len(),
alice.sessions().len(), alice.sessions().len(),
"alice should be connected to all peers" "alice should be connected to the first set of peers"
); );
// We now import the other addresses.
alice.import_addresses(&unconnected);
// A transient error such as this will cause Alice to attempt a reconnection. // A transient error such as this will cause Alice to attempt a reconnection.
let error = Arc::new(io::Error::from(io::ErrorKind::ConnectionReset)); let error = Arc::new(io::Error::from(io::ErrorKind::ConnectionReset));