diff --git a/crates/librqbit/src/peer_connection.rs b/crates/librqbit/src/peer_connection.rs index 127966d..106367f 100644 --- a/crates/librqbit/src/peer_connection.rs +++ b/crates/librqbit/src/peer_connection.rs @@ -105,9 +105,9 @@ impl PeerConnection { ) -> anyhow::Result<()> { use tokio::io::AsyncWriteExt; - // if self.addr.ip().to_string() != "213.189.217.38" { - // bail!("bad ip") - // } + if self.addr.ip().to_string() != "213.189.217.38" { + bail!("bad ip") + } let rwtimeout = self .options @@ -153,9 +153,9 @@ impl PeerConnection { &self, outgoing_chan: tokio::sync::mpsc::UnboundedReceiver, ) -> anyhow::Result<()> { - // if self.addr.ip().to_string() != "213.189.217.38" { - // bail!("bad ip") - // } + if self.addr.ip().to_string() != "213.189.217.38" { + bail!("bad ip") + } use tokio::io::AsyncWriteExt; let rwtimeout = self diff --git a/crates/rqbit/src/main.rs b/crates/rqbit/src/main.rs index a32791a..606db83 100644 --- a/crates/rqbit/src/main.rs +++ b/crates/rqbit/src/main.rs @@ -300,8 +300,8 @@ async fn async_main(opts: Opts) -> anyhow::Result<()> { default_defer_writes: opts.defer_writes, default_storage_factory: Some({ fn wrap(s: S) -> impl StorageFactory { - // TimingStorageFactory::new("hdd".to_owned(), SlowStorageFactory::new(s)) - TimingStorageFactory::new("hdd".to_owned(), s) + TimingStorageFactory::new("hdd".to_owned(), SlowStorageFactory::new(s)) + // TimingStorageFactory::new("hdd".to_owned(), s) } if opts.experimental_mmap_storage {