mirror of
https://github.com/falk-werner/webfuse-provider
synced 2024-10-27 20:44:10 +00:00
84 lines
1.9 KiB
C
84 lines
1.9 KiB
C
#include "wsfs/filesystem.h"
|
|
#include "wsfs/operations.h"
|
|
#include "wsfs/jsonrpc/server.h"
|
|
|
|
#include <stddef.h>
|
|
#include <string.h>
|
|
#include <errno.h>
|
|
|
|
static struct fuse_lowlevel_ops const wsfs_filesystem_operations =
|
|
{
|
|
.lookup = &wsfs_operation_lookup,
|
|
.getattr = &wsfs_operation_getattr,
|
|
.readdir = &wsfs_operation_readdir,
|
|
.open = &wsfs_operation_open,
|
|
.release = &wsfs_operation_close,
|
|
.read = &wsfs_operation_read
|
|
};
|
|
|
|
|
|
bool wsfs_filesystem_init(
|
|
struct wsfs_filesystem * filesystem,
|
|
struct wsfs_jsonrpc_server * rpc,
|
|
char * mount_point)
|
|
{
|
|
bool result = false;
|
|
|
|
char * argv[] = {"", NULL};
|
|
filesystem->args.argc = 1;
|
|
filesystem->args.argv = argv;
|
|
filesystem->args.allocated = 0;
|
|
|
|
filesystem->user_data.rpc = rpc;
|
|
filesystem->user_data.timeout = 1.0;
|
|
memset(&filesystem->buffer, 0, sizeof(struct fuse_buf));
|
|
|
|
filesystem->session = fuse_session_new(
|
|
&filesystem->args,
|
|
&wsfs_filesystem_operations,
|
|
sizeof(wsfs_filesystem_operations),
|
|
&filesystem->user_data);
|
|
if (NULL != filesystem->session)
|
|
{
|
|
result = (0 == fuse_session_mount(filesystem->session, mount_point));
|
|
}
|
|
|
|
return result;
|
|
}
|
|
|
|
void wsfs_filesystem_cleanup(
|
|
struct wsfs_filesystem * filesystem)
|
|
{
|
|
if (NULL != filesystem->session)
|
|
{
|
|
fuse_session_reset(filesystem->session);
|
|
fuse_session_unmount(filesystem->session);
|
|
fuse_session_destroy(filesystem->session);
|
|
filesystem->session = NULL;
|
|
}
|
|
|
|
free(filesystem->buffer.mem);
|
|
fuse_opt_free_args(&filesystem->args);
|
|
}
|
|
|
|
int wsfs_filesystem_get_fd(
|
|
struct wsfs_filesystem * filesystem)
|
|
{
|
|
return fuse_session_fd(filesystem->session);
|
|
}
|
|
|
|
void wsfs_filesystem_process_request(
|
|
struct wsfs_filesystem * filesystem)
|
|
{
|
|
int const result = fuse_session_receive_buf(filesystem->session, &filesystem->buffer);
|
|
if (0 < result)
|
|
{
|
|
fuse_session_process_buf(filesystem->session, &filesystem->buffer);
|
|
}
|
|
else if (-EINTR != result)
|
|
{
|
|
// ToDo
|
|
}
|
|
|
|
}
|