mirror of
https://github.com/fuse-friends/fuse-native
synced 2024-10-27 18:34:01 +00:00
Added fuse timeout read test
This commit is contained in:
parent
b333a2fd3d
commit
de825b61e6
69
test/read.js
69
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)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user