else
break;
} else if (res > 0) {
- res = fuse_session_receive_buf_int(se, &fbuf, NULL);
+ res = fuse_session_receive_buf_internal(se, &fbuf,
+ NULL);
if (res == -EINTR)
continue;
if (res <= 0)
break;
- fuse_session_process_buf_int(se, &fbuf, NULL);
+ fuse_session_process_buf_internal(se, &fbuf, NULL);
} else {
timeout = fuse_clean_cache(f);
curr_time(&now);
fuse_lib_opt_proc) == -1
|| !conf.modules)
return;
-
+
char *module;
char *next;
struct fuse_module *m;
}
}
-
-
static int fuse_init_intr_signal(int signum, int *installed)
{
struct sigaction old_sa;
void fuse_buf_free(struct fuse_buf *buf);
-int fuse_session_receive_buf_int(struct fuse_session *se, struct fuse_buf *buf,
- struct fuse_chan *ch);
-void fuse_session_process_buf_int(struct fuse_session *se,
- const struct fuse_buf *buf, struct fuse_chan *ch);
+int fuse_session_receive_buf_internal(struct fuse_session *se,
+ struct fuse_buf *buf,
+ struct fuse_chan *ch);
+void fuse_session_process_buf_internal(struct fuse_session *se,
+ const struct fuse_buf *buf,
+ struct fuse_chan *ch);
struct fuse *fuse_new_31(struct fuse_args *args, const struct fuse_operations *op,
size_t op_size, void *private_data);
};
while (!fuse_session_exited(se)) {
- res = fuse_session_receive_buf_int(se, &fbuf, NULL);
+ res = fuse_session_receive_buf_internal(se, &fbuf, NULL);
if (res == -EINTR)
continue;
int res;
pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
- res = fuse_session_receive_buf_int(mt->se, &w->fbuf, w->ch);
+ res = fuse_session_receive_buf_internal(mt->se, &w->fbuf,
+ w->ch);
pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);
if (res == -EINTR)
continue;
fuse_loop_start_thread(mt);
pthread_mutex_unlock(&mt->lock);
- fuse_session_process_buf_int(mt->se, &w->fbuf, w->ch);
+ fuse_session_process_buf_internal(mt->se, &w->fbuf, w->ch);
pthread_mutex_lock(&mt->lock);
if (!isforget)
void fuse_session_process_buf(struct fuse_session *se,
const struct fuse_buf *buf)
{
- fuse_session_process_buf_int(se, buf, NULL);
+ fuse_session_process_buf_internal(se, buf, NULL);
}
-void fuse_session_process_buf_int(struct fuse_session *se,
+/* libfuse internal handler */
+void fuse_session_process_buf_internal(struct fuse_session *se,
const struct fuse_buf *buf, struct fuse_chan *ch)
{
const size_t write_header_size = sizeof(struct fuse_in_header) +
}
/* libfuse internal handler */
-int fuse_session_receive_buf_int(struct fuse_session *se, struct fuse_buf *buf,
- struct fuse_chan *ch)
+int fuse_session_receive_buf_internal(struct fuse_session *se,
+ struct fuse_buf *buf,
+ struct fuse_chan *ch)
{
return _fuse_session_receive_buf(se, buf, ch, true);
}