Skip to content

Commit

Permalink
More logging inside UR
Browse files Browse the repository at this point in the history
akoshelev committed Dec 7, 2023
1 parent 7608e75 commit edb93c5
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions ipa-core/src/helpers/buffers/unordered_receiver.rs
Original file line number Diff line number Diff line change
@@ -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();

0 comments on commit edb93c5

Please sign in to comment.