leyoda/rqbit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Prevent self-connections just in case

Browse source
This commit is contained in:
Igor Katson 2023-12-05 22:19:58 +00:00
parent 5e238419f4
commit cc92afcdec
No known key found for this signature in database
GPG key ID: B4EC22B66D61A3F5
1 changed files with 9 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

10
crates/librqbit/src/peer_connection.rs
View file

@ -3,7 +3,7 @@ use std::{
time::{Duration, Instant},
};
use anyhow::Context;
use anyhow::{bail, Context};
use buffers::{ByteBuf, ByteString};
use clone_to_owned::CloneToOwned;
use librqbit_core::{id20::Id20, lengths::ChunkInfo, peer_id::try_decode_peer_id};
@ -142,6 +142,10 @@ impl<H: PeerConnectionHandler> PeerConnection<H> {
anyhow::bail!("wrong info hash");
}
if handshake.peer_id == self.peer_id.0 {
bail!("looks like we are connecting to ourselves");
}
trace!(
"incoming connection: id={:?}",
try_decode_peer_id(Id20(handshake.peer_id))
@ -217,6 +221,10 @@ impl<H: PeerConnectionHandler> PeerConnection<H> {
anyhow::bail!("info hash does not match");
}
if h.peer_id == self.peer_id.0 {
bail!("looks like we are connecting to ourselves");
}
self.handler.on_handshake(h)?;
if read_so_far > size {