fix: pr comments

ethereum · Feb 4, 2025 · d50d831 · d50d831
1 parent da5ae3e
commit d50d831
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/conn.rs b/src/conn.rs
@@ -237,7 +237,7 @@ impl<const N: usize, P: ConnectionPeer> Connection<N, P> {
         mut writes: mpsc::UnboundedReceiver<Write>,
         mut shutdown: oneshot::Receiver<()>,
     ) -> io::Result<()> {
-        tracing::debug!("uTP conn starting... {:?}", self.cid.peer_id);
+        tracing::debug!("uTP conn starting... {:?}", self.peer);
 
         // If we are the initiating endpoint, then send the SYN. If we are the accepting endpoint,
         // then send the SYN-ACK.

diff --git a/src/socket.rs b/src/socket.rs
@@ -96,7 +96,7 @@ where
                         let packet = match Packet::decode(&buf[..n]) {
                             Ok(pkt) => pkt,
                             Err(..) => {
-                                tracing::warn!(?peer_id, "unable to decode uTP packet");
+                                tracing::warn!(?peer, "unable to decode uTP packet");
                                 continue;
                             }
                         };
@@ -115,7 +115,7 @@ where
                             }
                             None => {
                                 if std::matches!(packet.packet_type(), PacketType::Syn) {
-                                    let cid = cid_from_packet::<P>(&packet, peer_id, IdType::RecvId);
+                                    let cid = acc_cid;
 
                                     // If there was an awaiting connection with the CID, then
                                     // create a new stream for that connection. Otherwise, add the