Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 1 | /* |
| 2 | FUSE: Filesystem in Userspace |
| 3 | Copyright (C) 2001 Miklos Szeredi (mszeredi@inf.bme.hu) |
| 4 | |
| 5 | This program can be distributed under the terms of the GNU GPL. |
| 6 | See the file COPYING. |
| 7 | */ |
| 8 | |
| 9 | #include "fuse.h" |
| 10 | |
| 11 | #include <stdio.h> |
| 12 | #include <stdlib.h> |
| 13 | #include <string.h> |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 14 | #include <pthread.h> |
| 15 | #include <signal.h> |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 16 | |
Miklos Szeredi | f830a7f | 2001-11-16 17:46:45 +0000 | [diff] [blame^] | 17 | struct fuse_thr_data { |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 18 | struct fuse *f; |
Miklos Szeredi | f830a7f | 2001-11-16 17:46:45 +0000 | [diff] [blame^] | 19 | void *data; |
| 20 | fuse_processor_t proc; |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 21 | struct fuse_cmd *cmd; |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 22 | }; |
| 23 | |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 24 | static void *do_work(void *data) |
| 25 | { |
Miklos Szeredi | f830a7f | 2001-11-16 17:46:45 +0000 | [diff] [blame^] | 26 | struct fuse_thr_data *d = (struct fuse_thr_data *) data; |
| 27 | d->proc(d->f, d->cmd, d->data); |
| 28 | free(d); |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 29 | return NULL; |
| 30 | } |
| 31 | |
Miklos Szeredi | f830a7f | 2001-11-16 17:46:45 +0000 | [diff] [blame^] | 32 | static void start_thread(struct fuse_thr_data *d) |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 33 | { |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 34 | pthread_t thrid; |
| 35 | sigset_t oldset; |
| 36 | sigset_t newset; |
| 37 | int res; |
| 38 | |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 39 | /* Disallow signal reception in worker threads */ |
| 40 | sigfillset(&newset); |
Miklos Szeredi | 680a69a | 2001-11-16 13:31:14 +0000 | [diff] [blame] | 41 | pthread_sigmask(SIG_SETMASK, &newset, &oldset); |
Miklos Szeredi | f830a7f | 2001-11-16 17:46:45 +0000 | [diff] [blame^] | 42 | res = pthread_create(&thrid, NULL, do_work, d); |
Miklos Szeredi | 680a69a | 2001-11-16 13:31:14 +0000 | [diff] [blame] | 43 | pthread_sigmask(SIG_SETMASK, &oldset, NULL); |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 44 | if(res != 0) { |
| 45 | fprintf(stderr, "Error creating thread: %s\n", strerror(res)); |
| 46 | exit(1); |
| 47 | } |
Miklos Szeredi | f830a7f | 2001-11-16 17:46:45 +0000 | [diff] [blame^] | 48 | pthread_detach(thrid); |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 49 | } |
| 50 | |
Miklos Szeredi | f830a7f | 2001-11-16 17:46:45 +0000 | [diff] [blame^] | 51 | void __fuse_loop_mt(struct fuse *f, fuse_processor_t proc, void *data) |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 52 | { |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 53 | while(1) { |
Miklos Szeredi | f830a7f | 2001-11-16 17:46:45 +0000 | [diff] [blame^] | 54 | struct fuse_thr_data *d; |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 55 | struct fuse_cmd *cmd = __fuse_read_cmd(f); |
| 56 | if(cmd == NULL) |
| 57 | exit(1); |
| 58 | |
Miklos Szeredi | f830a7f | 2001-11-16 17:46:45 +0000 | [diff] [blame^] | 59 | d = malloc(sizeof(struct fuse_thr_data)); |
| 60 | d->proc = proc; |
| 61 | d->f = f; |
| 62 | d->cmd = cmd; |
| 63 | d->data = data; |
| 64 | |
| 65 | start_thread(d); |
Miklos Szeredi | fff56ab | 2001-11-16 10:12:59 +0000 | [diff] [blame] | 66 | } |
| 67 | } |
Miklos Szeredi | f830a7f | 2001-11-16 17:46:45 +0000 | [diff] [blame^] | 68 | |
| 69 | void fuse_loop_mt(struct fuse *f) |
| 70 | { |
| 71 | __fuse_loop_mt(f, (fuse_processor_t) __fuse_process_cmd, NULL); |
| 72 | } |