Archives/fuse-friends_fuse-native
1
0
Fork 0
mirror of https://github.com/fuse-friends/fuse-native synced 2024-10-27 18:34:01 +00:00
Code Issues Releases Wiki Activity

Merge pull request #2 from fuse-friends/rereimpl

Browse Source 
Rereimpl
This commit is contained in:
Andrew Osheroff 2019-11-19 11:00:25 +01:00 committed by GitHub
commit 7ec7c065cf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 396 additions and 482 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

878
fuse-native.c
View File

@ -32,6 +32,7 @@
#define FUSE_NATIVE_HANDLER(name, blk)\ #define FUSE_NATIVE_HANDLER(name, blk)\
fuse_thread_locals_t *l = get_thread_locals();\ fuse_thread_locals_t *l = get_thread_locals();\
l->op = op_##name;\ l->op = op_##name;\
l->op_fn = fuse_native_dispatch_##name;\
blk\ blk\
uv_async_send(&(l->async));\ uv_async_send(&(l->async));\
uv_sem_wait(&(l->sem));\ uv_sem_wait(&(l->sem));\
@ -61,6 +62,9 @@
FUSE_NATIVE_HANDLER(name, callBlk)\ FUSE_NATIVE_HANDLER(name, callBlk)\
} }
#define FUSE_METHOD_VOID(name, callbackArgs, signalArgs, signature, callBlk, callbackBlk)\
FUSE_METHOD(name, callbackArgs, signalArgs, signature, callBlk, callbackBlk, {})
// Opcodes // Opcodes
static const uint32_t op_init = 0; static const uint32_t op_init = 0;
@ -124,6 +128,7 @@ typedef struct {
typedef struct { typedef struct {
// Opcode // Opcode
uint32_t op; uint32_t op;
void *op_fn;
// Payloads // Payloads
const char *path; const char *path;
@ -224,495 +229,442 @@ static void populate_statvfs (uint32_t *ints, struct statvfs* statvfs) {
// Methods // Methods
FUSE_METHOD(statfs, 1, 1, (const char * path, struct statvfs *statvfs), { FUSE_METHOD(statfs, 1, 1, (const char * path, struct statvfs *statvfs), {
l->path = path; l->path = path;
l->statvfs = statvfs; l->statvfs = statvfs;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); }, {
}, NAPI_ARGV_BUFFER_CAST(uint32_t*, ints, 2)
{ populate_statvfs(ints, l->statvfs);
NAPI_ARGV_BUFFER_CAST(uint32_t*, ints, 2) })
populate_statvfs(ints, l->statvfs);
})
FUSE_METHOD(getattr, 1, 1, (const char *path, struct stat *stat), { FUSE_METHOD(getattr, 1, 1, (const char *path, struct stat *stat), {
l->path = path; l->path = path;
l->stat = stat; l->stat = stat;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); }, {
}, NAPI_ARGV_BUFFER_CAST(uint32_t*, ints, 2)
{ populate_stat(ints, l->stat);
NAPI_ARGV_BUFFER_CAST(uint32_t*, ints, 2) })
populate_stat(ints, l->stat);
})
FUSE_METHOD(fgetattr, 2, 1, (const char *path, struct stat *stat, struct fuse_file_info *info), { FUSE_METHOD(fgetattr, 2, 1, (const char *path, struct stat *stat, struct fuse_file_info *info), {
l->path = path; l->path = path;
l->stat = stat; l->stat = stat;
l->info = info; l->info = info;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); if (l->info != NULL) {
if (l->info != NULL) { napi_create_uint32(env, l->info->fh, &(argv[3]));
napi_create_uint32(env, l->info->fh, &(argv[3])); } else {
} else { napi_create_uint32(env, 0, &(argv[3]));
napi_create_uint32(env, 0, &(argv[3])); }
} }, {
}, NAPI_ARGV_BUFFER_CAST(uint32_t*, ints, 2)
{ populate_stat(ints, l->stat);
NAPI_ARGV_BUFFER_CAST(uint32_t*, ints, 2) })
populate_stat(ints, l->stat);
})
FUSE_METHOD(access, 2, 0, (const char *path, int mode), { FUSE_METHOD_VOID(access, 2, 0, (const char *path, int mode), {
l->path = path; l->path = path;
l->mode = mode; l->mode = mode;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_uint32(env, l->mode, &(argv[3]));
napi_create_uint32(env, l->mode, &(argv[3])); })
},
{})
FUSE_METHOD(open, 2, 1, (const char *path, struct fuse_file_info *info), { FUSE_METHOD(open, 2, 1, (const char *path, struct fuse_file_info *info), {
l->path = path; l->path = path;
l->info = info; l->info = info;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); if (l->info != NULL) {
if (l->info != NULL) { napi_create_uint32(env, l->info->flags, &(argv[3]));
napi_create_uint32(env, l->info->flags, &(argv[3])); } else {
} else { napi_create_uint32(env, 0, &(argv[3]));
napi_create_uint32(env, 0, &(argv[3])); }
} }, {
}, NAPI_ARGV_INT32(fd, 2)
{ if (fd != 0) {
NAPI_ARGV_INT32(fd, 2) l->info->fh = fd;
if (fd != 0) { }
l->info->fh = fd; })
}
})
FUSE_METHOD(opendir, 3, 1, (const char *path, struct fuse_file_info *info), { FUSE_METHOD(opendir, 3, 1, (const char *path, struct fuse_file_info *info), {
l->path = path; l->path = path;
l->info = info; l->info = info;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); if (l->info != NULL) {
if (l->info != NULL) { napi_create_uint32(env, l->info->fh, &(argv[3]));
napi_create_uint32(env, l->info->fh, &(argv[3])); napi_create_uint32(env, l->info->flags, &(argv[4]));
napi_create_uint32(env, l->info->flags, &(argv[4])); } else {
} else { napi_create_uint32(env, 0, &(argv[3]));
napi_create_uint32(env, 0, &(argv[3])); napi_create_uint32(env, 0, &(argv[4]));
napi_create_uint32(env, 0, &(argv[4])); }
} }, {
}, NAPI_ARGV_INT32(fd, 2)
{ if (fd != 0) {
NAPI_ARGV_INT32(fd, 2) l->info->fh = fd;
if (fd != 0) { }
l->info->fh = fd; })
}
})
FUSE_METHOD(create, 2, 1, (const char *path, mode_t mode, struct fuse_file_info *info), { FUSE_METHOD(create, 2, 1, (const char *path, mode_t mode, struct fuse_file_info *info), {
l->path = path; l->path = path;
l->mode = mode; l->mode = mode;
l->info = info; l->info = info;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_uint32(env, l->mode, &(argv[3]));
napi_create_uint32(env, l->mode, &(argv[3])); }, {
}, NAPI_ARGV_INT32(fd, 2)
{ if (fd != 0) {
NAPI_ARGV_INT32(fd, 2) l->info->fh = fd;
if (fd != 0) { }
l->info->fh = fd; })
}
})
FUSE_METHOD(utimens, 3, 0, (const char *path, const struct timespec tv[2]), { FUSE_METHOD_VOID(utimens, 3, 0, (const char *path, const struct timespec tv[2]), {
l->path = path; l->path = path;
from_timespec(&tv[0], l->atim); from_timespec(&tv[0], l->atim);
from_timespec(&tv[1], l->mtim); from_timespec(&tv[1], l->mtim);
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_external_arraybuffer(env, l->atim, 2 * sizeof(uint32_t), &fin, NULL, &argv[3]);
napi_create_external_arraybuffer(env, l->atim, 2 * sizeof(uint32_t), &fin, NULL, &argv[3]); napi_create_external_arraybuffer(env, l->mtim, 2 * sizeof(uint32_t), &fin, NULL, &argv[4]);
napi_create_external_arraybuffer(env, l->mtim, 2 * sizeof(uint32_t), &fin, NULL, &argv[4]); })
},
{})
FUSE_METHOD(release, 2, 0, (const char *path, struct fuse_file_info *info), { FUSE_METHOD_VOID(release, 2, 0, (const char *path, struct fuse_file_info *info), {
l->path = path; l->path = path;
l->info = info; l->info = info;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); if (l->info != NULL) {
if (l->info != NULL) { napi_create_uint32(env, l->info->fh, &(argv[3]));
napi_create_uint32(env, l->info->fh, &(argv[3])); } else {
} else { napi_create_uint32(env, 0, &(argv[3]));
napi_create_uint32(env, 0, &(argv[3])); }
} })
},
{})
FUSE_METHOD(releasedir, 2, 0, (const char *path, struct fuse_file_info *info), { FUSE_METHOD_VOID(releasedir, 2, 0, (const char *path, struct fuse_file_info *info), {
l->path = path; l->path = path;
l->info = info; l->info = info;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); if (l->info != NULL) {
if (l->info != NULL) { napi_create_uint32(env, l->info->fh, &(argv[3]));
napi_create_uint32(env, l->info->fh, &(argv[3])); } else {
} else { napi_create_uint32(env, 0, &(argv[3]));
napi_create_uint32(env, 0, &(argv[3])); }
} })
},
{})
FUSE_METHOD(read, 5, 1, (const char *path, char *buf, size_t len, off_t offset, struct fuse_file_info *info), { FUSE_METHOD(read, 5, 1, (const char *path, char *buf, size_t len, off_t offset, struct fuse_file_info *info), {
l->path = path; l->path = path;
l->buf = buf; l->buf = buf;
l->len = len; l->len = len;
l->offset = offset; l->offset = offset;
l->info = info; l->info = info;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_uint32(env, l->info->fh, &(argv[3]));
napi_create_uint32(env, l->info->fh, &(argv[3])); napi_create_external_buffer(env, l->len, (char *) l->buf, &fin, NULL, &(argv[4]));
napi_create_external_buffer(env, l->len, (char *) l->buf, &fin, NULL, &(argv[4])); napi_create_uint32(env, l->len, &(argv[5]));
napi_create_uint32(env, l->len, &(argv[5])); napi_create_uint32(env, l->offset, &(argv[6]));
napi_create_uint32(env, l->offset, &(argv[6])); }, {
}, // TODO: handle bytes processed?
{ })
// TODO: handle bytes processed?
})
FUSE_METHOD(write, 5, 1, (const char *path, const char *buf, size_t len, off_t offset, struct fuse_file_info *info), { FUSE_METHOD(write, 5, 1, (const char *path, const char *buf, size_t len, off_t offset, struct fuse_file_info *info), {
l->path = path; l->path = path;
l->buf = buf; l->buf = buf;
l->len = len; l->len = len;
l->offset = offset; l->offset = offset;
l->info = info; l->info = info;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_uint32(env, l->info->fh, &(argv[3]));
napi_create_uint32(env, l->info->fh, &(argv[3])); napi_create_external_buffer(env, l->len, (char *) l->buf, &fin, NULL, &(argv[4]));
napi_create_external_buffer(env, l->len, (char *) l->buf, &fin, NULL, &(argv[4])); napi_create_uint32(env, l->len, &(argv[5]));
napi_create_uint32(env, l->len, &(argv[5])); napi_create_uint32(env, l->offset, &(argv[6]));
napi_create_uint32(env, l->offset, &(argv[6])); }, {
}, // TODO: handle bytes processed?
{ })
// TODO: handle bytes processed?
})
FUSE_METHOD(readdir, 1, 2, (const char *path, void *buf, fuse_fill_dir_t filler, off_t offset, struct fuse_file_info *info), { FUSE_METHOD(readdir, 1, 2, (const char *path, void *buf, fuse_fill_dir_t filler, off_t offset, struct fuse_file_info *info), {
l->buf = buf; l->buf = buf;
l->path = path; l->path = path;
l->offset = offset; l->offset = offset;
l->info = info; l->info = info;
l->readdir_filler = filler; l->readdir_filler = filler;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); }, {
}, uint32_t stats_length;
{ uint32_t names_length;
uint32_t stats_length; napi_get_array_length(env, argv[3], &stats_length);
uint32_t names_length; napi_get_array_length(env, argv[2], &names_length);
napi_get_array_length(env, argv[3], &stats_length);
napi_get_array_length(env, argv[2], &names_length);
napi_value raw_names = argv[2]; napi_value raw_names = argv[2];
napi_value raw_stats = argv[3]; napi_value raw_stats = argv[3];
if (names_length != stats_length) { if (names_length != stats_length) {
NAPI_FOR_EACH(raw_names, raw_name) { NAPI_FOR_EACH(raw_names, raw_name) {
NAPI_UTF8(name, 1024, raw_name) NAPI_UTF8(name, 1024, raw_name)
int err = l->readdir_filler((char *) l->buf, name, NULL, 0); int err = l->readdir_filler((char *) l->buf, name, NULL, 0);
if (err == 1) { if (err == 1) {
break; break;
}
}
} else {
NAPI_FOR_EACH(raw_names, raw_name) {
NAPI_UTF8(name, 1024, raw_name)
napi_value raw_stat;
napi_get_element(env, raw_stats, i, &raw_stat);
NAPI_BUFFER_CAST(uint32_t*, stats_array, raw_stat);
struct stat st;
populate_stat(stats_array, &st);
// TODO: It turns out readdirplus likely won't work with FUSE 29...
// Metadata caching between readdir/getattr will be enabled when we upgrade fuse-shared-library
int err = l->readdir_filler((char *) l->buf, name, (struct stat *) &st, 0);
if (err == 1) {
break;
}
} }
} }
}) } else {
NAPI_FOR_EACH(raw_names, raw_name) {
NAPI_UTF8(name, 1024, raw_name)
napi_value raw_stat;
napi_get_element(env, raw_stats, i, &raw_stat);
NAPI_BUFFER_CAST(uint32_t*, stats_array, raw_stat);
struct stat st;
populate_stat(stats_array, &st);
// TODO: It turns out readdirplus likely won't work with FUSE 29...
// Metadata caching between readdir/getattr will be enabled when we upgrade fuse-shared-library
int err = l->readdir_filler((char *) l->buf, name, (struct stat *) &st, 0);
if (err == 1) {
break;
}
}
}
})
#ifdef __APPLE__ #ifdef __APPLE__
FUSE_METHOD(setxattr, 6, 0, (const char *path, const char *name, const char *value, size_t size, int flags, uint32_t position), { FUSE_METHOD_VOID(setxattr, 6, 0, (const char *path, const char *name, const char *value, size_t size, int flags, uint32_t position), {
l->path = path; l->path = path;
l->name = name; l->name = name;
l->value = value; l->value = value;
l->size = size; l->size = size;
l->flags = flags; l->flags = flags;
l->position = position; l->position = position;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->name, NAPI_AUTO_LENGTH, &(argv[3]));
napi_create_string_utf8(env, l->name, NAPI_AUTO_LENGTH, &(argv[3])); napi_create_string_utf8(env, l->value, NAPI_AUTO_LENGTH, &(argv[4]));
napi_create_string_utf8(env, l->value, NAPI_AUTO_LENGTH, &(argv[4])); napi_create_uint32(env, l->size, &(argv[5]));
napi_create_uint32(env, l->size, &(argv[5])); napi_create_uint32(env, l->flags, &(argv[6]));
napi_create_uint32(env, l->flags, &(argv[6])); napi_create_uint32(env, l->position, &(argv[7]));
napi_create_uint32(env, l->position, &(argv[7])); })
},
{})
FUSE_METHOD(getxattr, 5, 0, (const char *path, const char *name, char *value, size_t size, uint32_t position), { FUSE_METHOD_VOID(getxattr, 5, 0, (const char *path, const char *name, char *value, size_t size, uint32_t position), {
l->path = path; l->path = path;
l->name = name; l->name = name;
l->value = value; l->value = value;
l->size = size; l->size = size;
l->position = position; l->position = position;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->name, NAPI_AUTO_LENGTH, &(argv[3]));
napi_create_string_utf8(env, l->name, NAPI_AUTO_LENGTH, &(argv[3])); napi_create_string_utf8(env, l->value, NAPI_AUTO_LENGTH, &(argv[4]));
napi_create_string_utf8(env, l->value, NAPI_AUTO_LENGTH, &(argv[4])); napi_create_uint32(env, l->size, &(argv[5]));
napi_create_uint32(env, l->size, &(argv[5])); napi_create_uint32(env, l->position, &(argv[6]));
napi_create_uint32(env, l->position, &(argv[6])); })
},
{})
#else #else
FUSE_METHOD(setxattr, 5, 0, (const char *path, const char *name, const char *value, size_t size, int flags), { FUSE_METHOD_VOID(setxattr, 5, 0, (const char *path, const char *name, const char *value, size_t size, int flags), {
l->path = path; l->path = path;
l->name = name; l->name = name;
l->value = value; l->value = value;
l->size = size; l->size = size;
l->flags = flags; l->flags = flags;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->name, NAPI_AUTO_LENGTH, &(argv[3]));
napi_create_string_utf8(env, l->name, NAPI_AUTO_LENGTH, &(argv[3])); napi_create_string_utf8(env, l->value, NAPI_AUTO_LENGTH, &(argv[4]));
napi_create_string_utf8(env, l->value, NAPI_AUTO_LENGTH, &(argv[4])); napi_create_uint32(env, l->size, &(argv[5]));
napi_create_uint32(env, l->size, &(argv[5])); napi_create_uint32(env, l->flags, &(argv[6]));
napi_create_uint32(env, l->flags, &(argv[6])); })
},
{})
FUSE_METHOD(getxattr, 4, 0, (const char *path, const char *name, char *value, size_t size), { FUSE_METHOD_VOID(getxattr, 4, 0, (const char *path, const char *name, char *value, size_t size), {
l->path = path; l->path = path;
l->name = name; l->name = name;
l->value = value; l->value = value;
l->size = size; l->size = size;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->name, NAPI_AUTO_LENGTH, &(argv[3]));
napi_create_string_utf8(env, l->name, NAPI_AUTO_LENGTH, &(argv[3])); napi_create_string_utf8(env, l->value, NAPI_AUTO_LENGTH, &(argv[4]));
napi_create_string_utf8(env, l->value, NAPI_AUTO_LENGTH, &(argv[4])); napi_create_uint32(env, l->size, &(argv[5]));
napi_create_uint32(env, l->size, &(argv[5])); })
},
{})
#endif #endif
FUSE_METHOD(listxattr, 3, 0, (const char *path, char *list, size_t size), { FUSE_METHOD_VOID(listxattr, 3, 0, (const char *path, char *list, size_t size), {
l->path = path; l->path = path;
l->list = list; l->list = list;
l->size = size; l->size = size;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_external_buffer(env, l->size, l->list, &fin, NULL, &(argv[3]));
napi_create_external_buffer(env, l->size, l->list, &fin, NULL, &(argv[3])); napi_create_uint32(env, l->size, &(argv[4]));
napi_create_uint32(env, l->size, &(argv[4])); })
},
{})
FUSE_METHOD(removexattr, 2, 0, (const char *path, const char *name), { FUSE_METHOD_VOID(removexattr, 2, 0, (const char *path, const char *name), {
l->path = path; l->path = path;
l->name = name; l->name = name;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->name, NAPI_AUTO_LENGTH, &(argv[3]));
napi_create_string_utf8(env, l->name, NAPI_AUTO_LENGTH, &(argv[3])); })
},
{})
FUSE_METHOD(flush, 2, 0, (const char *path, struct fuse_file_info *info), { FUSE_METHOD_VOID(flush, 2, 0, (const char *path, struct fuse_file_info *info), {
l->path = path; l->path = path;
l->info = info; l->info = info;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
if (l->info != NULL) { if (l->info != NULL) {
napi_create_uint32(env, l->info->fh, &(argv[3])); napi_create_uint32(env, l->info->fh, &(argv[3]));
} else { } else {
napi_create_uint32(env, 0, &(argv[3])); napi_create_uint32(env, 0, &(argv[3]));
} }
}, })
{})
FUSE_METHOD(fsync, 3, 0, (const char *path, int datasync, struct fuse_file_info *info), { FUSE_METHOD_VOID(fsync, 3, 0, (const char *path, int datasync, struct fuse_file_info *info), {
l->path = path; l->path = path;
l->mode = datasync; l->mode = datasync;
l->info = info; l->info = info;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_uint32(env, l->mode, &(argv[3])); napi_create_uint32(env, l->mode, &(argv[3]));
if (l->info != NULL) { if (l->info != NULL) {
napi_create_uint32(env, l->info->fh, &(argv[4])); napi_create_uint32(env, l->info->fh, &(argv[4]));
} else { } else {
napi_create_uint32(env, 0, &(argv[4])); napi_create_uint32(env, 0, &(argv[4]));
} }
}, })
{})
FUSE_METHOD(fsyncdir, 3, 0, (const char *path, int datasync, struct fuse_file_info *info), { FUSE_METHOD_VOID(fsyncdir, 3, 0, (const char *path, int datasync, struct fuse_file_info *info), {
l->path = path; l->path = path;
l->mode = datasync; l->mode = datasync;
l->info = info; l->info = info;
}, }, {
{ napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_uint32(env, l->mode, &(argv[3]));
napi_create_uint32(env, l->mode, &(argv[3])); if (l->info != NULL) {
if (l->info != NULL) { napi_create_uint32(env, l->info->fh, &(argv[4]));
napi_create_uint32(env, l->info->fh, &(argv[4])); } else {
} else { napi_create_uint32(env, 0, &(argv[4]));
napi_create_uint32(env, 0, &(argv[4])); }
} })
},
{})
FUSE_METHOD(truncate, 2, 0, (const char *path, off_t size), { FUSE_METHOD_VOID(truncate, 2, 0, (const char *path, off_t size), {
l->path = path; l->path = path;
l->len = size; l->len = size;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_uint32(env, l->len, &(argv[3])); napi_create_uint32(env, l->len, &(argv[3]));
}, })
{})
FUSE_METHOD(ftruncate, 2, 0, (const char *path, off_t size, struct fuse_file_info *info), { FUSE_METHOD_VOID(ftruncate, 2, 0, (const char *path, off_t size, struct fuse_file_info *info), {
l->path = path; l->path = path;
l->len = size; l->len = size;
l->info = info; l->info = info;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_uint32(env, l->len, &(argv[3])); napi_create_uint32(env, l->len, &(argv[3]));
if (l->info != NULL) { if (l->info != NULL) {
napi_create_uint32(env, l->info->fh, &(argv[4])); napi_create_uint32(env, l->info->fh, &(argv[4]));
} else { } else {
napi_create_uint32(env, 0, &(argv[4])); napi_create_uint32(env, 0, &(argv[4]));
} }
}, })
{})
FUSE_METHOD(readlink, 1, 1, (const char *path, char *linkname, size_t len), { FUSE_METHOD(readlink, 1, 1, (const char *path, char *linkname, size_t len), {
l->path = path; l->path = path;
l->linkname = linkname; l->linkname = linkname;
l->len = len; l->len = len;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
}, { }, {
NAPI_ARGV_UTF8(linkname, l->len, 2) NAPI_ARGV_UTF8(linkname, l->len, 2)
strncpy(l->linkname, linkname, l->len); strncpy(l->linkname, linkname, l->len);
}) })
FUSE_METHOD(chown, 3, 0, (const char *path, uid_t uid, gid_t gid), { FUSE_METHOD_VOID(chown, 3, 0, (const char *path, uid_t uid, gid_t gid), {
l->path = path; l->path = path;
l->uid = uid; l->uid = uid;
l->gid = gid; l->gid = gid;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_uint32(env, l->uid, &(argv[3])); napi_create_uint32(env, l->uid, &(argv[3]));
napi_create_uint32(env, l->gid, &(argv[4])); napi_create_uint32(env, l->gid, &(argv[4]));
}, })
{})
FUSE_METHOD(chmod, 2, 0, (const char *path, mode_t mode), { FUSE_METHOD_VOID(chmod, 2, 0, (const char *path, mode_t mode), {
l->path = path; l->path = path;
l->mode = mode; l->mode = mode;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_uint32(env, l->mode, &(argv[3])); napi_create_uint32(env, l->mode, &(argv[3]));
}, })
{})
FUSE_METHOD(mknod, 3, 0, (const char *path, mode_t mode, dev_t dev), { FUSE_METHOD_VOID(mknod, 3, 0, (const char *path, mode_t mode, dev_t dev), {
l->path = path; l->path = path;
l->mode = mode; l->mode = mode;
l->dev = dev; l->dev = dev;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_uint32(env, l->mode, &(argv[3])); napi_create_uint32(env, l->mode, &(argv[3]));
napi_create_uint32(env, l->dev, &(argv[4])); napi_create_uint32(env, l->dev, &(argv[4]));
}, })
{})
FUSE_METHOD(unlink, 1, 0, (const char *path), { FUSE_METHOD_VOID(unlink, 1, 0, (const char *path), {
l->path = path; l->path = path;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
}, })
{})
FUSE_METHOD(rename, 2, 0, (const char *path, const char *dest), { FUSE_METHOD_VOID(rename, 2, 0, (const char *path, const char *dest), {
l->path = path; l->path = path;
l->dest = dest; l->dest = dest;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->dest, NAPI_AUTO_LENGTH, &(argv[3])); napi_create_string_utf8(env, l->dest, NAPI_AUTO_LENGTH, &(argv[3]));
}, })
{})
FUSE_METHOD(link, 2, 0, (const char *path, const char *dest), { FUSE_METHOD_VOID(link, 2, 0, (const char *path, const char *dest), {
l->path = path; l->path = path;
l->dest = dest; l->dest = dest;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->dest, NAPI_AUTO_LENGTH, &(argv[3])); napi_create_string_utf8(env, l->dest, NAPI_AUTO_LENGTH, &(argv[3]));
}, })
{})
FUSE_METHOD(symlink, 2, 0, (const char *path, const char *dest), { FUSE_METHOD_VOID(symlink, 2, 0, (const char *path, const char *dest), {
l->path = path; l->path = path;
l->dest = dest; l->dest = dest;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_string_utf8(env, l->dest, NAPI_AUTO_LENGTH, &(argv[3])); napi_create_string_utf8(env, l->dest, NAPI_AUTO_LENGTH, &(argv[3]));
}, })
{})
FUSE_METHOD(mkdir, 2, 0, (const char *path, mode_t mode), { FUSE_METHOD_VOID(mkdir, 2, 0, (const char *path, mode_t mode), {
l->path = path; l->path = path;
l->mode = mode; l->mode = mode;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
napi_create_uint32(env, l->mode, &(argv[3])); napi_create_uint32(env, l->mode, &(argv[3]));
}, })
{})
FUSE_METHOD(rmdir, 1, 0, (const char *path), { FUSE_METHOD_VOID(rmdir, 1, 0, (const char *path), {
l->path = path; l->path = path;
}, { }, {
napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2])); napi_create_string_utf8(env, l->path, NAPI_AUTO_LENGTH, &(argv[2]));
}, })
{})
static void fuse_native_dispatch_init (uv_async_t* handle, fuse_thread_locals_t* l, fuse_thread_t* ft) {\ static void fuse_native_dispatch_init (uv_async_t* handle, fuse_thread_locals_t* l, fuse_thread_t* ft) {\
FUSE_NATIVE_CALLBACK(ft->handlers[op_init], { FUSE_NATIVE_CALLBACK(ft->handlers[op_init], {
napi_value argv[2]; napi_value argv[2];
napi_create_external_buffer(env, sizeof(fuse_thread_locals_t), l, &fin, NULL, &(argv[0])); napi_create_external_buffer(env, sizeof(fuse_thread_locals_t), l, &fin, NULL, &(argv[0]));
napi_create_uint32(env, l->op, &(argv[1])); napi_create_uint32(env, l->op, &(argv[1]));
NAPI_MAKE_CALLBACK(env, NULL, ctx, callback, 2, argv, NULL); NAPI_MAKE_CALLBACK(env, NULL, ctx, callback, 2, argv, NULL);
}) })
} }
@ -728,19 +680,20 @@ NAPI_METHOD(fuse_native_signal_init) {
static void * fuse_native_init (struct fuse_conn_info *conn) { static void * fuse_native_init (struct fuse_conn_info *conn) {
fuse_thread_locals_t *l = get_thread_locals(); fuse_thread_locals_t *l = get_thread_locals();
l->op = op_init; l->op = op_init;
l->op_fn = fuse_native_dispatch_init;
uv_async_send(&(l->async)); uv_async_send(&(l->async));
uv_sem_wait(&(l->sem)); uv_sem_wait(&(l->sem));
return l->fuse; return l->fuse;
} }
static void fuse_native_dispatch_destroy (uv_async_t* handle, fuse_thread_locals_t* l, fuse_thread_t* ft) {\ static void fuse_native_dispatch_destroy (uv_async_t* handle, fuse_thread_locals_t* l, fuse_thread_t* ft) {
FUSE_NATIVE_CALLBACK(ft->handlers[op_destroy], { FUSE_NATIVE_CALLBACK(ft->handlers[op_destroy], {
napi_value argv[2]; napi_value argv[2];
napi_create_external_buffer(env, sizeof(fuse_thread_locals_t), l, &fin, NULL, &(argv[0])); napi_create_external_buffer(env, sizeof(fuse_thread_locals_t), l, &fin, NULL, &(argv[0]));
napi_create_uint32(env, l->op, &(argv[1])); napi_create_uint32(env, l->op, &(argv[1]));
NAPI_MAKE_CALLBACK(env, NULL, ctx, callback, 2, argv, NULL); NAPI_MAKE_CALLBACK(env, NULL, ctx, callback, 2, argv, NULL);
}) })
} }
NAPI_METHOD(fuse_native_signal_destroy) { NAPI_METHOD(fuse_native_signal_destroy) {
NAPI_ARGV(2) NAPI_ARGV(2)
@ -754,55 +707,18 @@ NAPI_METHOD(fuse_native_signal_destroy) {
static void fuse_native_destroy (void *data) { static void fuse_native_destroy (void *data) {
fuse_thread_locals_t *l = get_thread_locals(); fuse_thread_locals_t *l = get_thread_locals();
l->op = op_init; l->op = op_init;
l->op_fn = fuse_native_dispatch_init;
uv_async_send(&(l->async)); uv_async_send(&(l->async));
uv_sem_wait(&(l->sem)); uv_sem_wait(&(l->sem));
} }
// Top-level dispatcher // Top-level dispatcher
// TODO: Generate this with a macro
static void fuse_native_dispatch (uv_async_t* handle) { static void fuse_native_dispatch (uv_async_t* handle) {
fuse_thread_locals_t *l = (fuse_thread_locals_t *) handle->data; fuse_thread_locals_t *l = (fuse_thread_locals_t *) handle->data;
fuse_thread_t *ft = l->fuse; fuse_thread_t *ft = l->fuse;
void (*fn)(uv_async_t *, fuse_thread_locals_t *, fuse_thread_t *) = l->op_fn;
// TODO: Either use a function pointer (like ft->handlers[op]) or generate with a macro. fn(handle, l, ft);
switch (l->op) {
case (op_init): return fuse_native_dispatch_init(handle, l, ft);
case (op_statfs): return fuse_native_dispatch_statfs(handle, l, ft);
case (op_fgetattr): return fuse_native_dispatch_fgetattr(handle, l, ft);
case (op_getattr): return fuse_native_dispatch_getattr(handle, l, ft);
case (op_readdir): return fuse_native_dispatch_readdir(handle, l, ft);
case (op_open): return fuse_native_dispatch_open(handle, l, ft);
case (op_create): return fuse_native_dispatch_create(handle, l, ft);
case (op_access): return fuse_native_dispatch_access(handle, l, ft);
case (op_utimens): return fuse_native_dispatch_utimens(handle, l, ft);
case (op_release): return fuse_native_dispatch_release(handle, l, ft);
case (op_releasedir): return fuse_native_dispatch_releasedir(handle, l, ft);
case (op_read): return fuse_native_dispatch_read(handle, l, ft);
case (op_write): return fuse_native_dispatch_write(handle, l, ft);
case (op_getxattr): return fuse_native_dispatch_getxattr(handle, l, ft);
case (op_setxattr): return fuse_native_dispatch_setxattr(handle, l, ft);
case (op_listxattr): return fuse_native_dispatch_listxattr(handle, l, ft);
case (op_removexattr): return fuse_native_dispatch_removexattr(handle, l, ft);
case (op_flush): return fuse_native_dispatch_flush(handle, l, ft);
case (op_fsync): return fuse_native_dispatch_fsync(handle, l, ft);
case (op_fsyncdir): return fuse_native_dispatch_fsyncdir(handle, l, ft);
case (op_truncate): return fuse_native_dispatch_truncate(handle, l, ft);
case (op_ftruncate): return fuse_native_dispatch_ftruncate(handle, l, ft);
case (op_readlink): return fuse_native_dispatch_readlink(handle, l, ft);
case (op_chown): return fuse_native_dispatch_chown(handle, l, ft);
case (op_chmod): return fuse_native_dispatch_chmod(handle, l, ft);
case (op_mknod): return fuse_native_dispatch_mknod(handle, l, ft);
case (op_opendir): return fuse_native_dispatch_opendir(handle, l, ft);
case (op_unlink): return fuse_native_dispatch_unlink(handle, l, ft);
case (op_rename): return fuse_native_dispatch_rename(handle, l, ft);
case (op_link): return fuse_native_dispatch_link(handle, l, ft);
case (op_symlink): return fuse_native_dispatch_symlink(handle, l, ft);
case (op_mkdir): return fuse_native_dispatch_mkdir(handle, l, ft);
case (op_rmdir): return fuse_native_dispatch_rmdir(handle, l, ft);
case (op_destroy): return fuse_native_dispatch_destroy(handle, l, ft);
default: return;
}
} }
static void fuse_native_async_init (uv_async_t* handle) { static void fuse_native_async_init (uv_async_t* handle) {
@ -1051,5 +967,3 @@ NAPI_INIT() {
NAPI_EXPORT_UINT32(op_rmdir) NAPI_EXPORT_UINT32(op_rmdir)
NAPI_EXPORT_UINT32(op_destroy) NAPI_EXPORT_UINT32(op_destroy)
} }