Async IO for write data

Cargo.toml

@@ -16,6 +16,7 @@ fxhash = "0.2"
 nix = "0.18.0"
 crossbeam = "0.7"
 thiserror = "1.0"
+futures = { version = "0.3", features = ["thread-pool", "compat"] }
 
 [dev-dependencies]
 raft = { git = "https://github.com/tikv/raft-rs", branch = "master", default-features = false, features = ["protobuf-codec"] }

src/cache_evict.rs

@@ -64,13 +64,8 @@ impl CacheSubmitor {
         self.block_on_full = false;
     }
 
-    pub fn get_cache_tracker(
-        &mut self,
-        file_num: u64,
-        offset: u64,
-        size: usize,
-    ) -> Option<CacheTracker> {
-        if self.cache_limit == 0 || size == 0 {
+    pub fn get_cache_tracker(&mut self, file_num: u64, offset: u64) -> Option<CacheTracker> {
+        if self.cache_limit == 0 {
             return None;
         }
 
@@ -109,14 +104,17 @@ impl CacheSubmitor {
             }
         }
 
-        self.chunk_size += size;
-        self.size_tracker.fetch_add(size, Ordering::Release);
         Some(CacheTracker::new(
             self.global_stats.clone(),
             self.size_tracker.clone(),
         ))
     }
 
+    pub fn fill_chunk(&mut self, size: usize) {
+        self.chunk_size += size;
+        self.size_tracker.fetch_add(size, Ordering::Release);
+    }
+
     fn reset(&mut self, file_num: u64, offset: u64) {
         self.file_num = file_num;
         self.offset = offset;