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

Restore simulation

Browse source
This commit is contained in:
Igor Katson 2024-05-03 11:38:47 +01:00
parent 86c95e7c71
commit 16a28a4d96
2 changed files with 8 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -105,9 +105,9 @@ impl<H: PeerConnectionHandler> PeerConnection<H> {
) -> anyhow::Result<()> { ) -> anyhow::Result<()> {
use tokio::io::AsyncWriteExt; use tokio::io::AsyncWriteExt;
// if self.addr.ip().to_string() != "213.189.217.38" { if self.addr.ip().to_string() != "213.189.217.38" {
// bail!("bad ip") bail!("bad ip")
// } }
let rwtimeout = self let rwtimeout = self
.options .options
@ -153,9 +153,9 @@ impl<H: PeerConnectionHandler> PeerConnection<H> {
&self, &self,
outgoing_chan: tokio::sync::mpsc::UnboundedReceiver<WriterRequest>, outgoing_chan: tokio::sync::mpsc::UnboundedReceiver<WriterRequest>,
) -> anyhow::Result<()> { ) -> anyhow::Result<()> {
// if self.addr.ip().to_string() != "213.189.217.38" { if self.addr.ip().to_string() != "213.189.217.38" {
// bail!("bad ip") bail!("bad ip")
// } }
use tokio::io::AsyncWriteExt; use tokio::io::AsyncWriteExt;
let rwtimeout = self let rwtimeout = self

4
crates/rqbit/src/main.rs
View file

@ -300,8 +300,8 @@ async fn async_main(opts: Opts) -> anyhow::Result<()> {
default_defer_writes: opts.defer_writes, default_defer_writes: opts.defer_writes,
default_storage_factory: Some({ default_storage_factory: Some({
fn wrap<S: StorageFactory + Clone>(s: S) -> impl StorageFactory { 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) // TimingStorageFactory::new("hdd".to_owned(), s)
} }
if opts.experimental_mmap_storage { if opts.experimental_mmap_storage {