Почему FUSE блокирует все потоки?

Я взял предохранитель Привет и изменил дно, чтобы показать, о чем я говорю. В моем приложении мне нужно сделать что-то после того, как мой предохранитель FS будет доступен. Мне также нужен другой поток для IPC и поддержания некоторых вещей в актуальном состоянии. Так как fuse_main не возвращается, я бросил его в своей собственной теме.

Когда я закомментирую fuse_main консоль показывает A и B. Однако, если я не закомментирую fuse_main (который находится в другой ветке) только A печатается. Как, черт возьми, предохранитель останавливает мой основной поток и как мне запустить код после того, как FUSE сделает свое дело?

#define FUSE_USE_VERSION 26

#include <fuse.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <fcntl.h>

static const char *hello_str = "Hello World!\n";
static const char *hello_path = "/hello";

static int hello_getattr(const char *path, struct stat *stbuf)
{
int res = 0;

memset(stbuf, 0, sizeof(struct stat));
if (strcmp(path, "/") == 0) {
stbuf->st_mode = S_IFDIR | 0755;
stbuf->st_nlink = 2;
} else if (strcmp(path, hello_path) == 0) {
stbuf->st_mode = S_IFREG | 0444;
stbuf->st_nlink = 1;
stbuf->st_size = strlen(hello_str);
} else
res = -ENOENT;

return res;
}

static int hello_readdir(const char *path, void *buf, fuse_fill_dir_t filler,
off_t offset, struct fuse_file_info *fi)
{
(void) offset;
(void) fi;

if (strcmp(path, "/") != 0)
return -ENOENT;

filler(buf, ".", NULL, 0);
filler(buf, "..", NULL, 0);
filler(buf, hello_path + 1, NULL, 0);

return 0;
}

static int hello_open(const char *path, struct fuse_file_info *fi)
{
if (strcmp(path, hello_path) != 0)
return -ENOENT;

if ((fi->flags & 3) != O_RDONLY)
return -EACCES;

return 0;
}

static int hello_read(const char *path, char *buf, size_t size, off_t offset,
struct fuse_file_info *fi)
{
size_t len;
(void) fi;
if(strcmp(path, hello_path) != 0)
return -ENOENT;

len = strlen(hello_str);
if (offset < len) {
if (offset + size > len)
size = len - offset;
memcpy(buf, hello_str + offset, size);
} else
size = 0;

return size;
}

static struct fuse_operations hello_oper;
//modification starts below this line
#include<thread>
#include<unistd.h>
int main(int argc, char *argv[])
{
std::thread t([&]{
hello_oper.getattr  = hello_getattr;
hello_oper.readdir  = hello_readdir;
hello_oper.open     = hello_open;
hello_oper.read     = hello_read;

return fuse_main(argc, argv, &hello_oper, NULL);
});
printf("A\n");
sleep(5);
printf("B\n");
t.join();
}

8

Решение

fuse_main демонизирует, то есть звонит fork() и звонки _exit(0) в родительском процессе, поэтому процесс завершается, поэтому вы видите только A распечатывать.

Если вы даете вариант -f в ./hello -f /tmp/fuse fuse_main не звонит _exit но остается в живых на переднем плане и оба A а также B можно увидеть.

Вам, безусловно, нужен способ положить конец fuse_main Поток изящно, когда ваша программа хочет выйти:

//modification starts below this line
#include<thread>
#include<unistd.h>
#include <signal.h>
#include <sys/syscall.h>

int main(int argc, char *argv[])
{
pid_t tid;
std::thread t([&]{
hello_oper.getattr  = hello_getattr;
hello_oper.readdir  = hello_readdir;
hello_oper.open     = hello_open;
hello_oper.read     = hello_read;

tid = syscall(SYS_gettid);
return fuse_main(argc, argv, &hello_oper, NULL);
});
printf("A\n");
sleep(5);
printf("B\n");
kill(tid, SIGTERM);
t.join();
}

Варианты для hello:

general options:
-o opt,[opt...]        mount options
-h   --help            print help
-V   --version         print version

FUSE options:
-d   -o debug          enable debug output (implies -f)
-f                     foreground operation
-s                     disable multi-threaded operation
[...]
8

Другие решения

Из того, что я прочитал в документации здесь http://fuse.sourceforge.net/doxygen/hello_8c.html на использовании hello.c программа говорит, что программа выходит и исчезает на заднем плане, такова природа fuse_main API. Почему бы вам не попробовать, начиная с этого кода
http://fuse.sourceforge.net/doxygen/hello__ll_8c.html, из их описания,
unlike hello.c this example will stay in the foreground. it also replaced the convenience function fuse_main(..) with a more low level approach. Таким образом, в линии,

err = fuse_session_loop(se);

в основной функции у вас есть контроль, чтобы иметь дополнения и делать другие вещи, которые вы хотите сделать.

Также есть реализация C ++ для FUSE, https://code.google.com/p/fusekit/

Надеюсь это поможет.

4

По вопросам рекламы [email protected]