From aa9653c7951ec28ce3ac2b0d0d993dd61bea5dfd Mon Sep 17 00:00:00 2001
From: iGxnon <igxnon@gmail.com>
Date: Thu, 31 Oct 2024 15:00:15 +0800
Subject: [PATCH] fix: nack buffer reverse

Signed-off-by: iGxnon <igxnon@gmail.com>
---
 src/link.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/link.rs b/src/link.rs
index c75b278..d4cdce3 100644
--- a/src/link.rs
+++ b/src/link.rs
@@ -36,7 +36,7 @@ pub(crate) struct TransferLink {
     /// pending ACK packets to be sent.
     outgoing_ack: parking_lot::Mutex<BinaryHeap<Reverse<u24>>>,
     /// pending NACK packets to be sent.
-    outgoing_nack: parking_lot::Mutex<BTreeSet<Reverse<u24>>>,
+    outgoing_nack: parking_lot::Mutex<BTreeSet<u24>>,
 
     /// data related to unconnected packets awaiting processing.
     unconnected: ConcurrentQueue<unconnected::Packet>,
@@ -157,7 +157,7 @@ impl TransferLink {
     }
 
     pub(crate) fn process_outgoing_nack(&self, mtu: u16) -> Option<AckOrNack> {
-        AckOrNack::extend_from(self.outgoing_nack.lock().iter().map(|v| v.0), mtu)
+        AckOrNack::extend_from(self.outgoing_nack.lock().iter().copied(), mtu)
     }
 
     pub(crate) fn process_unconnected(&self) -> impl Iterator<Item = unconnected::Packet> + '_ {
@@ -226,12 +226,12 @@ impl Route {
                 {
                     let mut nack = self.link.outgoing_nack.lock();
                     let seq_num = frames.seq_num;
-                    nack.remove(&Reverse(seq_num));
+                    nack.remove(&seq_num);
                     let pre_read = self.seq_read;
                     if pre_read <= seq_num {
                         self.seq_read = seq_num + 1;
                         for n in pre_read.to_u32()..seq_num.to_u32() {
-                            nack.insert(Reverse(n.into()));
+                            nack.insert(n.into());
                         }
                     }
                 }