From adae697154539e4f05176bad81a651dc74d7b972 Mon Sep 17 00:00:00 2001 From: Maple Nebel Date: Sat, 8 Nov 2025 12:27:17 +0000 Subject: [PATCH] fix resending issues and remove debugging again --- prudpv1/src/prudp/socket.rs | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/prudpv1/src/prudp/socket.rs b/prudpv1/src/prudp/socket.rs index f5fb448..3e88a70 100644 --- a/prudpv1/src/prudp/socket.rs +++ b/prudpv1/src/prudp/socket.rs @@ -659,7 +659,7 @@ impl AnyInternalSocket for InternalSocket { 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 AnyInternalSocket for InternalSocket { 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...")