Pregunta

Contexto: Ubuntu 11.10 y Libfuse 2.8.4-1.4ubuntu1 Linux 3.0.0-14-Generic #23-Ubuntu SMP lon 21 de noviembre 20:28:43 UTC 2011 x86_64 x86_64 x86_64 Gnu/Linux

Estoy tratando de usar libfuse. Quiero hacer que Fuse_Session_Lloop salga (desde un controlador de señal o un hilo diferente), pero cuando llamo a Fuse_Session_Exit, nada sucede hasta que la sesión recibe una nueva solicitud.

FUSE_SESSION_EXIT establece un indicador que es leído por fuse_session_exited. Depuración en fuse_session_loop parece bloquear en fuse_chan_recv, por lo que no verifica fuse_session_exited hasta la parte superior del bucle ...

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 LLAME FUSE_KERN_CHAN_RECEIVE que bloquea la "Leer" Syscall del dispositivo "/dev/fuse", por lo que a pesar de que el indicador FUSE_SESSION_EXITED no sucede aún.

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;
}

Este problema parece efectuar el ejemplo de Hello_ll.C proporcionado con libfuse, así como mi programa. Me hace pensar que tal vez hay algún mecanismo que no funciona. Quizás se supone que Fuse_Session_Exit también está haciendo algo que interrumpe la llamada de lectura, que por alguna razón no funciona en mi sistema.

¿Algunas ideas?

No hay solución correcta

Licenciado bajo: CC-BY-SA con atribución
No afiliado a StackOverflow
scroll top