From 052c9f90eaab0faca48b35e95757ed5e431dcb18 Mon Sep 17 00:00:00 2001 From: Ming-Hung Tsai Date: Fri, 30 Jul 2021 01:28:56 +0800 Subject: [PATCH] [thin/cache_repair (rust)] Fix file open options --- src/cache/repair.rs | 4 ++-- src/thin/repair.rs | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/cache/repair.rs b/src/cache/repair.rs index dd88a26..1273da7 100644 --- a/src/cache/repair.rs +++ b/src/cache/repair.rs @@ -32,11 +32,11 @@ fn new_context(opts: &CacheRepairOptions) -> Result { let engine_out: Arc; if opts.async_io { - engine_in = Arc::new(AsyncIoEngine::new(opts.input, MAX_CONCURRENT_IO, true)?); + engine_in = Arc::new(AsyncIoEngine::new(opts.input, MAX_CONCURRENT_IO, false)?); engine_out = Arc::new(AsyncIoEngine::new(opts.output, MAX_CONCURRENT_IO, true)?); } else { let nr_threads = std::cmp::max(8, num_cpus::get() * 2); - engine_in = Arc::new(SyncIoEngine::new(opts.input, nr_threads, true)?); + engine_in = Arc::new(SyncIoEngine::new(opts.input, nr_threads, false)?); engine_out = Arc::new(SyncIoEngine::new(opts.output, nr_threads, true)?); } diff --git a/src/thin/repair.rs b/src/thin/repair.rs index 89d6e09..d4ad6ff 100644 --- a/src/thin/repair.rs +++ b/src/thin/repair.rs @@ -33,11 +33,11 @@ fn new_context(opts: &ThinRepairOptions) -> Result { let engine_out: Arc; if opts.async_io { - engine_in = Arc::new(AsyncIoEngine::new(opts.input, MAX_CONCURRENT_IO, true)?); + engine_in = Arc::new(AsyncIoEngine::new(opts.input, MAX_CONCURRENT_IO, false)?); engine_out = Arc::new(AsyncIoEngine::new(opts.output, MAX_CONCURRENT_IO, true)?); } else { let nr_threads = std::cmp::max(8, num_cpus::get() * 2); - engine_in = Arc::new(SyncIoEngine::new(opts.input, nr_threads, true)?); + engine_in = Arc::new(SyncIoEngine::new(opts.input, nr_threads, false)?); engine_out = Arc::new(SyncIoEngine::new(opts.output, nr_threads, true)?); }