1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
// SPDX-License-Identifier: GPL-2.0
#include "fuse_common.h"
static void *run_daemon(void *arg)
{
fuse_session_loop((struct fuse_session *)arg);
return NULL;
}
int fs_setup(const struct fuse_lowlevel_ops *fs_ops,
struct fuse_common_ctx *ctx, char *err)
{
char *fuse_argv[] = { "fuse_test", NULL };
struct fuse_args args = FUSE_ARGS_INIT(1, fuse_argv);
strcpy(ctx->mountpoint, MOUNTPOINT_TEMPLATE);
if (!mkdtemp(ctx->mountpoint)) {
snprintf(err, MAX_ERR_MSG, "mkdtemp: %s", strerror(errno));
return -1;
}
ctx->se = fuse_session_new(&args, fs_ops, sizeof(*fs_ops), NULL);
if (!ctx->se) {
rmdir(ctx->mountpoint);
snprintf(err, MAX_ERR_MSG, "fuse_session_new failed");
return -1;
}
if (fuse_session_mount(ctx->se, ctx->mountpoint)) {
fuse_session_destroy(ctx->se);
rmdir(ctx->mountpoint);
snprintf(err, MAX_ERR_MSG, "fuse_session_mount failed "
"(missing fusermount3 or insufficient privileges)");
return -1;
}
if (pthread_create(&ctx->thread, NULL, run_daemon, ctx->se)) {
fuse_session_unmount(ctx->se);
fuse_session_destroy(ctx->se);
rmdir(ctx->mountpoint);
snprintf(err, MAX_ERR_MSG, "pthread_create: %s", strerror(errno));
return -1;
}
fuse_opt_free_args(&args);
return 0;
}
void fs_teardown(struct fuse_common_ctx *ctx)
{
fuse_session_exit(ctx->se);
fuse_session_unmount(ctx->se);
pthread_join(ctx->thread, NULL);
fuse_session_destroy(ctx->se);
rmdir(ctx->mountpoint);
}
|
