spacebar/rust-nex
6
0
Fork 0
Code Issues Pull requests Projects Releases Packages 50 Wiki Activity Actions

add debugging to packet acknowledgements

Browse source
This commit is contained in:
Maple Nebel 2025-11-08 12:17:21 +00:00
commit f264f34a18
1 changed files with 14 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

20
prudpv1/src/prudp/socket.rs
View file

@ -4,6 +4,7 @@ use crate::prudp::packet::PacketOption::{
ConnectionSignature, FragmentId, MaximumSubstreamId, SupportedFunctions, ConnectionSignature, FragmentId, MaximumSubstreamId, SupportedFunctions,
}; };
use crate::prudp::packet::{PRUDPV1Header, PRUDPV1Packet, TypesFlags}; use crate::prudp::packet::{PRUDPV1Header, PRUDPV1Packet, TypesFlags};
use md5::digest::generic_array::sequence;
use rnex_core::prudp::virtual_port::VirtualPort; use rnex_core::prudp::virtual_port::VirtualPort;
use rnex_core::prudp::socket_addr::PRUDPSockAddr; use rnex_core::prudp::socket_addr::PRUDPSockAddr;
use async_trait::async_trait; use async_trait::async_trait;
@ -626,6 +627,8 @@ impl<T: CryptoHandler> AnyInternalSocket for InternalSocket<T> {
return; return;
} }
info!("got ack");
if let Some(conn) = self.get_connection(address).await { if let Some(conn) = self.get_connection(address).await {
let mut conn = conn.lock().await; let mut conn = conn.lock().await;
@ -682,13 +685,18 @@ impl<T: CryptoHandler> AnyInternalSocket for InternalSocket<T> {
return; return;
}; };
collected_ids.push(additional_sequence_id); collected_ids.push(additional_sequence_id);
conn.unacknowleged_packets.retain_mut(|(_, up)| {
!(
collected_ids.iter().any(|id| up.header.sequence_id == *id) ||
up.header.sequence_id < sequence_id
)
});
} }
println!("multiack new summary: \n\tup_till_id {}\n\tadditionals {:?}", sequence_id, collected_ids);
println!("pre size: {}", conn.unacknowleged_packets.len());
conn.unacknowleged_packets.retain_mut(|(_, up)| {
!(
collected_ids.iter().any(|id| up.header.sequence_id == *id) ||
up.header.sequence_id < sequence_id
)
});
println!("post size: {}", conn.unacknowleged_packets.len());
} }
} else { } else {
error!("non connection acknowledgement packet on nonexistent connection...") error!("non connection acknowledgement packet on nonexistent connection...")