From de825b61e62b0c4730dff7fb42d4ac39e918026c Mon Sep 17 00:00:00 2001
From: Andrew Osheroff <andrewosh@gmail.com>
Date: Fri, 24 Jan 2020 10:31:51 +0100
Subject: [PATCH] Added fuse timeout read test

---
 test/read.js | 69 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 69 insertions(+)

diff --git a/test/read.js b/test/read.js
index 3115a27..fe24e68 100644
--- a/test/read.js
+++ b/test/read.js
@@ -62,3 +62,72 @@ tape('read', function (t) {
     })
   })
 })
+
+// Skipped because this test takes 2 minutes to run.
+tape.skip('read timeout does not force unmount', function (t) {
+  var ops = {
+    force: true,
+    readdir: function (path, cb) {
+      if (path === '/') return process.nextTick(cb, null, ['test'])
+      return process.nextTick(cb, Fuse.ENOENT)
+    },
+    getattr: function (path, cb) {
+      if (path === '/') return process.nextTick(cb, null, stat({ mode: 'dir', size: 4096 }))
+      if (path === '/test') return process.nextTick(cb, null, stat({ mode: 'file', size: 11 }))
+      if (path === '/timeout') return process.nextTick(cb, null, stat({ mode: 'file', size: 11 }))
+      return process.nextTick(cb, Fuse.ENOENT)
+    },
+    open: function (path, flags, cb) {
+      return process.nextTick(cb, 0, 42)
+    },
+    release: function (path, fd, cb) {
+      t.same(fd, 42, 'fd was passed to release')
+      return process.nextTick(cb, 0)
+    },
+    read: function (path, fd, buf, len, pos, cb) {
+      if (path === '/test') {
+        var str = 'hello world'.slice(pos, pos + len)
+        if (!str) return process.nextTick(cb, 0)
+        buf.write(str)
+        return process.nextTick(cb, str.length)
+      } else if (path === '/timeout') {
+        console.log('read is gonna time out')
+        // Just let this one timeout
+        return
+      }
+      return cb(-2)
+    }
+  }
+
+  const fuse = new Fuse(mnt, ops, { debug: false })
+  fuse.mount(function (err) {
+    t.error(err, 'no error')
+
+    fs.readFile(path.join(mnt, 'test'), function (err, buf) {
+      t.error(err, 'no error')
+      t.same(buf, Buffer.from('hello world'), 'read file')
+
+      // Start the read that will time out, wait a bit, then ensure that the second read works.
+      console.time('timeout')
+      fs.readFile(path.join(mnt, 'timeout'), function (err, buf) {
+        console.timeEnd('timeout')
+        console.log('the read timed out')
+        t.true(err)
+      })
+
+      // The default FUSE timeout is 2 minutes, so wait another second after the timeout.
+      setTimeout(function () {
+        console.log('reading from test')
+        fs.readFile(path.join(mnt, 'test'), function (err, buf) {
+          t.error(err, 'no error')
+          t.same(buf, Buffer.from('hello world'), 'read file')
+          unmount(fuse, function () {
+            t.end()
+          })
+        })
+      }, 1000 * 121)
+    })
+  })
+})
+
+