Files
cgofuse/fuse/host_cgo.go
2025-07-21 00:21:22 -03:00

1045 lines
32 KiB
Go

//go:build cgo && unix
package fuse
/*
#cgo freebsd,!fuse3 CFLAGS: -DFUSE_USE_VERSION=28 -D_FILE_OFFSET_BITS=64 -I/usr/local/include/fuse
#cgo freebsd,fuse3 CFLAGS: -DFUSE_USE_VERSION=39 -D_FILE_OFFSET_BITS=64 -I/usr/local/include/fuse3
#cgo netbsd CFLAGS: -DFUSE_USE_VERSION=28 -D_FILE_OFFSET_BITS=64 -D_KERNTYPES
#cgo openbsd CFLAGS: -DFUSE_USE_VERSION=28 -D_FILE_OFFSET_BITS=64
#cgo darwin CFLAGS: -DFUSE_USE_VERSION=28 -D_FILE_OFFSET_BITS=64 -I/usr/local/include/osxfuse/fuse -I/usr/local/include/fuse
#cgo linux,!fuse3 CFLAGS: -DFUSE_USE_VERSION=28 -D_FILE_OFFSET_BITS=64 -I/usr/include/fuse
#cgo linux,fuse3 CFLAGS: -DFUSE_USE_VERSION=39 -D_FILE_OFFSET_BITS=64 -I/usr/include/fuse3
#cgo linux LDFLAGS: -ldl
#if !(defined(__APPLE__) || defined(__FreeBSD__) || defined(__NetBSD__) || defined(__OpenBSD__) || defined(__linux__))
#error platform not supported
#endif
#include <stdbool.h>
#include <stdint.h>
#include <stdlib.h>
#include <string.h>
#if defined(__APPLE__) || defined(__FreeBSD__) || defined(__NetBSD__) || defined(__OpenBSD__) || defined(__linux__)
#include <dlfcn.h>
#include <pthread.h>
#include <spawn.h>
#include <sys/mount.h>
#include <sys/wait.h>
#include <unistd.h>
#define cgofuse_barrier() __sync_synchronize()
#define cgofuse_mutex_t pthread_mutex_t
#define cgofuse_mutex_init(l) ((void)0)
#define cgofuse_mutex_lock(l) pthread_mutex_lock(l)
#define cgofuse_mutex_unlock(l) pthread_mutex_unlock(l)
#define CGOFUSE_MUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER
#endif
static void *cgofuse_init_slow(int hardfail);
static void cgofuse_init_fail(void);
static void *cgofuse_init_fuse(void);
static cgofuse_mutex_t cgofuse_mutex = CGOFUSE_MUTEX_INITIALIZER;
static void *cgofuse_module = 0;
static inline void *cgofuse_init_fast(int hardfail)
{
void *Module = cgofuse_module;
cgofuse_barrier();
if (0 == Module)
Module = cgofuse_init_slow(hardfail);
return Module;
}
static void *cgofuse_init_slow(int hardfail)
{
void *Module;
cgofuse_mutex_lock(&cgofuse_mutex);
Module = cgofuse_module;
if (0 == Module)
{
Module = cgofuse_init_fuse();
cgofuse_barrier();
cgofuse_module = Module;
}
cgofuse_mutex_unlock(&cgofuse_mutex);
if (0 == Module && hardfail)
cgofuse_init_fail();
return Module;
}
static void cgofuse_init_fail(void)
{
#if defined(__APPLE__) || defined(__FreeBSD__) || defined(__NetBSD__) || defined(__OpenBSD__) || defined(__linux__)
static const char *message = "cgofuse: cannot find FUSE\n";
int res = write(2, message, strlen(message));
(void)res; // suppress dumb gcc warning; see https://gcc.gnu.org/bugzilla/show_bug.cgi?id=66425
exit(1);
#endif
}
#if defined(__APPLE__) || defined(__FreeBSD__) || defined(__NetBSD__) || defined(__OpenBSD__) || defined(__linux__)
#include <fuse.h>
#if defined(__OpenBSD__)
static int (*pfn_fuse_main)(int argc, char *argv[],
const struct fuse_operations *ops, void *data);
#else
static int (*pfn_fuse_main_real)(int argc, char *argv[],
const struct fuse_operations *ops, size_t opsize, void *data);
#endif
static struct fuse_context *(*pfn_fuse_get_context)(void);
static int (*pfn_fuse_opt_parse)(struct fuse_args *args, void *data,
const struct fuse_opt opts[], fuse_opt_proc_t proc);
static void (*pfn_fuse_opt_free_args)(struct fuse_args *args);
static inline int inl_fuse_main_real(int argc, char *argv[],
const struct fuse_operations *ops, size_t opsize, void *data)
{
cgofuse_init_fast(1);
#if defined(__OpenBSD__)
return pfn_fuse_main(argc, argv, ops, data);
#else
return pfn_fuse_main_real(argc, argv, ops, opsize, data);
#endif
}
static inline struct fuse_context *inl_fuse_get_context(void)
{
cgofuse_init_fast(1);
return pfn_fuse_get_context();
}
static inline int inl_fuse_opt_parse(struct fuse_args *args, void *data,
const struct fuse_opt opts[], fuse_opt_proc_t proc)
{
cgofuse_init_fast(1);
return pfn_fuse_opt_parse(args, data, opts, proc);
}
static inline void inl_fuse_opt_free_args(struct fuse_args *args)
{
cgofuse_init_fast(1);
return pfn_fuse_opt_free_args(args);
}
#define fuse_main_real inl_fuse_main_real
#define fuse_exit fuse_exit_DO_NOT_USE
#define fuse_get_context inl_fuse_get_context
#define fuse_opt_parse inl_fuse_opt_parse
#define fuse_opt_free_args inl_fuse_opt_free_args
static void *cgofuse_init_fuse(void)
{
#define CGOFUSE_GET_API(n) \
if (0 == (*(void **)&(pfn_ ## n) = dlsym(h, #n)))\
return 0;
void *h;
#if defined(__APPLE__)
h = dlopen("/usr/local/lib/libfuse.2.dylib", RTLD_NOW); // MacFUSE/OSXFuse >= v4
if (0 == h)
h = dlopen("/usr/local/lib/libosxfuse.2.dylib", RTLD_NOW); // MacFUSE/OSXFuse < v4
if (0 == h)
h = dlopen("/usr/local/lib/libfuse-t.dylib", RTLD_NOW); // FUSE-T
#elif defined(__FreeBSD__)
#if FUSE_USE_VERSION < 30
h = dlopen("libfuse.so.2", RTLD_NOW);
#else
h = dlopen("libfuse3.so.3", RTLD_NOW);
#endif
#elif defined(__NetBSD__)
h = dlopen("librefuse.so.2", RTLD_NOW);
#elif defined(__OpenBSD__)
h = dlopen("libfuse.so.2.0", RTLD_NOW);
#elif defined(__linux__)
#if FUSE_USE_VERSION < 30
h = dlopen("libfuse.so.2", RTLD_NOW);
#else
h = dlopen("libfuse3.so.3", RTLD_NOW);
#endif
#endif
if (0 == h)
return 0;
#if defined(__OpenBSD__)
CGOFUSE_GET_API(fuse_main);
#else
CGOFUSE_GET_API(fuse_main_real);
#endif
CGOFUSE_GET_API(fuse_get_context);
CGOFUSE_GET_API(fuse_opt_parse);
CGOFUSE_GET_API(fuse_opt_free_args);
return h;
#undef CGOFUSE_GET_API
}
#endif
#if defined(__APPLE__) || defined(__FreeBSD__) || defined(__NetBSD__) || defined(__OpenBSD__) || defined(__linux__)
typedef struct stat fuse_stat_t;
typedef struct stat fuse_stat_ex_t;
typedef struct statvfs fuse_statvfs_t;
typedef struct timespec fuse_timespec_t;
typedef mode_t fuse_mode_t;
typedef dev_t fuse_dev_t;
typedef uid_t fuse_uid_t;
typedef gid_t fuse_gid_t;
typedef off_t fuse_off_t;
typedef unsigned long fuse_opt_offset_t;
#endif
#if FUSE_USE_VERSION < 30
struct fuse_config;
enum fuse_readdir_flags
{
fuse_readdir_flags_DUMMY
};
#endif
#if FUSE_USE_VERSION < 30
extern int go_hostGetattr(char *path, fuse_stat_t *stbuf);
#else
extern int go_hostGetattr3(char *path, fuse_stat_t *stbuf, struct fuse_file_info *fi);
#endif
extern int go_hostReadlink(char *path, char *buf, size_t size);
extern int go_hostMknod(char *path, fuse_mode_t mode, fuse_dev_t dev);
extern int go_hostMkdir(char *path, fuse_mode_t mode);
extern int go_hostUnlink(char *path);
extern int go_hostRmdir(char *path);
extern int go_hostSymlink(char *target, char *newpath);
#if FUSE_USE_VERSION < 30
extern int go_hostRename(char *oldpath, char *newpath);
#else
extern int go_hostRename3(char *oldpath, char *newpath, unsigned int flags);
#endif
extern int go_hostLink(char *oldpath, char *newpath);
#if FUSE_USE_VERSION < 30
extern int go_hostChmod(char *path, fuse_mode_t mode);
extern int go_hostChown(char *path, fuse_uid_t uid, fuse_gid_t gid);
extern int go_hostTruncate(char *path, fuse_off_t size);
#else
extern int go_hostChmod3(char *path, fuse_mode_t mode, struct fuse_file_info *fi);
extern int go_hostChown3(char *path, fuse_uid_t uid, fuse_gid_t gid, struct fuse_file_info *fi);
extern int go_hostTruncate3(char *path, fuse_off_t size, struct fuse_file_info *fi);
#endif
extern int go_hostOpen(char *path, struct fuse_file_info *fi);
extern int go_hostRead(char *path, char *buf, size_t size, fuse_off_t off,
struct fuse_file_info *fi);
extern int go_hostWrite(char *path, char *buf, size_t size, fuse_off_t off,
struct fuse_file_info *fi);
extern int go_hostStatfs(char *path, fuse_statvfs_t *stbuf);
extern int go_hostFlush(char *path, struct fuse_file_info *fi);
extern int go_hostRelease(char *path, struct fuse_file_info *fi);
extern int go_hostFsync(char *path, int datasync, struct fuse_file_info *fi);
extern int go_hostSetxattr(char *path, char *name, char *value, size_t size, int flags);
extern int go_hostGetxattr(char *path, char *name, char *value, size_t size);
extern int go_hostListxattr(char *path, char *namebuf, size_t size);
extern int go_hostRemovexattr(char *path, char *name);
extern int go_hostOpendir(char *path, struct fuse_file_info *fi);
#if FUSE_USE_VERSION < 30
extern int go_hostReaddir(char *path, void *buf, fuse_fill_dir_t filler, fuse_off_t off,
struct fuse_file_info *fi);
#else
extern int go_hostReaddir3(char *path, void *buf, fuse_fill_dir_t filler, fuse_off_t off,
struct fuse_file_info *fi, enum fuse_readdir_flags flags);
#endif
extern int go_hostReleasedir(char *path, struct fuse_file_info *fi);
extern int go_hostFsyncdir(char *path, int datasync, struct fuse_file_info *fi);
#if FUSE_USE_VERSION < 30
extern void *go_hostInit(struct fuse_conn_info *conn);
#else
extern void *go_hostInit3(struct fuse_conn_info *conn, struct fuse_config *conf);
#endif
extern void go_hostDestroy(void *data);
extern int go_hostAccess(char *path, int mask);
extern int go_hostCreate(char *path, fuse_mode_t mode, struct fuse_file_info *fi);
#if FUSE_USE_VERSION < 30
extern int go_hostFtruncate(char *path, fuse_off_t off, struct fuse_file_info *fi);
extern int go_hostFgetattr(char *path, fuse_stat_t *stbuf, struct fuse_file_info *fi);
#endif
//extern int go_hostLock(char *path, struct fuse_file_info *fi, int cmd, struct fuse_flock *lock);
#if FUSE_USE_VERSION < 30
extern int go_hostUtimens(char *path, fuse_timespec_t tv[2]);
#else
extern int go_hostUtimens3(char *path, fuse_timespec_t tv[2], struct fuse_file_info *fi);
#endif
extern int go_hostGetpath(char *path, char *buf, size_t size,
struct fuse_file_info *fi);
extern int go_hostSetchgtime(char *path, fuse_timespec_t *tv);
extern int go_hostSetcrtime(char *path, fuse_timespec_t *tv);
extern int go_hostChflags(char *path, uint32_t flags);
static inline void hostAsgnCconninfo(struct fuse_conn_info *conn,
bool capCaseInsensitive,
bool capReaddirPlus,
bool capDeleteAccess,
bool capOpenTrunc)
{
#if defined(__APPLE__)
if (capCaseInsensitive)
FUSE_ENABLE_CASE_INSENSITIVE(conn);
#elif defined(__NetBSD__) || defined(__OpenBSD__)
#elif defined(__FreeBSD__) || defined(__linux__)
#if FUSE_USE_VERSION >= 30
if (capReaddirPlus)
conn->want |= conn->capable & FUSE_CAP_READDIRPLUS;
else
conn->want &= ~FUSE_CAP_READDIRPLUS;
#endif
// FUSE_CAP_ATOMIC_O_TRUNC was disabled in FUSE2 and is enabled in FUSE3.
// So disable it here, unless the user explicitly enables it.
if (capOpenTrunc)
conn->want |= conn->capable & FUSE_CAP_ATOMIC_O_TRUNC;
else
conn->want &= ~FUSE_CAP_ATOMIC_O_TRUNC;
#endif
}
#if FUSE_USE_VERSION < 30
static inline void hostAsgnCconfig(struct fuse_config *conf,
bool direct_io,
bool use_ino)
{
}
#else
static inline void hostAsgnCconfig(struct fuse_config *conf,
bool direct_io,
bool use_ino)
{
memset(conf, 0, sizeof *conf);
conf->direct_io = direct_io;
conf->use_ino = use_ino;
}
#endif
static inline void hostCstatvfsFromFusestatfs(fuse_statvfs_t *stbuf,
uint64_t bsize,
uint64_t frsize,
uint64_t blocks,
uint64_t bfree,
uint64_t bavail,
uint64_t files,
uint64_t ffree,
uint64_t favail,
uint64_t fsid,
uint64_t flag,
uint64_t namemax)
{
memset(stbuf, 0, sizeof *stbuf);
stbuf->f_bsize = bsize;
stbuf->f_frsize = frsize;
stbuf->f_blocks = blocks;
stbuf->f_bfree = bfree;
stbuf->f_bavail = bavail;
stbuf->f_files = files;
stbuf->f_ffree = ffree;
stbuf->f_favail = favail;
stbuf->f_fsid = fsid;
stbuf->f_flag = flag;
stbuf->f_namemax = namemax;
}
static inline void hostCstatFromFusestat(fuse_stat_t *stbuf,
uint64_t dev,
uint64_t ino,
uint32_t mode,
uint32_t nlink,
uint32_t uid,
uint32_t gid,
uint64_t rdev,
int64_t size,
int64_t atimSec, int64_t atimNsec,
int64_t mtimSec, int64_t mtimNsec,
int64_t ctimSec, int64_t ctimNsec,
int64_t blksize,
int64_t blocks,
int64_t birthtimSec, int64_t birthtimNsec,
uint32_t flags)
{
memset(stbuf, 0, sizeof *stbuf);
stbuf->st_dev = dev;
stbuf->st_ino = ino;
stbuf->st_mode = mode;
stbuf->st_nlink = nlink;
stbuf->st_uid = uid;
stbuf->st_gid = gid;
stbuf->st_rdev = rdev;
stbuf->st_size = size;
stbuf->st_blksize = blksize;
stbuf->st_blocks = blocks;
#if defined(__APPLE__)
stbuf->st_atimespec.tv_sec = atimSec; stbuf->st_atimespec.tv_nsec = atimNsec;
stbuf->st_mtimespec.tv_sec = mtimSec; stbuf->st_mtimespec.tv_nsec = mtimNsec;
stbuf->st_ctimespec.tv_sec = ctimSec; stbuf->st_ctimespec.tv_nsec = ctimNsec;
if (0 != birthtimSec)
{
stbuf->st_birthtimespec.tv_sec = birthtimSec;
stbuf->st_birthtimespec.tv_nsec = birthtimNsec;
}
else
{
stbuf->st_birthtimespec.tv_sec = ctimSec;
stbuf->st_birthtimespec.tv_nsec = ctimNsec;
}
stbuf->st_flags = flags;
#else
stbuf->st_atim.tv_sec = atimSec; stbuf->st_atim.tv_nsec = atimNsec;
stbuf->st_mtim.tv_sec = mtimSec; stbuf->st_mtim.tv_nsec = mtimNsec;
stbuf->st_ctim.tv_sec = ctimSec; stbuf->st_ctim.tv_nsec = ctimNsec;
#endif
}
static inline void hostAsgnCfileinfo(struct fuse_file_info *fi,
bool direct_io,
bool keep_cache,
bool nonseekable,
uint64_t fh)
{
fi->direct_io = direct_io;
fi->keep_cache = keep_cache;
#if !defined(__NetBSD__)
fi->nonseekable = nonseekable;
#endif
fi->fh = fh;
}
static inline int hostFilldir(fuse_fill_dir_t filler, void *buf,
char *name, fuse_stat_t *stbuf, fuse_off_t off)
{
#if FUSE_USE_VERSION < 30
return filler(buf, name, stbuf, off);
#else
return filler(buf, name, stbuf, off, FUSE_FILL_DIR_PLUS);
#endif
}
#if defined(__APPLE__)
static int _hostSetxattr(char *path, char *name, char *value, size_t size, int flags,
uint32_t position)
{
// OSX uses position only for the resource fork; we do not support it!
return go_hostSetxattr(path, name, value, size, flags);
}
static int _hostGetxattr(char *path, char *name, char *value, size_t size,
uint32_t position)
{
// OSX uses position only for the resource fork; we do not support it!
return go_hostGetxattr(path, name, value, size);
}
#else
#define _hostSetxattr go_hostSetxattr
#define _hostGetxattr go_hostGetxattr
#endif
// hostStaticInit, hostFuseInit and hostInit serve different purposes.
//
// hostStaticInit and hostFuseInit are needed to provide static and dynamic initialization
// of the FUSE layer. This is currently useful on Windows only.
//
// hostInit is simply the .init implementation of struct fuse_operations.
static void hostStaticInit(void)
{
cgofuse_mutex_init(&cgofuse_mutex);
}
static int hostFuseInit(void)
{
return 0 != cgofuse_init_fast(0);
}
static int hostMount(int argc, char *argv[], void *data)
{
static struct fuse_operations fsop =
{
#if FUSE_USE_VERSION < 30
.getattr = (int (*)(const char *, fuse_stat_t *))go_hostGetattr,
#else
.getattr = (int (*)(const char *, fuse_stat_t *, struct fuse_file_info *))go_hostGetattr3,
#endif
.readlink = (int (*)(const char *, char *, size_t))go_hostReadlink,
.mknod = (int (*)(const char *, fuse_mode_t, fuse_dev_t))go_hostMknod,
.mkdir = (int (*)(const char *, fuse_mode_t))go_hostMkdir,
.unlink = (int (*)(const char *))go_hostUnlink,
.rmdir = (int (*)(const char *))go_hostRmdir,
.symlink = (int (*)(const char *, const char *))go_hostSymlink,
#if FUSE_USE_VERSION < 30
.rename = (int (*)(const char *, const char *))go_hostRename,
#else
.rename = (int (*)(const char *, const char *, unsigned int flags))go_hostRename3,
#endif
.link = (int (*)(const char *, const char *))go_hostLink,
#if FUSE_USE_VERSION < 30
.chmod = (int (*)(const char *, fuse_mode_t))go_hostChmod,
.chown = (int (*)(const char *, fuse_uid_t, fuse_gid_t))go_hostChown,
.truncate = (int (*)(const char *, fuse_off_t))go_hostTruncate,
#else
.chmod = (int (*)(const char *, fuse_mode_t, struct fuse_file_info *))go_hostChmod3,
.chown = (int (*)(const char *, fuse_uid_t, fuse_gid_t, struct fuse_file_info *))go_hostChown3,
.truncate = (int (*)(const char *, fuse_off_t, struct fuse_file_info *))go_hostTruncate3,
#endif
.open = (int (*)(const char *, struct fuse_file_info *))go_hostOpen,
.read = (int (*)(const char *, char *, size_t, fuse_off_t, struct fuse_file_info *))
go_hostRead,
.write = (int (*)(const char *, const char *, size_t, fuse_off_t, struct fuse_file_info *))
go_hostWrite,
.statfs = (int (*)(const char *, fuse_statvfs_t *))go_hostStatfs,
.flush = (int (*)(const char *, struct fuse_file_info *))go_hostFlush,
.release = (int (*)(const char *, struct fuse_file_info *))go_hostRelease,
.fsync = (int (*)(const char *, int, struct fuse_file_info *))go_hostFsync,
#if defined(__APPLE__)
.setxattr = (int (*)(const char *, const char *, const char *, size_t, int, uint32_t))
_hostSetxattr,
.getxattr = (int (*)(const char *, const char *, char *, size_t, uint32_t))
_hostGetxattr,
#else
.setxattr = (int (*)(const char *, const char *, const char *, size_t, int))_hostSetxattr,
.getxattr = (int (*)(const char *, const char *, char *, size_t))_hostGetxattr,
#endif
.listxattr = (int (*)(const char *, char *, size_t))go_hostListxattr,
.removexattr = (int (*)(const char *, const char *))go_hostRemovexattr,
.opendir = (int (*)(const char *, struct fuse_file_info *))go_hostOpendir,
#if FUSE_USE_VERSION < 30
.readdir = (int (*)(const char *, void *, fuse_fill_dir_t, fuse_off_t,
struct fuse_file_info *))go_hostReaddir,
#else
.readdir = (int (*)(const char *, void *, fuse_fill_dir_t, fuse_off_t,
struct fuse_file_info *, enum fuse_readdir_flags flags))go_hostReaddir3,
#endif
.releasedir = (int (*)(const char *, struct fuse_file_info *))go_hostReleasedir,
.fsyncdir = (int (*)(const char *, int, struct fuse_file_info *))go_hostFsyncdir,
#if FUSE_USE_VERSION < 30
.init = (void *(*)(struct fuse_conn_info *))go_hostInit,
#else
.init = (void *(*)(struct fuse_conn_info *, struct fuse_config *))go_hostInit3,
#endif
.destroy = (void (*)(void *))go_hostDestroy,
.access = (int (*)(const char *, int))go_hostAccess,
.create = (int (*)(const char *, fuse_mode_t, struct fuse_file_info *))go_hostCreate,
#if FUSE_USE_VERSION < 30
.ftruncate = (int (*)(const char *, fuse_off_t, struct fuse_file_info *))go_hostFtruncate,
.fgetattr = (int (*)(const char *, fuse_stat_t *, struct fuse_file_info *))go_hostFgetattr,
#endif
//.lock = (int (*)(const char *, struct fuse_file_info *, int, struct fuse_flock *))
// go_hostFlock,
#if FUSE_USE_VERSION < 30
.utimens = (int (*)(const char *, const fuse_timespec_t [2]))go_hostUtimens,
#else
.utimens = (int (*)(const char *, const fuse_timespec_t [2], struct fuse_file_info *))go_hostUtimens3,
#endif
#if defined(__APPLE__)
.setchgtime = (int (*)(const char *, const fuse_timespec_t *))go_hostSetchgtime,
.setcrtime = (int (*)(const char *, const fuse_timespec_t *))go_hostSetcrtime,
.chflags = (int (*)(const char *, uint32_t))go_hostChflags,
#endif
};
return fuse_main_real(argc, argv, &fsop, sizeof fsop, data);
}
static int hostUnmount(struct fuse *fuse, char *mountpoint)
{
#if defined(__APPLE__) || defined(__FreeBSD__) || defined(__NetBSD__) || defined(__OpenBSD__)
if (0 == mountpoint)
return 0;
// darwin,freebsd,netbsd: unmount is available to non-root
// openbsd: kern.usermount has been removed and mount/unmount is available to root only
return unmount(mountpoint, MNT_FORCE);
#elif defined(__linux__)
if (0 == mountpoint)
return 0;
// linux: try umount2 first in case we are root
if (0 == umount2(mountpoint, MNT_DETACH))
return 0;
// linux: umount2 failed; try fusermount
char *paths[] =
{
"/bin/fusermount",
"/usr/bin/fusermount",
};
char *path = paths[0];
for (size_t i = 0; sizeof paths / sizeof paths[0] > i; i++)
if (0 == access(paths[i], X_OK))
{
path = paths[i];
break;
}
char *argv[] =
{
path,
"-z",
"-u",
mountpoint,
0,
};
pid_t pid = 0;
int status = 0;
if ((status = posix_spawn(&pid, argv[0], 0, 0, argv, 0)) != 0) {
return status;
}
waitpid(pid, &status, 0);
WIFEXITED(status);
return WEXITSTATUS(status);
#endif
}
static int hostNotify(struct fuse *fuse, const char *path, uint32_t action)
{
return 0;
}
static void hostOptSet(struct fuse_opt *opt,
const char *templ, fuse_opt_offset_t offset, int value)
{
memset(opt, 0, sizeof *opt);
#if defined(__OpenBSD__)
opt->templ = templ;
opt->off = offset;
opt->val = value;
#else
opt->templ = templ;
opt->offset = offset;
opt->value = value;
#endif
}
static int hostOptParseOptProc(void *opt_data, const char *arg, int key,
struct fuse_args *outargs)
{
switch (key)
{
default:
return 0;
case FUSE_OPT_KEY_NONOPT:
return 1;
}
}
static int hostOptParse(struct fuse_args *args, void *data, const struct fuse_opt opts[],
bool nonopts)
{
return fuse_opt_parse(args, data, opts, nonopts ? hostOptParseOptProc : 0);
}
*/
import "C"
import "unsafe"
type (
c_bool = C.bool
c_char = C.char
c_fuse_dev_t = C.fuse_dev_t
c_fuse_fill_dir_t = C.fuse_fill_dir_t
c_fuse_gid_t = C.fuse_gid_t
c_fuse_mode_t = C.fuse_mode_t
c_fuse_off_t = C.fuse_off_t
c_fuse_opt_offset_t = C.fuse_opt_offset_t
c_enum_fuse_readdir_flags = C.enum_fuse_readdir_flags
c_fuse_stat_t = C.fuse_stat_t
c_fuse_stat_ex_t = C.fuse_stat_ex_t
c_fuse_statvfs_t = C.fuse_statvfs_t
c_fuse_timespec_t = C.fuse_timespec_t
c_fuse_uid_t = C.fuse_uid_t
c_int = C.int
c_int16_t = C.int16_t
c_int32_t = C.int32_t
c_int64_t = C.int64_t
c_int8_t = C.int8_t
c_size_t = C.size_t
c_struct_fuse = C.struct_fuse
c_struct_fuse_args = C.struct_fuse_args
c_struct_fuse_config = C.struct_fuse_config
c_struct_fuse_conn_info = C.struct_fuse_conn_info
c_struct_fuse_context = C.struct_fuse_context
c_struct_fuse_file_info = C.struct_fuse_file_info
c_struct_fuse_opt = C.struct_fuse_opt
c_uint16_t = C.uint16_t
c_uint32_t = C.uint32_t
c_uint64_t = C.uint64_t
c_uint8_t = C.uint8_t
c_uintptr_t = C.uintptr_t
c_unsigned = C.unsigned
)
func c_GoString(s *c_char) string {
return C.GoString(s)
}
func c_CString(s string) *c_char {
return C.CString(s)
}
func c_malloc(size c_size_t) unsafe.Pointer {
return C.malloc(size)
}
func c_calloc(count c_size_t, size c_size_t) unsafe.Pointer {
return C.calloc(count, size)
}
func c_free(p unsafe.Pointer) {
C.free(p)
}
func c_fuse_get_context() *c_struct_fuse_context {
return C.fuse_get_context()
}
func c_fuse_opt_free_args(args *c_struct_fuse_args) {
C.fuse_opt_free_args(args)
}
func c_hostAsgnCconninfo(conn *c_struct_fuse_conn_info,
capCaseInsensitive c_bool,
capReaddirPlus c_bool,
capDeleteAccess c_bool,
capOpenTrunc c_bool) {
C.hostAsgnCconninfo(conn, capCaseInsensitive, capReaddirPlus, capDeleteAccess, capOpenTrunc)
}
func c_hostAsgnCconfig(conf *c_struct_fuse_config,
directIO c_bool,
useIno c_bool) {
C.hostAsgnCconfig(conf, directIO, useIno)
}
func c_hostCstatvfsFromFusestatfs(stbuf *c_fuse_statvfs_t,
bsize c_uint64_t,
frsize c_uint64_t,
blocks c_uint64_t,
bfree c_uint64_t,
bavail c_uint64_t,
files c_uint64_t,
ffree c_uint64_t,
favail c_uint64_t,
fsid c_uint64_t,
flag c_uint64_t,
namemax c_uint64_t) {
C.hostCstatvfsFromFusestatfs(stbuf,
bsize,
frsize,
blocks,
bfree,
bavail,
files,
ffree,
favail,
fsid,
flag,
namemax)
}
func c_hostCstatFromFusestat(stbuf *c_fuse_stat_t,
dev c_uint64_t,
ino c_uint64_t,
mode c_uint32_t,
nlink c_uint32_t,
uid c_uint32_t,
gid c_uint32_t,
rdev c_uint64_t,
size c_int64_t,
atimSec c_int64_t, atimNsec c_int64_t,
mtimSec c_int64_t, mtimNsec c_int64_t,
ctimSec c_int64_t, ctimNsec c_int64_t,
blksize c_int64_t,
blocks c_int64_t,
birthtimSec c_int64_t, birthtimNsec c_int64_t,
flags c_uint32_t) {
C.hostCstatFromFusestat(stbuf,
dev,
ino,
mode,
nlink,
uid,
gid,
rdev,
size,
atimSec,
atimNsec,
mtimSec,
mtimNsec,
ctimSec,
ctimNsec,
blksize,
blocks,
birthtimSec,
birthtimNsec,
flags)
}
func c_hostAsgnCfileinfo(fi *c_struct_fuse_file_info,
direct_io c_bool,
keep_cache c_bool,
nonseekable c_bool,
fh c_uint64_t) {
C.hostAsgnCfileinfo(fi,
direct_io,
keep_cache,
nonseekable,
fh)
}
func c_hostFilldir(filler c_fuse_fill_dir_t,
buf unsafe.Pointer, name *c_char, stbuf *c_fuse_stat_t, off c_fuse_off_t) c_int {
return C.hostFilldir(filler, buf, name, stbuf, off)
}
func c_hostStaticInit() {
C.hostStaticInit()
}
func c_hostFuseInit() c_int {
return C.hostFuseInit()
}
func c_hostMount(argc c_int, argv **c_char, data unsafe.Pointer) c_int {
return C.hostMount(argc, argv, data)
}
func c_hostUnmount(fuse *c_struct_fuse, mountpoint *c_char) c_int {
return C.hostUnmount(fuse, mountpoint)
}
func c_hostNotify(fuse *c_struct_fuse, path *c_char, action c_uint32_t) c_int {
return C.hostNotify(fuse, path, action)
}
func c_hostOptSet(opt *c_struct_fuse_opt,
templ *c_char, offset c_fuse_opt_offset_t, value c_int) {
C.hostOptSet(opt, templ, offset, value)
}
func c_hostOptParse(args *c_struct_fuse_args, data unsafe.Pointer, opts *c_struct_fuse_opt,
nonopts c_bool) c_int {
return C.hostOptParse(args, data, opts, nonopts)
}
//export go_hostGetattr
func go_hostGetattr(path0 *c_char, stat0 *c_fuse_stat_t) (errc0 c_int) {
return hostGetattr(path0, stat0, nil)
}
//export go_hostGetattr3
func go_hostGetattr3(path0 *c_char, stat0 *c_fuse_stat_t,
fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostGetattr(path0, stat0, fi0)
}
//export go_hostReadlink
func go_hostReadlink(path0 *c_char, buff0 *c_char, size0 c_size_t) (errc0 c_int) {
return hostReadlink(path0, buff0, size0)
}
//export go_hostMknod
func go_hostMknod(path0 *c_char, mode0 c_fuse_mode_t, dev0 c_fuse_dev_t) (errc0 c_int) {
return hostMknod(path0, mode0, dev0)
}
//export go_hostMkdir
func go_hostMkdir(path0 *c_char, mode0 c_fuse_mode_t) (errc0 c_int) {
return hostMkdir(path0, mode0)
}
//export go_hostUnlink
func go_hostUnlink(path0 *c_char) (errc0 c_int) {
return hostUnlink(path0)
}
//export go_hostRmdir
func go_hostRmdir(path0 *c_char) (errc0 c_int) {
return hostRmdir(path0)
}
//export go_hostSymlink
func go_hostSymlink(target0 *c_char, newpath0 *c_char) (errc0 c_int) {
return hostSymlink(target0, newpath0)
}
//export go_hostRename
func go_hostRename(oldpath0 *c_char, newpath0 *c_char) (errc0 c_int) {
return hostRename(oldpath0, newpath0, 0)
}
//export go_hostRename3
func go_hostRename3(oldpath0 *c_char, newpath0 *c_char, flags c_uint32_t) (errc0 c_int) {
return hostRename(oldpath0, newpath0, flags)
}
//export go_hostLink
func go_hostLink(oldpath0 *c_char, newpath0 *c_char) (errc0 c_int) {
return hostLink(oldpath0, newpath0)
}
//export go_hostChmod
func go_hostChmod(path0 *c_char, mode0 c_fuse_mode_t) (errc0 c_int) {
return hostChmod(path0, mode0, nil)
}
//export go_hostChmod3
func go_hostChmod3(path0 *c_char, mode0 c_fuse_mode_t, fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostChmod(path0, mode0, fi0)
}
//export go_hostChown
func go_hostChown(path0 *c_char, uid0 c_fuse_uid_t, gid0 c_fuse_gid_t) (errc0 c_int) {
return hostChown(path0, uid0, gid0, nil)
}
//export go_hostChown3
func go_hostChown3(path0 *c_char, uid0 c_fuse_uid_t, gid0 c_fuse_gid_t, fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostChown(path0, uid0, gid0, fi0)
}
//export go_hostTruncate
func go_hostTruncate(path0 *c_char, size0 c_fuse_off_t) (errc0 c_int) {
return hostTruncate(path0, size0, nil)
}
//export go_hostTruncate3
func go_hostTruncate3(path0 *c_char, size0 c_fuse_off_t,
fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostTruncate(path0, size0, fi0)
}
//export go_hostOpen
func go_hostOpen(path0 *c_char, fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostOpen(path0, fi0)
}
//export go_hostRead
func go_hostRead(path0 *c_char, buff0 *c_char, size0 c_size_t, ofst0 c_fuse_off_t,
fi0 *c_struct_fuse_file_info) (nbyt0 c_int) {
return hostRead(path0, buff0, size0, ofst0, fi0)
}
//export go_hostWrite
func go_hostWrite(path0 *c_char, buff0 *c_char, size0 c_size_t, ofst0 c_fuse_off_t,
fi0 *c_struct_fuse_file_info) (nbyt0 c_int) {
return hostWrite(path0, buff0, size0, ofst0, fi0)
}
//export go_hostStatfs
func go_hostStatfs(path0 *c_char, stat0 *c_fuse_statvfs_t) (errc0 c_int) {
return hostStatfs(path0, stat0)
}
//export go_hostFlush
func go_hostFlush(path0 *c_char, fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostFlush(path0, fi0)
}
//export go_hostRelease
func go_hostRelease(path0 *c_char, fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostRelease(path0, fi0)
}
//export go_hostFsync
func go_hostFsync(path0 *c_char, datasync c_int, fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostFsync(path0, datasync, fi0)
}
//export go_hostSetxattr
func go_hostSetxattr(path0 *c_char, name0 *c_char, buff0 *c_char, size0 c_size_t,
flags c_int) (errc0 c_int) {
return hostSetxattr(path0, name0, buff0, size0, flags)
}
//export go_hostGetxattr
func go_hostGetxattr(path0 *c_char, name0 *c_char, buff0 *c_char, size0 c_size_t) (nbyt0 c_int) {
return hostGetxattr(path0, name0, buff0, size0)
}
//export go_hostListxattr
func go_hostListxattr(path0 *c_char, buff0 *c_char, size0 c_size_t) (nbyt0 c_int) {
return hostListxattr(path0, buff0, size0)
}
//export go_hostRemovexattr
func go_hostRemovexattr(path0 *c_char, name0 *c_char) (errc0 c_int) {
return hostRemovexattr(path0, name0)
}
//export go_hostOpendir
func go_hostOpendir(path0 *c_char, fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostOpendir(path0, fi0)
}
//export go_hostReaddir
func go_hostReaddir(path0 *c_char,
buff0 unsafe.Pointer, fill0 c_fuse_fill_dir_t, ofst0 c_fuse_off_t,
fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostReaddir(path0, buff0, fill0, ofst0, fi0)
}
//export go_hostReaddir3
func go_hostReaddir3(path0 *c_char,
buff0 unsafe.Pointer, fill0 c_fuse_fill_dir_t, ofst0 c_fuse_off_t,
fi0 *c_struct_fuse_file_info, flags c_enum_fuse_readdir_flags) (errc0 c_int) {
return hostReaddir(path0, buff0, fill0, ofst0, fi0)
}
//export go_hostReleasedir
func go_hostReleasedir(path0 *c_char, fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostReleasedir(path0, fi0)
}
//export go_hostFsyncdir
func go_hostFsyncdir(path0 *c_char, datasync c_int, fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostFsyncdir(path0, datasync, fi0)
}
//export go_hostInit
func go_hostInit(conn0 *c_struct_fuse_conn_info) (user_data unsafe.Pointer) {
return hostInit(conn0, nil)
}
//export go_hostInit3
func go_hostInit3(conn0 *c_struct_fuse_conn_info, conf0 *c_struct_fuse_config) (user_data unsafe.Pointer) {
return hostInit(conn0, conf0)
}
//export go_hostDestroy
func go_hostDestroy(user_data unsafe.Pointer) {
hostDestroy(user_data)
}
//export go_hostAccess
func go_hostAccess(path0 *c_char, mask0 c_int) (errc0 c_int) {
return hostAccess(path0, mask0)
}
//export go_hostCreate
func go_hostCreate(path0 *c_char, mode0 c_fuse_mode_t, fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostCreate(path0, mode0, fi0)
}
//export go_hostFtruncate
func go_hostFtruncate(path0 *c_char, size0 c_fuse_off_t,
fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostFtruncate(path0, size0, fi0)
}
//export go_hostFgetattr
func go_hostFgetattr(path0 *c_char, stat0 *c_fuse_stat_t,
fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostFgetattr(path0, stat0, fi0)
}
//export go_hostUtimens
func go_hostUtimens(path0 *c_char, tmsp0 *c_fuse_timespec_t) (errc0 c_int) {
return hostUtimens(path0, tmsp0, nil)
}
//export go_hostUtimens3
func go_hostUtimens3(path0 *c_char, tmsp0 *c_fuse_timespec_t, fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostUtimens(path0, tmsp0, fi0)
}
//export go_hostGetpath
func go_hostGetpath(path0 *c_char, buff0 *c_char, size0 c_size_t,
fi0 *c_struct_fuse_file_info) (errc0 c_int) {
return hostGetpath(path0, buff0, size0, fi0)
}
//export go_hostSetchgtime
func go_hostSetchgtime(path0 *c_char, tmsp0 *c_fuse_timespec_t) (errc0 c_int) {
return hostSetchgtime(path0, tmsp0)
}
//export go_hostSetcrtime
func go_hostSetcrtime(path0 *c_char, tmsp0 *c_fuse_timespec_t) (errc0 c_int) {
return hostSetcrtime(path0, tmsp0)
}
//export go_hostChflags
func go_hostChflags(path0 *c_char, flags c_uint32_t) (errc0 c_int) {
return hostChflags(path0, flags)
}