diff --git a/crates/librqbit/src/peer_connection.rs b/crates/librqbit/src/peer_connection.rs index 106367f..127966d 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 5c907e8..a32791a 100644 --- a/crates/rqbit/src/main.rs +++ b/crates/rqbit/src/main.rs @@ -300,7 +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(), SlowStorageFactory::new(s)) + TimingStorageFactory::new("hdd".to_owned(), s) } if opts.experimental_mmap_storage {