Ecosystem/serai
Ecosystem/serai
1
0
Fork 0
mirror of https://github.com/serai-dex/serai.git synced 2025-01-03 17:40:34 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Use a constant for the target amount of peer

Browse source
This commit is contained in:
Luke Parker 2024-04-23 11:59:38 -04:00
parent 43dc036660
commit d94c9a4a5e
No known key found for this signature in database
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
coordinator/src/p2p.rs
View file

@ -370,6 +370,9 @@ impl LibP2p {
IdentTopic::new(format!("{LIBP2P_TOPIC}-{}", hex::encode(set.encode()))) IdentTopic::new(format!("{LIBP2P_TOPIC}-{}", hex::encode(set.encode())))
} }
// TODO: If a network has less than TARGET_PEERS, this will cause retried ad infinitum
const TARGET_PEERS: usize = 8;
// The addrs we're currently dialing, and the networks associated with them // The addrs we're currently dialing, and the networks associated with them
let dialing_peers = Arc::new(RwLock::new(HashMap::new())); let dialing_peers = Arc::new(RwLock::new(HashMap::new()));
// The peers we're currently connected to, and the networks associated with them // The peers we're currently connected to, and the networks associated with them
@ -448,7 +451,7 @@ impl LibP2p {
} }
} }
// If we do not, start connecting to this network again // If we do not, start connecting to this network again
if remaining_peers < 3 { if remaining_peers < TARGET_PEERS {
connect_to_network_send.send(net).expect( connect_to_network_send.send(net).expect(
"couldn't send net to connect to due to disconnects (receiver dropped?)", "couldn't send net to connect to due to disconnects (receiver dropped?)",
); );
@ -476,7 +479,7 @@ impl LibP2p {
if let Ok(mut nodes) = serai.p2p_validators(network).await { if let Ok(mut nodes) = serai.p2p_validators(network).await {
// If there's an insufficient amount of nodes known, connect to all yet add it // If there's an insufficient amount of nodes known, connect to all yet add it
// back and break // back and break
if nodes.len() < 3 { if nodes.len() < TARGET_PEERS {
log::warn!( log::warn!(
"insufficient amount of P2P nodes known for {:?}: {}", "insufficient amount of P2P nodes known for {:?}: {}",
network, network,
@ -643,7 +646,7 @@ impl LibP2p {
} }
} }
// If we do not, start connecting to this network again // If we do not, start connecting to this network again
if remaining_peers < 3 { if remaining_peers < TARGET_PEERS {
connect_to_network_send connect_to_network_send
.send(net) .send(net)
.expect( .expect(