Skip to content

Commit

Permalink
Log waker vtable
Browse files Browse the repository at this point in the history
  • Loading branch information
akoshelev committed Dec 7, 2023
1 parent 049768b commit 96cf341
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions ipa-core/src/helpers/buffers/unordered_receiver.rs
Original file line number Diff line number Diff line change
Expand Up @@ -198,6 +198,7 @@ where
// to be woken when we invoke the waker we get.
assert!(waker.will_wake(old));
}
tracing::trace!("Save waker for i = {i}: {:?} ", waker);
self.wakers[index] = Some(waker);
}
}
Expand All @@ -208,6 +209,7 @@ where
tracing::trace!("Waking up next in line: {} ", self.next);
let index = self.next % self.wakers.len();
if let Some(w) = self.wakers[index].take() {
tracing::trace!("Wake waker for i = {}: {:?} ", self.next, w);
w.wake();
} else {
tracing::trace!("No waker for {}", self.next)
Expand All @@ -230,9 +232,7 @@ where
fn poll_next<M: Message>(&mut self, cx: &mut Context<'_>) -> Poll<Result<M, Error>> {
self.max_polled_idx = std::cmp::max(self.max_polled_idx, self.next);
if let Some(m) = self.spare.read() {
let this_recv = self.next;
self.wake_next();
tracing::trace!("Resolved receiver at {this_recv}, next one is {}", self.next);
return Poll::Ready(Ok(m));
}

Expand Down

0 comments on commit 96cf341

Please sign in to comment.