12 #include "fuse_lowlevel.h"
13 #include "fuse_misc.h"
14 #include "fuse_kernel.h"
22 #include <semaphore.h>
25 #include <sys/ioctl.h>
30 #define ENVNAME_THREAD_STACK "FUSE_THREAD_STACK"
32 #define FUSE_LOOP_MT_V2_IDENTIFIER INT_MAX - 2
33 #define FUSE_LOOP_MT_DEF_CLONE_FD 0
34 #define FUSE_LOOP_MT_DEF_MAX_THREADS 10
35 #define FUSE_LOOP_MT_DEF_IDLE_THREADS -1
39 struct fuse_worker *prev;
40 struct fuse_worker *next;
54 struct fuse_session *se;
55 struct fuse_worker main;
64 static struct fuse_chan *fuse_chan_new(
int fd)
66 struct fuse_chan *ch = (
struct fuse_chan *) malloc(
sizeof(*ch));
68 fuse_log(FUSE_LOG_ERR,
"fuse: failed to allocate channel\n");
72 memset(ch, 0,
sizeof(*ch));
75 pthread_mutex_init(&ch->lock, NULL);
80 struct fuse_chan *fuse_chan_get(
struct fuse_chan *ch)
83 pthread_mutex_lock(&ch->lock);
85 pthread_mutex_unlock(&ch->lock);
90 void fuse_chan_put(
struct fuse_chan *ch)
94 pthread_mutex_lock(&ch->lock);
97 pthread_mutex_unlock(&ch->lock);
99 pthread_mutex_destroy(&ch->lock);
102 pthread_mutex_unlock(&ch->lock);
105 static void list_add_worker(
struct fuse_worker *w,
struct fuse_worker *next)
107 struct fuse_worker *prev = next->prev;
114 static void list_del_worker(
struct fuse_worker *w)
116 struct fuse_worker *prev = w->prev;
117 struct fuse_worker *next = w->next;
122 static int fuse_loop_start_thread(
struct fuse_mt *mt);
124 static void *fuse_do_work(
void *data)
126 struct fuse_worker *w = (
struct fuse_worker *) data;
127 struct fuse_mt *mt = w->mt;
133 pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
134 res = fuse_session_receive_buf_int(mt->se, &w->fbuf, w->ch);
135 pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);
146 pthread_mutex_lock(&mt->lock);
148 pthread_mutex_unlock(&mt->lock);
157 struct fuse_in_header *in = w->fbuf.mem;
159 if (in->opcode == FUSE_FORGET ||
160 in->opcode == FUSE_BATCH_FORGET)
166 if (mt->numavail == 0 && mt->numworker < mt->max_threads)
167 fuse_loop_start_thread(mt);
168 pthread_mutex_unlock(&mt->lock);
170 fuse_session_process_buf_int(mt->se, &w->fbuf, w->ch);
172 pthread_mutex_lock(&mt->lock);
182 if (mt->max_idle != -1 && mt->numavail > mt->max_idle) {
184 pthread_mutex_unlock(&mt->lock);
190 pthread_mutex_unlock(&mt->lock);
192 pthread_detach(w->thread_id);
194 fuse_chan_put(w->ch);
198 pthread_mutex_unlock(&mt->lock);
201 sem_post(&mt->finish);
206 int fuse_start_thread(pthread_t *thread_id,
void *(*func)(
void *),
void *arg)
218 pthread_attr_init(&attr);
219 stack_size = getenv(ENVNAME_THREAD_STACK);
220 if (stack_size && pthread_attr_setstacksize(&attr, atoi(stack_size)))
221 fuse_log(FUSE_LOG_ERR,
"fuse: invalid stack size: %s\n", stack_size);
224 sigemptyset(&newset);
225 sigaddset(&newset, SIGTERM);
226 sigaddset(&newset, SIGINT);
227 sigaddset(&newset, SIGHUP);
228 sigaddset(&newset, SIGQUIT);
229 pthread_sigmask(SIG_BLOCK, &newset, &oldset);
230 res = pthread_create(thread_id, &attr, func, arg);
231 pthread_sigmask(SIG_SETMASK, &oldset, NULL);
232 pthread_attr_destroy(&attr);
234 fuse_log(FUSE_LOG_ERR,
"fuse: error creating thread: %s\n",
242 static struct fuse_chan *fuse_clone_chan(
struct fuse_mt *mt)
247 struct fuse_chan *newch;
248 const char *devname =
"/dev/fuse";
253 clonefd = open(devname, O_RDWR | O_CLOEXEC);
255 fuse_log(FUSE_LOG_ERR,
"fuse: failed to open %s: %s\n", devname,
259 fcntl(clonefd, F_SETFD, FD_CLOEXEC);
261 masterfd = mt->se->fd;
262 res = ioctl(clonefd, FUSE_DEV_IOC_CLONE, &masterfd);
264 fuse_log(FUSE_LOG_ERR,
"fuse: failed to clone device fd: %s\n",
269 newch = fuse_chan_new(clonefd);
276 static int fuse_loop_start_thread(
struct fuse_mt *mt)
280 struct fuse_worker *w = malloc(
sizeof(
struct fuse_worker));
282 fuse_log(FUSE_LOG_ERR,
"fuse: failed to allocate worker structure\n");
285 memset(w, 0,
sizeof(
struct fuse_worker));
291 w->ch = fuse_clone_chan(mt);
294 fuse_log(FUSE_LOG_ERR,
"fuse: trying to continue "
295 "without -o clone_fd.\n");
300 res = fuse_start_thread(&w->thread_id, fuse_do_work, w);
302 fuse_chan_put(w->ch);
306 list_add_worker(w, &mt->main);
313 static void fuse_join_worker(
struct fuse_mt *mt,
struct fuse_worker *w)
315 pthread_join(w->thread_id, NULL);
316 pthread_mutex_lock(&mt->lock);
318 pthread_mutex_unlock(&mt->lock);
320 fuse_chan_put(w->ch);
324 int fuse_session_loop_mt_312(
struct fuse_session *se,
struct fuse_loop_config *config);
325 FUSE_SYMVER(
"fuse_session_loop_mt_312",
"fuse_session_loop_mt@@FUSE_3.12")
326 int fuse_session_loop_mt_312(struct fuse_session *se, struct
fuse_loop_config *config)
330 struct fuse_worker *w;
331 int created_config = 0;
334 err = fuse_loop_cfg_verify(config);
344 memset(&mt, 0,
sizeof(
struct fuse_mt));
346 mt.clone_fd = config->clone_fd;
350 mt.max_idle = config->max_idle_threads;
351 mt.max_threads = config->max_threads;
352 mt.main.thread_id = pthread_self();
353 mt.main.prev = mt.main.next = &mt.main;
354 sem_init(&mt.finish, 0, 0);
355 pthread_mutex_init(&mt.lock, NULL);
357 pthread_mutex_lock(&mt.lock);
358 err = fuse_loop_start_thread(&mt);
359 pthread_mutex_unlock(&mt.lock);
363 sem_wait(&mt.finish);
365 pthread_mutex_lock(&mt.lock);
366 for (w = mt.main.next; w != &mt.main; w = w->next)
367 pthread_cancel(w->thread_id);
369 pthread_mutex_unlock(&mt.lock);
371 while (mt.main.next != &mt.main)
372 fuse_join_worker(&mt, mt.main.next);
377 pthread_mutex_destroy(&mt.lock);
378 sem_destroy(&mt.finish);
383 if (created_config) {
391 int fuse_session_loop_mt_32(
struct fuse_session *se,
struct fuse_loop_config_v1 *config_v1);
392 FUSE_SYMVER(
"fuse_session_loop_mt_32",
"fuse_session_loop_mt@FUSE_3.2")
393 int fuse_session_loop_mt_32(struct fuse_session *se, struct fuse_loop_config_v1 *config_v1)
398 if (config_v1 != NULL) {
407 err = fuse_session_loop_mt_312(se, config);
415 int fuse_session_loop_mt_31(
struct fuse_session *se,
int clone_fd);
416 FUSE_SYMVER(
"fuse_session_loop_mt_31",
"fuse_session_loop_mt@FUSE_3.0")
417 int fuse_session_loop_mt_31(struct fuse_session *se,
int clone_fd)
422 return fuse_session_loop_mt_312(se, config);
431 config->version_id = FUSE_LOOP_MT_V2_IDENTIFIER;
433 config->
max_threads = FUSE_LOOP_MT_DEF_MAX_THREADS;
434 config->
clone_fd = FUSE_LOOP_MT_DEF_CLONE_FD;
446 if (config->version_id != FUSE_LOOP_MT_V2_IDENTIFIER)
453 struct fuse_loop_config_v1 *v1_conf)
void fuse_log(enum fuse_log_level level, const char *fmt,...)
void fuse_session_exit(struct fuse_session *se)
int fuse_session_exited(struct fuse_session *se)
void fuse_session_reset(struct fuse_session *se)
void fuse_loop_cfg_convert(struct fuse_loop_config *config, struct fuse_loop_config_v1 *v1_conf)
void fuse_loop_cfg_set_idle_threads(struct fuse_loop_config *config, unsigned int value)
struct fuse_loop_config * fuse_loop_cfg_create(void)
void fuse_loop_cfg_set_clone_fd(struct fuse_loop_config *config, unsigned int value)
void fuse_loop_cfg_destroy(struct fuse_loop_config *config)
void fuse_loop_cfg_set_max_threads(struct fuse_loop_config *config, unsigned int value)
unsigned int max_idle_threads