From edb93c58fd942c9f8683dae82b726f76e79de706 Mon Sep 17 00:00:00 2001 From: Alex Koshelev Date: Wed, 6 Dec 2023 21:11:25 -0800 Subject: [PATCH] More logging inside UR --- ipa-core/src/helpers/buffers/unordered_receiver.rs | 4 ++++ 1 file changed, 4 insertions(+) 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();