1 files changed, 126 insertions, 0 deletions
diff --git a/lib/fuse_lowlevel_mt.c b/lib/fuse_lowlevel_mt.c
new file mode 100644
index 0000000..a06d42c
--- /dev/null
+++ b/lib/fuse_lowlevel_mt.c
@@ -0,0 +1,126 @@
+/*
+    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_i.h"
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <pthread.h>
+#include <unistd.h>
+#include <signal.h>
+#include <errno.h>
+#include <sys/time.h>
+
+#define FUSE_MAX_WORKERS 10
+
+struct fuse_worker {
+    struct fuse_ll *f;
+    pthread_t threads[FUSE_MAX_WORKERS];
+    void *data;
+    fuse_ll_processor_t proc;
+};
+
+static int start_thread(struct fuse_worker *w, pthread_t *thread_id);
+
+static void *do_work(void *data)
+{
+    struct fuse_worker *w = (struct fuse_worker *) data;
+    struct fuse_ll *f = w->f;
+    int is_mainthread = (f->numworker == 1);
+
+    pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
+    pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
+
+    while (1) {
+        struct fuse_cmd *cmd;
+
+        if (fuse_ll_exited(f))
+            break;
+
+        cmd = fuse_ll_read_cmd(w->f);
+        if (cmd == NULL)
+            continue;
+
+        if (f->numavail == 0 && f->numworker < FUSE_MAX_WORKERS) {
+            pthread_mutex_lock(&f->worker_lock);
+            if (f->numworker < FUSE_MAX_WORKERS) {
+                /* FIXME: threads should be stored in a list instead
+                   of an array */
+                int res;
+                pthread_t *thread_id = &w->threads[f->numworker];
+                f->numavail ++;
+                f->numworker ++;
+                pthread_mutex_unlock(&f->worker_lock);
+                res = start_thread(w, thread_id);
+                if (res == -1) {
+                    pthread_mutex_lock(&f->worker_lock);
+                    f->numavail --;
+                    pthread_mutex_unlock(&f->worker_lock);
+                }
+            } else
+                pthread_mutex_unlock(&f->worker_lock);
+        }
+
+        w->proc(w->f, cmd, w->data);
+    }
+
+    /* Wait for cancellation */
+    if (!is_mainthread)
+        pause();
+
+    return NULL;
+}
+
+static int start_thread(struct fuse_worker *w, pthread_t *thread_id)
+{
+    int res = pthread_create(thread_id, NULL, do_work, w);
+    if (res != 0) {
+        fprintf(stderr, "fuse: error creating thread: %s\n", strerror(res));
+        return -1;
+    }
+
+    pthread_detach(*thread_id);
+    return 0;
+}
+
+int fuse_ll_loop_mt_proc(struct fuse_ll *f, fuse_ll_processor_t proc, void *data)
+{
+    struct fuse_worker *w;
+    int i;
+
+    w = malloc(sizeof(struct fuse_worker));
+    if (w == NULL) {
+        fprintf(stderr, "fuse: failed to allocate worker structure\n");
+        return -1;
+    }
+    memset(w, 0, sizeof(struct fuse_worker));
+    w->f = f;
+    w->data = data;
+    w->proc = proc;
+
+    f->numworker = 1;
+    do_work(w);
+
+    pthread_mutex_lock(&f->worker_lock);
+    for (i = 1; i < f->numworker; i++)
+        pthread_cancel(w->threads[i]);
+    pthread_mutex_unlock(&f->worker_lock);
+    free(w);
+    f->exited = 0;
+    return 0;
+}
+
+int fuse_ll_loop_mt(struct fuse_ll *f)
+{
+    if (f)
+        return fuse_ll_loop_mt_proc(f, (fuse_ll_processor_t) fuse_ll_process_cmd, NULL);
+    else
+        return -1;
+}
+