cleanup

1 files changed, 154 insertions, 0 deletions

diff --git a/lib/fuse_session.c b/lib/fuse_session.c
new file mode 100644
index 0000000..a467b2f
--- /dev/null
+++ b/lib/fuse_session.c
@@ -0,0 +1,154 @@
+/*
+    FUSE: Filesystem in Userspace
+    Copyright (C) 2001-2005  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)
+{
+    se->exited = 1;
+}
+
+void fuse_session_reset(struct fuse_session *se)
+{
+    se->exited = 0;
+}
+
+int fuse_session_exited(struct fuse_session *se)
+{
+    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);
+}