From 0d3a74cabb99072576e0f84e094cf1c455544f96 Mon Sep 17 00:00:00 2001 From: Alex Koshelev Date: Wed, 6 Dec 2023 10:52:42 -0800 Subject: [PATCH] Log next inside OrderedSender --- ipa-core/src/helpers/buffers/ordering_sender.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/ipa-core/src/helpers/buffers/ordering_sender.rs b/ipa-core/src/helpers/buffers/ordering_sender.rs index fcba14972..1f6570eac 100644 --- 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)