Some debug/trace logs

ipa-core/src/helpers/buffers/ordering_sender.rs

@@ -385,6 +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());
             Poll::Ready(Some(v))
         } else if b.closed {
             Poll::Ready(None)

ipa-core/src/helpers/buffers/unordered_receiver.rs

@@ -233,6 +233,7 @@ where
                     return Poll::Pending;
                 }
                 Poll::Ready(Some(b)) => {
+                    tracing::trace!("Received next {} bytes", b.as_ref().len());
                     if let Some(m) = self.spare.extend(b.as_ref()) {
                         self.wake_next();
                         return Poll::Ready(Ok(m));

ipa-core/src/helpers/gateway/send.rs

@@ -180,6 +180,9 @@ impl Stream for GatewaySendStream {
     type Item = Vec<u8>;
 
     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 _enter = span.enter();
         Pin::get_mut(self).inner.ordering_tx.take_next(cx)
     }
 }

ipa-core/src/report.rs

@@ -69,7 +69,7 @@ impl Serializable for EventType {
         match buf[0] {
             0 => EventType::Trigger,
             1 => EventType::Source,
-            v @ 2_u8..=u8::MAX => panic!("Unrecognized event type: {v}"),
+            v@ 2_u8..=u8::MAX => panic!("Unrecognized event type: {v}"),
         }
     }
 }