diff --git a/ipa-core/src/helpers/buffers/unordered_receiver.rs b/ipa-core/src/helpers/buffers/unordered_receiver.rs index 19726d4b7..f59c3e92f 100644 --- a/ipa-core/src/helpers/buffers/unordered_receiver.rs +++ b/ipa-core/src/helpers/buffers/unordered_receiver.rs @@ -162,6 +162,9 @@ where { /// Determine whether `i` is the next record that we expect to receive. fn is_next(&self, i: usize) -> bool { + if i < self.next { + tracing::warn!("{i} is way behind {}", self.next) + } i == self.next } @@ -201,6 +204,7 @@ where /// Wake the waker from the next future, if the next receiver has been polled. fn wake_next(&mut self) { self.next += 1; + tracing::trace!("Waking up next in line: {} ", self.next); let index = self.next % self.wakers.len(); if let Some(w) = self.wakers[index].take() { w.wake();