falk-werner_webfuse-provider/lib/wsfs/filesystem.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
	}

}