inode based API first working version

3 files changed, 172 insertions, 1 deletions

diff --git a/example/.cvsignore b/example/.cvsignore
index 80eb82b..56dabc1 100644
--- a/example/.cvsignore
+++ b/example/.cvsignore
@@ -5,4 +5,5 @@ fusexmp
 fusexmp_fh
 null
 hello
+hello_ll
 .libs
diff --git a/example/Makefile.am b/example/Makefile.am
index be7a674..8d62e9d 100644
--- a/example/Makefile.am
+++ b/example/Makefile.am
@@ -1,6 +1,6 @@
 ## Process this file with automake to produce Makefile.in
 
-noinst_PROGRAMS = fusexmp fusexmp_fh null hello
+noinst_PROGRAMS = fusexmp fusexmp_fh null hello hello_ll
 
 fusexmp_SOURCES = fusexmp.c
 fusexmp_fh_SOURCES = fusexmp_fh.c
diff --git a/example/hello_ll.c b/example/hello_ll.c
new file mode 100644
index 0000000..2739e3a
--- /dev/null
+++ b/example/hello_ll.c
@@ -0,0 +1,170 @@
+/*
+    FUSE: Filesystem in Userspace
+    Copyright (C) 2001-2005  Miklos Szeredi <miklos@szeredi.hu>
+
+    This program can be distributed under the terms of the GNU GPL.
+    See the file COPYING.
+*/
+
+#include <fuse_lowlevel.h>
+#include <fuse.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <errno.h>
+#include <fcntl.h>
+#include <unistd.h>
+#include <assert.h>
+
+static const char *hello_str = "Hello World!\n";
+static const char *hello_name = "hello";
+
+static int hello_stat(fuse_ino_t ino, struct stat *stbuf)
+{
+    stbuf->st_ino = ino;
+    switch (ino) {
+    case 1:
+        stbuf->st_mode = S_IFDIR | 0755;
+        stbuf->st_nlink = 2;
+        break;
+        
+    case 2:
+        stbuf->st_mode = S_IFREG | 0444;
+        stbuf->st_nlink = 1;
+        stbuf->st_size = strlen(hello_str);
+        break;
+        
+    default:
+        return -1;
+    }
+    return 0;
+}
+
+static void hello_ll_getattr(fuse_req_t req, fuse_ino_t ino)
+{
+    struct stat stbuf;
+
+    memset(&stbuf, 0, sizeof(stbuf));
+    if (hello_stat(ino, &stbuf) == -1)
+        fuse_reply_err(req, ENOENT);
+    else
+        fuse_reply_attr(req, &stbuf, 1.0);
+}
+
+static void hello_ll_lookup(fuse_req_t req, fuse_ino_t parent, const char *name)
+{
+    struct fuse_entry_param e;
+
+    if (parent != 1 || strcmp(name, hello_name) != 0)
+        fuse_reply_err(req, ENOENT);
+    else {
+        memset(&e, 0, sizeof(e));
+        e.ino = 2;
+        e.attr_timeout = 1.0;
+        e.entry_timeout = 1.0;
+        hello_stat(e.ino, &e.attr);
+        
+        fuse_reply_entry(req, &e);
+    }
+}
+
+struct dirbuf {
+    char *p;
+    size_t size;
+};
+
+static void dirbuf_add(struct dirbuf *b, const char *name, fuse_ino_t ino)
+{
+    struct stat stbuf;
+    size_t oldsize = b->size;
+    b->size += fuse_dirent_size(strlen(name));
+    b->p = realloc(b->p, b->size);
+    memset(&stbuf, 0, sizeof(stbuf));
+    stbuf.st_ino = ino;
+    fuse_add_dirent(b->p + oldsize, name, &stbuf, b->size);
+}
+
+#define min(x, y) ((x) < (y) ? (x) : (y))
+
+static int reply_buf_limited(fuse_req_t req, const char *buf, size_t bufsize,
+                             off_t off, size_t maxsize)
+{
+        
+    if (off < bufsize)
+        return fuse_reply_buf(req, buf + off, min(bufsize - off, maxsize));
+    else
+        return fuse_reply_buf(req, NULL, 0);
+}
+
+static void hello_ll_readdir(fuse_req_t req, fuse_ino_t ino, size_t size,
+                             off_t off, struct fuse_file_info *fi)
+{
+    (void) fi;
+
+    if (ino != 1)
+        fuse_reply_err(req, ENOTDIR);
+    else {
+        struct dirbuf b;
+    
+        memset(&b, 0, sizeof(b));
+        dirbuf_add(&b, ".", 1);
+        dirbuf_add(&b, "..", 1);
+        dirbuf_add(&b, hello_name, 2);
+        reply_buf_limited(req, b.p, b.size, off, size);
+        free(b.p);
+    }
+}
+
+static void hello_ll_open(fuse_req_t req, fuse_ino_t ino,
+                         struct fuse_file_info *fi)
+{
+    if (ino != 2)
+        fuse_reply_err(req, EISDIR);
+    else if ((fi->flags & 3) != O_RDONLY)
+        fuse_reply_err(req, EACCES);
+    else
+        fuse_reply_open(req, fi);
+}
+
+static void hello_ll_read(fuse_req_t req, fuse_ino_t ino, size_t size,
+                         off_t off, struct fuse_file_info *fi)
+{
+    (void) fi;
+
+    assert(ino == 2);
+    reply_buf_limited(req, hello_str, strlen(hello_str), off, size);
+}
+
+static struct fuse_ll_operations hello_ll_oper = {
+    .lookup     = hello_ll_lookup,
+    .getattr	= hello_ll_getattr,
+    .readdir    = hello_ll_readdir,
+    .open       = hello_ll_open,
+    .read	= hello_ll_read,
+};
+
+int main(int argc, char *argv[])
+{
+    const char *mountpoint;
+    struct fuse_ll *f;
+    int err = -1;
+    int fd;
+
+    if (argc != 2) {
+        fprintf(stderr, "usage: %s mountpoint\n", argv[0]);
+        return 1;
+    }
+    mountpoint = argv[1];
+    fd = fuse_mount(mountpoint, NULL);
+    if (fd != -1) {
+        f = fuse_ll_new(fd, "debug", &hello_ll_oper, sizeof(hello_ll_oper));
+        if (f != NULL) {
+            err = fuse_ll_loop(f);
+            fuse_ll_destroy(f);
+        }
+        close(fd);
+    }
+    fuse_unmount(mountpoint);
+
+    return err ? 1 : 0;
+}