add test for big files

test/big.js

@@ -0,0 +1,104 @@
+const tape = require('tape')
+const fs = require('fs')
+const path = require('path')
+const concat = require('concat-stream')
+
+const Fuse = require('../')
+const mnt = require('./fixtures/mnt')
+const stat = require('./fixtures/stat')
+const { unmount } = require('./helpers')
+
+tape('read', function (t) {
+  let size = 0
+  const reads = [0, 4 * 1024 * 1024 * 1024, 6 * 1024 * 1024 * 1024]
+  const writes = [0, 4 * 1024 * 1024 * 1024, 6 * 1024 * 1024 * 1024]
+
+  var ops = {
+    force: true,
+    readdir (path, cb) {
+      if (path === '/') return process.nextTick(cb, null, ['test'])
+      return process.nextTick(cb, Fuse.ENOENT)
+    },
+    getattr (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, mtime: new Date() }))
+      return process.nextTick(cb, Fuse.ENOENT)
+    },
+    open (path, flags, cb) {
+      return process.nextTick(cb, 0, 42)
+    },
+    release (path, fd, cb) {
+      t.same(fd, 42, 'fd was passed to release')
+      return process.nextTick(cb, 0)
+    },
+    read (path, fd, buf, len, pos, cb) {
+      t.same(pos, reads.shift(), 'read is expected')
+      buf.fill(0)
+      if (pos + len > size) return cb(Math.max(size - pos, 0))
+      cb(len)
+    },
+    ftruncate (path, fd, len, cb) {
+      size = len
+      cb(0)
+    },
+    truncate (path, len, cb) {
+      size = len
+      cb(0)
+    },
+    write (path, fd, buf, len, pos, cb) {
+      if (!writes.length) return cb(-1)
+      t.same(pos, writes.shift(), 'write is expected')
+      size = Math.max(pos + len, size)
+      cb(len)
+    }
+  }
+
+  const fuse = new Fuse(mnt, ops, { debug: !true, autoCache: true })
+  fuse.mount(function (err) {
+    t.error(err, 'no error')
+
+    fs.open(path.join(mnt, 'test'), 'w+', function (_, fd) {
+      run(
+        (_, cb) => fs.fstat(fd, cb),
+        checkSize(0),
+        (_, cb) => fs.ftruncate(fd, 4 * 1024 * 1024 * 1024 + 1, cb),
+        (_, cb) => fs.fstat(fd, cb),
+        checkSize(4 * 1024 * 1024 * 1024 + 1),
+        (_, cb) => fs.truncate(path.join(mnt, 'test'), 6 * 1024 * 1024 * 1024 + 2, cb),
+        (_, cb) => fs.fstat(fd, cb),
+        checkSize(6 * 1024 * 1024 * 1024 + 2),
+        (_, cb) => fs.write(fd, Buffer.alloc(4096), 0, 4096, 0, cb),
+        (_, cb) => fs.write(fd, Buffer.alloc(4096), 0, 4096, 4 * 1024 * 1024 * 1024, cb),
+        (_, cb) => fs.write(fd, Buffer.alloc(4096), 0, 4096, 6 * 1024 * 1024 * 1024, cb),
+        (_, cb) => fs.fstat(fd, cb),
+        checkSize(6 * 1024 * 1024 * 1024 + 4096),
+        (_, cb) => fs.read(fd, Buffer.alloc(4096), 0, 4096, 0, cb),
+        (_, cb) => fs.read(fd, Buffer.alloc(4096), 0, 4096, 4 * 1024 * 1024 * 1024, cb),
+        (_, cb) => fs.read(fd, Buffer.alloc(4096), 0, 4096, 6 * 1024 * 1024 * 1024, cb),
+        (_, cb) => fs.close(fd, cb),
+        (_, cb) => unmount(fuse, cb),
+        () => {
+          t.same(writes.length, 0)
+          t.same(reads.length, 0)
+          t.end()
+        }
+      )
+    })
+  })
+
+  function checkSize (n) {
+    return ({ size}, cb) => {
+      t.same(size, n)
+      cb()
+    }
+  }
+})
+
+function run (...fns) {
+  const all = [...fns]
+  tick()
+  function tick (_, val) {
+    const next = all.shift()
+    if (next) next(val, tick)
+  }
+}