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

Correct recv to try_recv when exhausting channel

Browse source
This commit is contained in:
Luke Parker 2024-04-23 12:38:59 -04:00
parent 19e68f7f75
commit cc7202e0bf
No known key found for this signature in database
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
coordinator/src/p2p.rs
View file

@ -370,7 +370,7 @@ 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 // TODO: If a network has less than TARGET_PEERS, this will cause retries ad infinitum
const TARGET_PEERS: usize = 8; 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
@ -472,7 +472,7 @@ impl LibP2p {
// Drain the chainnel, de-duplicating any networks in it // Drain the chainnel, de-duplicating any networks in it
let mut connect_to_network_networks = HashSet::new(); let mut connect_to_network_networks = HashSet::new();
while let Some(network) = connect_to_network_recv.recv().await { while let Ok(network) = connect_to_network_recv.try_recv() {
connect_to_network_networks.insert(network); connect_to_network_networks.insert(network);
} }
for network in connect_to_network_networks { for network in connect_to_network_networks {