fuse - libfuse : exiting fuse_session_loop

Question

上下文:Ubuntu 11.10 和 libfuse 2.8.4-1.4ubuntu1Linux 3.0.0-14-generic#23-Ubuntu SMP 11 月 21 日星期一 20:28:43 UTC 2011 x86_64 x86_64 x86_64 GNU/Linux

我正在尝试使用 libfuse。我想导致fuse_session_loop退出(从信号处理程序或不同的线程)，但是当我调用fuse_session_exit时，在 session 收到新请求之前不会发生任何事情。

fuse_session_exit 设置一个由fuse_session_exited 读取的标志。调试到fuse_session_loop，它似乎在fuse_chan_recv上阻塞，因此它不会再次检查fuse_session_exited，直到循环顶部...

int fuse_session_loop(struct fuse_session *se)
{
    int res = 0;
    struct fuse_chan *ch = fuse_session_next_chan(se, NULL);
    size_t bufsize = fuse_chan_bufsize(ch);
    char *buf = (char *) malloc(bufsize);
    if (!buf) {
        fprintf(stderr, "fuse: failed to allocate read buffer\n");
        return -1;
    }

    while (!fuse_session_exited(se)) {
        struct fuse_chan *tmpch = ch;
        res = fuse_chan_recv(&tmpch, buf, bufsize); <--- BLOCKING
        if (res == -EINTR)
            continue;
        if (res <= 0)
            break;
        fuse_session_process(se, buf, res, tmpch);
    }

    free(buf);
    fuse_session_reset(se);
    return res < 0 ? -1 : 0;
}

fuse_chan_recv调用fuse_kern_chan_receive，它会阻止“/dev/fuse”设备的“read”系统调用，因此即使设置了fuse_session_exited标志，也不会发生任何事情。

static int fuse_kern_chan_receive(struct fuse_chan **chp, char *buf,
                  size_t size)
{
    struct fuse_chan *ch = *chp;
    int err;
    ssize_t res;
    struct fuse_session *se = fuse_chan_session(ch);
    assert(se != NULL);

restart:
    res = read(fuse_chan_fd(ch), buf, size); <--- BLOCKING
    err = errno;

    if (fuse_session_exited(se))
        return 0;
    if (res == -1) {
        /* ENOENT means the operation was interrupted, it's safe
           to restart */
        if (err == ENOENT)
            goto restart;

        if (err == ENODEV) {
            fuse_session_exit(se);
            return 0;
        }
        /* Errors occuring during normal operation: EINTR (read
           interrupted), EAGAIN (nonblocking I/O), ENODEV (filesystem
           umounted) */
        if (err != EINTR && err != EAGAIN)
            perror("fuse: reading device");
        return -err;
    }
    if ((size_t) res < sizeof(struct fuse_in_header)) {
        fprintf(stderr, "short read on fuse device\n");
        return -EIO;
    }
    return res;
}

这个问题似乎会影响 libfuse 提供的 hello_ll.c 示例以及我的程序。这让我觉得也许有某种机制没有发挥作用，但它应该发挥作用。也许fuse_session_exit也应该做一些中断读取调用的事情，由于某种原因，它在我的系统上不起作用。

有什么想法吗？

Answer 1

这可能值得提交错误报告；它也可能被关闭为“按预期工作”。

也就是说，如果您还发送信号来中断 fuse_kern_chan_receive() 函数中执行的 read() 调用，则会出现准备通过堆栈向上传播错误，这将触发更高级别调用中的继续，这将注意到退出标志，并希望干净地终止循环尽可能。

尝试添加 pthread_kill(3) 来终止有问题的特定线程。 fuse_signals.c 为调用 fuse_session_exit() 的 SIGHUP、SIGINT 和 SIGTERM 安装处理程序>.