Skip to content

Commit

Permalink
log slot sizes
Browse files Browse the repository at this point in the history
  • Loading branch information
rklaehn committed Aug 15, 2023
1 parent 8aa4052 commit 22d642e
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion src/transport/interprocess.rs
Original file line number Diff line number Diff line change
Expand Up @@ -178,7 +178,6 @@ impl FlumeSocketInner {
meta: &mut [quinn_udp::RecvMeta],
) -> task::Poll<io::Result<usize>> {
let n = bufs.len().min(meta.len());
let n = 1;
if n == 0 {
return task::Poll::Ready(Ok(0));
}
Expand All @@ -204,10 +203,12 @@ impl FlumeSocketInner {
dst_ip: Some(self.local.ip()),
};
tracing::debug!("R {} received {} bytes {}", self.local, packet.data.len(), fp(&packet.data));
tracing::debug!("R {} filling slot {}", self.local, bufs[offset].len());
bufs[offset][..len].copy_from_slice(&packet.data);
meta[offset] = m;
offset += 1;
} else {
tracing::debug!("R {} ignoring packet for {}", self.local, packet.to);
// not for us, ignore
continue;
}
Expand Down

0 comments on commit 22d642e

Please sign in to comment.