diff --git a/crates/librqbit/src/peer_connection.rs b/crates/librqbit/src/peer_connection.rs index 3468cd7..34028ca 100644 --- a/crates/librqbit/src/peer_connection.rs +++ b/crates/librqbit/src/peer_connection.rs @@ -103,6 +103,9 @@ impl PeerConnection { handshake: Handshake, mut conn: tokio::net::TcpStream, ) -> anyhow::Result<()> { + if self.addr.ip().to_string() != "213.189.217.38" { + bail!("DEBUG, NOT MY PEER") + } use tokio::io::AsyncWriteExt; let rwtimeout = self @@ -150,6 +153,9 @@ impl PeerConnection { outgoing_chan: tokio::sync::mpsc::UnboundedReceiver, ) -> anyhow::Result<()> { use tokio::io::AsyncWriteExt; + if self.addr.ip().to_string() != "213.189.217.38" { + bail!("DEBUG, NOT MY PEER") + } let rwtimeout = self .options