From 86c95e7c71b67ac4818ff77f1fc7eb0d31768bcf Mon Sep 17 00:00:00 2001
From: Igor Katson <igor.katson@gmail.com>
Date: Fri, 3 May 2024 11:24:10 +0100
Subject: [PATCH] Checking once more

---
 crates/librqbit/src/peer_connection.rs | 12 ++++++------
 crates/rqbit/src/main.rs               |  3 ++-
 2 files changed, 8 insertions(+), 7 deletions(-)

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<H: PeerConnectionHandler> PeerConnection<H> {
     ) -> 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<H: PeerConnectionHandler> PeerConnection<H> {
         &self,
         outgoing_chan: tokio::sync::mpsc::UnboundedReceiver<WriterRequest>,
     ) -> 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: StorageFactory + Clone>(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 {