libfuse:退出fuse_session_loop

Question

上下文:Ubuntu 11.10和libfuse 2.8.4-1.4ubuntu1 Linux 3.0.0-14-generic#23-Ubuntu SMP Mon Nov 21 20:28:43 UTC 2011 x86_64 x86_64 x86_64 GNU/Linux

我正在尝试使用libfuse.我想让fuse_session_loop退出(从信号处理程序或不同的线程),但是当我调用fuse_session_exit时,在会话收到新请求之前没有任何反应.

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"设备的"读取"系统调用,所以即使设置了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

通常，如果在系统调用（例如read(2)）阻塞时执行信号处理程序，系统调用会立即返回（在信号处理程序完成执行后）并带有EINTR。这显然是fuse_session_loop和fuse_session_exit的设计目的。

但是，如果信号处理程序安装时设置了SA_RESTART标志（请参阅sigaction(2) ），则在信号处理程序执行后，系统调用将不会返回EINTR 。系统调用将恢复阻塞。

由于某种原因，在我的系统（Ubuntu 11.10 x86_64）上，signal(2)的默认行为是使用SA_RESTART标志安装信号处理程序。

即以下程序的 strace...

#include <stdlib.h>
#include <signal.h>

void f(int signum) {}

int main()
{
    signal(SIGINT,f);
    return EXIT_SUCCESS;
}

...如下...

rt_sigaction(SIGINT, {0x400524, [INT], SA_RESTORER|SA_RESTART, 0x7f4997e1f420}, {SIG_DFL, [], 0}, 8) = 0

由于这个原因，信号（在fuse和我自己的程序提供的示例中）没有中断fuse_kern_chan_receive中的阻塞读取，正如它们的作者所期望的那样。

修复方法是使用sigaction(2)（并将SA_RESTART位保留为零）来安装处理程序（而不是signal(2)）。

仍然存在的一个悬而未决的问题是，为什么对signal(2)的调用默认会打开SA_RESTART标志？我希望中断（而不是重新启动）是预期的默认行为。