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

fix resending issues and remove debugging again

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

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

@ -659,7 +659,7 @@ impl<T: CryptoHandler> AnyInternalSocket for InternalSocket<T> {
conn.unacknowleged_packets.retain_mut(|(_, up)| {
!(
collected_ids.iter().any(|id| up.header.sequence_id == *id) ||
up.header.sequence_id < packet.header.sequence_id
up.header.sequence_id <= packet.header.sequence_id
)
});
@ -687,16 +687,12 @@ impl<T: CryptoHandler> AnyInternalSocket for InternalSocket<T> {
collected_ids.push(additional_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
up.header.sequence_id <= sequence_id
)
});
println!("post size: {}", conn.unacknowleged_packets.len());
}
} else {
error!("non connection acknowledgement packet on nonexistent connection...")