Skip to content

Commit

Permalink
Info span for send
Browse files Browse the repository at this point in the history
  • Loading branch information
akoshelev committed Dec 5, 2023
1 parent 6211d6a commit 8d32357
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion ipa-core/src/helpers/buffers/ordering_sender.rs
Original file line number Diff line number Diff line change
Expand Up @@ -385,7 +385,7 @@ impl OrderingSender {

if let Poll::Ready(v) = b.take(cx) {
self.waiting.wake(self.next.load(Acquire));
tracing::trace!("Sending next {} bytes", v.len());
tracing::info!("Sending next {} bytes", v.len());
Poll::Ready(Some(v))
} else if b.closed {
Poll::Ready(None)
Expand Down
2 changes: 1 addition & 1 deletion ipa-core/src/helpers/gateway/send.rs
Original file line number Diff line number Diff line change
Expand Up @@ -181,7 +181,7 @@ impl Stream for GatewaySendStream {

fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
let channel_id = &self.inner.channel_id;
let span = tracing::trace_span!("send", to = ?channel_id.role, gate = ?channel_id.gate);
let span = tracing::info_span!("send", to = ?channel_id.role, gate = ?channel_id.gate);
let _enter = span.enter();
Pin::get_mut(self).inner.ordering_tx.take_next(cx)
}
Expand Down

0 comments on commit 8d32357

Please sign in to comment.