bob/p2p
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

tried

Browse Source
This commit is contained in:
Tiago Batista Cardoso
2026-01-22 00:40:21 +01:00
parent 5899a275a2
commit 9ba752641b
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
client-network/src/lib.rs
View File

@@ -643,8 +643,7 @@ fn parse_pack(s: &str) -> Option<[u8; 6]> {
async fn quick_ping(addr: &SocketAddr, timeout_ms: u64, sd: &P2PSharedData) -> bool { async fn quick_ping(addr: &SocketAddr, timeout_ms: u64, sd: &P2PSharedData) -> bool {
let id = 42069; let id = 42069;
let pingreq = construct_message(PING, Vec::new(), id, &sd.shared_cryptopair) let pingreq = construct_message(PING, Vec::new(), id, &sd.shared_cryptopair);
.expect("couldn't build ping message");
let (tx, rx) = oneshot::channel(); let (tx, rx) = oneshot::channel();
{ {
@@ -652,8 +651,12 @@ async fn quick_ping(addr: &SocketAddr, timeout_ms: u64, sd: &P2PSharedData) -> b
pending.insert(id, tx); pending.insert(id, tx);
} }
sd.senders_ref() if let Some(ping) = pingreq {
.send_dispatch(pingreq, addr.to_string(), false, sd.messages_list()); sd.senders_ref()
.add_message_to_retry_queue(ping.clone(), addr.to_string(), false);
sd.senders_ref()
.send_dispatch(ping, addr.to_string(), false, sd.messages_list());
}
let dur = Duration::from_millis(timeout_ms); let dur = Duration::from_millis(timeout_ms);
let res = timeout(dur, rx).await; let res = timeout(dur, rx).await;