handle ENOSPC by running the evicter

fixes #1
kahing · Sep 9, 2017 · e83d976 · e83d976
1 parent e3fea8b
commit e83d976
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/src/catfs/mod.rs b/src/catfs/mod.rs
@@ -30,6 +30,8 @@ mod inode;
 mod substr;
 
 use self::inode::Inode;
+use self::flags::DiskSpace;
+use super::evicter::Evicter;
 
 #[derive(Default)]
 struct InodeStore {
@@ -636,6 +638,15 @@ impl CatFS {
                                 reply.error(e2.raw_os_error().unwrap());
                                 return;
                             }
+                        } else if e.errno() == libc::ENOSPC {
+                            debug!(
+                                "write(0x{:016x}, 0x{:016x}, {}) = ENOSPC",
+                                ino,
+                                fh,
+                                data.len()
+                            );
+                            let _ = Evicter::new(self.cache_dir, &DiskSpace::Percent(1.0))
+                                .loop_once();
                         } else {
                             error!(
                                 "<-- !write 0x{:016x} {:?} @ {} = {}",

diff --git a/src/evicter/mod.rs b/src/evicter/mod.rs
@@ -118,7 +118,7 @@ impl Evicter {
         return to_evict(&self.low_watermark, st);
     }
 
-    fn loop_once(&self) -> error::Result<()> {
+    pub fn loop_once(&self) -> error::Result<()> {
         let st = (self.statvfs)(self.dir)?;
 
         let to_evict_bytes = self.should_evict(&st);