/*    FUSE: Filesystem in Userspace    Copyright (C) 2001-2006  Miklos Szeredi <miklos@szeredi.hu>    This program can be distributed under the terms of the GNU LGPL.    See the file COPYING.LIB*/#include "fuse_lowlevel.h"#include <stdio.h>#include <stdlib.h>#include <string.h>#include <assert.h>struct fuse_session {    struct fuse_session_ops op;    void *data;    volatile int exited;    struct fuse_chan *ch;};struct fuse_chan {    struct fuse_chan_ops op;    struct fuse_session *se;    int fd;    size_t bufsize;    void *data;};struct fuse_session *fuse_session_new(struct fuse_session_ops *op, void *data){    struct fuse_session *se = (struct fuse_session *) malloc(sizeof(*se));    if (se == NULL) {        fprintf(stderr, "fuse: failed to allocate session\n");        return NULL;    }    memset(se, 0, sizeof(*se));    se->op = *op;    se->data = data;    return se;}void fuse_session_add_chan(struct fuse_session *se, struct fuse_chan *ch){    assert(se->ch == NULL);    assert(ch->se == NULL);    se->ch = ch;    ch->se = se;}struct fuse_chan *fuse_session_next_chan(struct fuse_session *se,                                         struct fuse_chan *ch){    assert(ch == NULL || ch == se->ch);    if (ch == NULL)        return se->ch;    else        return NULL;}void fuse_session_process(struct fuse_session *se, const char *buf, size_t len,                          struct fuse_chan *ch){    se->op.process(se->data, buf, len, ch);}void fuse_session_destroy(struct fuse_session *se){    if (se->op.destroy)        se->op.destroy(se->data);    if (se->ch != NULL)        fuse_chan_destroy(se->ch);    free(se);}void fuse_session_exit(struct fuse_session *se){    if (se->op.exit)        se->op.exit(se->data, 1);    se->exited = 1;}void fuse_session_reset(struct fuse_session *se){    if (se->op.exit)        se->op.exit(se->data, 0);    se->exited = 0;}int fuse_session_exited(struct fuse_session *se){    if (se->op.exited)        return se->op.exited(se->data);    else        return se->exited;}struct fuse_chan *fuse_chan_new(struct fuse_chan_ops *op, int fd,                                size_t bufsize, void *data){    struct fuse_chan *ch = (struct fuse_chan *) malloc(sizeof(*ch));    if (ch == NULL) {        fprintf(stderr, "fuse: failed to allocate channel\n");        return NULL;    }    memset(ch, 0, sizeof(*ch));    ch->op = *op;    ch->fd = fd;    ch->bufsize = bufsize;    ch->data = data;    return ch;}int fuse_chan_fd(struct fuse_chan *ch){    return ch->fd;}size_t fuse_chan_bufsize(struct fuse_chan *ch){    return ch->bufsize;}void *fuse_chan_data(struct fuse_chan *ch){    return ch->data;}struct fuse_session *fuse_chan_session(struct fuse_chan *ch){    return ch->se;}int fuse_chan_receive(struct fuse_chan *ch, char *buf, size_t size){    return ch->op.receive(ch, buf, size);}int fuse_chan_send(struct fuse_chan *ch, const struct iovec iov[], size_t count){    return ch->op.send(ch, iov, count);}void fuse_chan_destroy(struct fuse_chan *ch){    if (ch->op.destroy)        ch->op.destroy(ch);    free(ch);}