Log next inside OrderedSender

akoshelev · Dec 6, 2023 · 0d3a74c · 0d3a74c
1 parent 66a7d0f
commit 0d3a74c
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/ipa-core/src/helpers/buffers/ordering_sender.rs b/ipa-core/src/helpers/buffers/ordering_sender.rs
@@ -385,8 +385,9 @@ impl OrderingSender {
         let mut b = self.state.lock().unwrap();
 
         if let Poll::Ready(v) = b.take(cx) {
-            self.waiting.wake(self.next.load(Acquire));
-            tracing::trace!("Sending next {} bytes. stream closed = {}", v.len(), b.closed);
+            let next = self.next.load(Acquire);
+            self.waiting.wake(next);
+            tracing::trace!("Sending next {} bytes. next = {}. stream closed = {}", v.len(), next, b.closed);
             Poll::Ready(Some(v))
         } else if b.closed {
             Poll::Ready(None)