mirror of
https://github.com/fuse-friends/fuse-native
synced 2024-10-27 18:34:01 +00:00
Compare commits
6 Commits
Author | SHA1 | Date | |
---|---|---|---|
|
21658b5ebb | ||
|
34554d664b | ||
|
14b3a23d68 | ||
|
3d8ddd21b5 | ||
|
fc92548561 | ||
|
7f529df642 |
25
index.js
25
index.js
@ -230,7 +230,8 @@ class Fuse extends Nanoresource {
|
||||
|
||||
return function (nativeHandler, opCode, ...args) {
|
||||
const sig = signal.bind(null, nativeHandler)
|
||||
const boundSignal = to ? autoTimeout(sig) : sig
|
||||
const input = [...args]
|
||||
const boundSignal = to ? autoTimeout(sig, input) : sig
|
||||
const funcName = `_op_${name}`
|
||||
if (!self[funcName] || !self._implemented.has(op)) return boundSignal(-1, ...defaults)
|
||||
return self[funcName].apply(self, [boundSignal, ...args])
|
||||
@ -247,16 +248,32 @@ class Fuse extends Nanoresource {
|
||||
return process.nextTick(nativeSignal, ...arr)
|
||||
}
|
||||
|
||||
function autoTimeout (cb) {
|
||||
function autoTimeout (cb, input) {
|
||||
let called = false
|
||||
const timeout = setTimeout(timeoutWrap, to, TIMEOUT_ERRNO)
|
||||
return timeoutWrap
|
||||
|
||||
function timeoutWrap (...args) {
|
||||
function timeoutWrap (err, ...args) {
|
||||
if (called) return
|
||||
called = true
|
||||
|
||||
clearTimeout(timeout)
|
||||
cb(...args)
|
||||
|
||||
if (err === TIMEOUT_ERRNO) {
|
||||
switch (name) {
|
||||
case 'write':
|
||||
case 'read':
|
||||
return cb(TIMEOUT_ERRNO, 0, input[2].buffer)
|
||||
case 'setxattr':
|
||||
return cb(TIMEOUT_ERRNO, input[2].buffer)
|
||||
case 'getxattr':
|
||||
return cb(TIMEOUT_ERRNO, input[2].buffer)
|
||||
case 'listxattr':
|
||||
return cb(TIMEOUT_ERRNO, input[1].buffer)
|
||||
}
|
||||
}
|
||||
|
||||
cb(err, ...args)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "fuse-native",
|
||||
"version": "2.2.3",
|
||||
"version": "2.2.6",
|
||||
"description": "Fully maintained fuse bindings for Node that aims to cover the entire FUSE api",
|
||||
"main": "index.js",
|
||||
"bin": {
|
||||
|
Loading…
Reference in New Issue
Block a user