1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
/*
FUSE: Filesystem in Userspace
Copyright (C) 2001 Miklos Szeredi (mszeredi@inf.bme.hu)
This program can be distributed under the terms of the GNU GPL.
See the file COPYING.
*/
#include "fuse_i.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <signal.h>
#include <errno.h>
#include <sys/time.h>
#define FUSE_MAX_WORKERS 10
struct fuse_worker {
struct fuse *f;
void *data;
fuse_processor_t proc;
};
static void start_thread(struct fuse_worker *w);
static void *do_work(void *data)
{
struct fuse_worker *w = (struct fuse_worker *) data;
struct fuse *f = w->f;
while(1) {
struct fuse_cmd *cmd = __fuse_read_cmd(w->f);
if(cmd == NULL)
pthread_exit(NULL);
if(f->numavail == 0 && f->numworker < FUSE_MAX_WORKERS) {
pthread_mutex_lock(&f->lock);
f->numavail ++;
f->numworker ++;
pthread_mutex_unlock(&f->lock);
start_thread(w);
}
w->proc(w->f, cmd, w->data);
}
return NULL;
}
static void start_thread(struct fuse_worker *w)
{
pthread_t thrid;
sigset_t oldset;
sigset_t newset;
int res;
/* Disallow signal reception in worker threads */
sigfillset(&newset);
pthread_sigmask(SIG_SETMASK, &newset, &oldset);
res = pthread_create(&thrid, NULL, do_work, w);
pthread_sigmask(SIG_SETMASK, &oldset, NULL);
if(res != 0) {
fprintf(stderr, "Error creating thread: %s\n", strerror(res));
exit(1);
}
pthread_detach(thrid);
}
static struct fuse_context *mt_getcontext(struct fuse *f)
{
struct fuse_context *ctx;
ctx = (struct fuse_context *) pthread_getspecific(f->context_key);
if(ctx == NULL) {
ctx = (struct fuse_context *) malloc(sizeof(struct fuse_context));
pthread_setspecific(f->context_key, ctx);
}
return ctx;
}
static void mt_freecontext(void *data)
{
free(data);
}
void __fuse_loop_mt(struct fuse *f, fuse_processor_t proc, void *data)
{
struct fuse_worker *w;
int res;
w = malloc(sizeof(struct fuse_worker));
w->f = f;
w->data = data;
w->proc = proc;
f->numworker = 1;
res = pthread_key_create(&f->context_key, mt_freecontext);
if(res != 0) {
fprintf(stderr, "Failed to create thread specific key\n");
exit(1);
}
f->getcontext = mt_getcontext;
do_work(w);
}
void fuse_loop_mt(struct fuse *f)
{
__fuse_loop_mt(f, (fuse_processor_t) __fuse_process_cmd, NULL);
}
|
