Lines Matching full:fc
78 void fuse_set_initialized(struct fuse_conn *fc) in fuse_set_initialized() argument
82 fc->initialized = 1; in fuse_set_initialized()
85 static bool fuse_block_alloc(struct fuse_conn *fc, bool for_background) in fuse_block_alloc() argument
87 return !fc->initialized || (for_background && fc->blocked); in fuse_block_alloc()
90 static void fuse_drop_waiting(struct fuse_conn *fc) in fuse_drop_waiting() argument
93 * lockess check of fc->connected is okay, because atomic_dec_and_test() in fuse_drop_waiting()
97 if (atomic_dec_and_test(&fc->num_waiting) && in fuse_drop_waiting()
98 !READ_ONCE(fc->connected)) { in fuse_drop_waiting()
100 wake_up_all(&fc->blocked_waitq); in fuse_drop_waiting()
108 struct fuse_conn *fc = fm->fc; in fuse_get_req() local
111 atomic_inc(&fc->num_waiting); in fuse_get_req()
113 if (fuse_block_alloc(fc, for_background)) { in fuse_get_req()
115 if (wait_event_killable_exclusive(fc->blocked_waitq, in fuse_get_req()
116 !fuse_block_alloc(fc, for_background))) in fuse_get_req()
123 if (!fc->connected) in fuse_get_req()
127 if (fc->conn_error) in fuse_get_req()
134 wake_up(&fc->blocked_waitq); in fuse_get_req()
138 req->in.h.uid = from_kuid(fc->user_ns, current_fsuid()); in fuse_get_req()
139 req->in.h.gid = from_kgid(fc->user_ns, current_fsgid()); in fuse_get_req()
140 req->in.h.pid = pid_nr_ns(task_pid(current), fc->pid_ns); in fuse_get_req()
154 fuse_drop_waiting(fc); in fuse_get_req()
160 struct fuse_conn *fc = req->fm->fc; in fuse_put_request() local
168 spin_lock(&fc->bg_lock); in fuse_put_request()
169 if (!fc->blocked) in fuse_put_request()
170 wake_up(&fc->blocked_waitq); in fuse_put_request()
171 spin_unlock(&fc->bg_lock); in fuse_put_request()
176 fuse_drop_waiting(fc); in fuse_put_request()
236 void fuse_queue_forget(struct fuse_conn *fc, struct fuse_forget_link *forget, in fuse_queue_forget() argument
239 struct fuse_iqueue *fiq = &fc->iq; in fuse_queue_forget()
255 static void flush_bg_queue(struct fuse_conn *fc) in flush_bg_queue() argument
257 struct fuse_iqueue *fiq = &fc->iq; in flush_bg_queue()
259 while (fc->active_background < fc->max_background && in flush_bg_queue()
260 !list_empty(&fc->bg_queue)) { in flush_bg_queue()
263 req = list_first_entry(&fc->bg_queue, struct fuse_req, list); in flush_bg_queue()
265 fc->active_background++; in flush_bg_queue()
283 struct fuse_conn *fc = fm->fc; in fuse_request_end() local
284 struct fuse_iqueue *fiq = &fc->iq; in fuse_request_end()
302 spin_lock(&fc->bg_lock); in fuse_request_end()
304 if (fc->num_background == fc->max_background) { in fuse_request_end()
305 fc->blocked = 0; in fuse_request_end()
306 wake_up(&fc->blocked_waitq); in fuse_request_end()
307 } else if (!fc->blocked) { in fuse_request_end()
311 * fc->blocked with waiters with the wake_up() call in fuse_request_end()
314 if (waitqueue_active(&fc->blocked_waitq)) in fuse_request_end()
315 wake_up(&fc->blocked_waitq); in fuse_request_end()
318 fc->num_background--; in fuse_request_end()
319 fc->active_background--; in fuse_request_end()
320 flush_bg_queue(fc); in fuse_request_end()
321 spin_unlock(&fc->bg_lock); in fuse_request_end()
336 struct fuse_iqueue *fiq = &req->fm->fc->iq; in queue_interrupt()
366 struct fuse_conn *fc = req->fm->fc; in request_wait_answer() local
367 struct fuse_iqueue *fiq = &fc->iq; in request_wait_answer()
370 if (!fc->no_interrupt) { in request_wait_answer()
412 struct fuse_iqueue *fiq = &req->fm->fc->iq; in __fuse_request_send()
432 static void fuse_adjust_compat(struct fuse_conn *fc, struct fuse_args *args) in fuse_adjust_compat() argument
434 if (fc->minor < 4 && args->opcode == FUSE_STATFS) in fuse_adjust_compat()
437 if (fc->minor < 9) { in fuse_adjust_compat()
453 if (fc->minor < 12) { in fuse_adjust_compat()
467 struct fuse_conn *fc = req->fm->fc; in fuse_force_creds() local
469 req->in.h.uid = from_kuid_munged(fc->user_ns, current_fsuid()); in fuse_force_creds()
470 req->in.h.gid = from_kgid_munged(fc->user_ns, current_fsgid()); in fuse_force_creds()
471 req->in.h.pid = pid_nr_ns(task_pid(current), fc->pid_ns); in fuse_force_creds()
487 struct fuse_conn *fc = fm->fc; in fuse_simple_request() local
492 atomic_inc(&fc->num_waiting); in fuse_simple_request()
507 /* Needs to be done after fuse_get_req() so that fc->minor is valid */ in fuse_simple_request()
508 fuse_adjust_compat(fc, args); in fuse_simple_request()
527 struct fuse_conn *fc = fm->fc; in fuse_request_queue_background() local
533 atomic_inc(&fc->num_waiting); in fuse_request_queue_background()
536 spin_lock(&fc->bg_lock); in fuse_request_queue_background()
537 if (likely(fc->connected)) { in fuse_request_queue_background()
538 fc->num_background++; in fuse_request_queue_background()
539 if (fc->num_background == fc->max_background) in fuse_request_queue_background()
540 fc->blocked = 1; in fuse_request_queue_background()
541 list_add_tail(&req->list, &fc->bg_queue); in fuse_request_queue_background()
542 flush_bg_queue(fc); in fuse_request_queue_background()
545 spin_unlock(&fc->bg_lock); in fuse_request_queue_background()
583 struct fuse_iqueue *fiq = &fm->fc->iq; in fuse_simple_notify_reply()
1184 static int fuse_read_forget(struct fuse_conn *fc, struct fuse_iqueue *fiq, in fuse_read_forget() argument
1189 if (fc->minor < 16 || fiq->forget_list_head.next->next == NULL) in fuse_read_forget()
1208 struct fuse_conn *fc = fud->fc; in fuse_dev_do_read() local
1209 struct fuse_iqueue *fiq = &fc->iq; in fuse_dev_do_read()
1231 fc->max_write)) in fuse_dev_do_read()
1250 err = fc->aborted ? -ECONNABORTED : -ENODEV; in fuse_dev_do_read()
1262 return fuse_read_forget(fc, fiq, cs, nbytes); in fuse_dev_do_read()
1306 err = fc->aborted ? -ECONNABORTED : -ENODEV; in fuse_dev_do_read()
1421 static int fuse_notify_poll(struct fuse_conn *fc, unsigned int size, in fuse_notify_poll() argument
1435 return fuse_notify_poll_wakeup(fc, &outarg); in fuse_notify_poll()
1442 static int fuse_notify_inval_inode(struct fuse_conn *fc, unsigned int size, in fuse_notify_inval_inode() argument
1456 down_read(&fc->killsb); in fuse_notify_inval_inode()
1457 err = fuse_reverse_inval_inode(fc, outarg.ino, in fuse_notify_inval_inode()
1459 up_read(&fc->killsb); in fuse_notify_inval_inode()
1467 static int fuse_notify_inval_entry(struct fuse_conn *fc, unsigned int size, in fuse_notify_inval_entry() argument
1503 down_read(&fc->killsb); in fuse_notify_inval_entry()
1504 err = fuse_reverse_inval_entry(fc, outarg.parent, 0, &name, outarg.flags); in fuse_notify_inval_entry()
1505 up_read(&fc->killsb); in fuse_notify_inval_entry()
1515 static int fuse_notify_delete(struct fuse_conn *fc, unsigned int size, in fuse_notify_delete() argument
1551 down_read(&fc->killsb); in fuse_notify_delete()
1552 err = fuse_reverse_inval_entry(fc, outarg.parent, outarg.child, &name, 0); in fuse_notify_delete()
1553 up_read(&fc->killsb); in fuse_notify_delete()
1563 static int fuse_notify_store(struct fuse_conn *fc, unsigned int size, in fuse_notify_store() argument
1591 down_read(&fc->killsb); in fuse_notify_store()
1594 inode = fuse_ilookup(fc, nodeid, NULL); in fuse_notify_store()
1642 up_read(&fc->killsb); in fuse_notify_store()
1674 struct fuse_conn *fc = fm->fc; in fuse_retrieve() local
1683 num = min(outarg->size, fc->max_write); in fuse_retrieve()
1690 num_pages = min(num_pages, fc->max_pages); in fuse_retrieve()
1743 static int fuse_notify_retrieve(struct fuse_conn *fc, unsigned int size, in fuse_notify_retrieve() argument
1762 down_read(&fc->killsb); in fuse_notify_retrieve()
1766 inode = fuse_ilookup(fc, nodeid, &fm); in fuse_notify_retrieve()
1771 up_read(&fc->killsb); in fuse_notify_retrieve()
1780 static int fuse_notify(struct fuse_conn *fc, enum fuse_notify_code code, in fuse_notify() argument
1788 return fuse_notify_poll(fc, size, cs); in fuse_notify()
1791 return fuse_notify_inval_inode(fc, size, cs); in fuse_notify()
1794 return fuse_notify_inval_entry(fc, size, cs); in fuse_notify()
1797 return fuse_notify_store(fc, size, cs); in fuse_notify()
1800 return fuse_notify_retrieve(fc, size, cs); in fuse_notify()
1803 return fuse_notify_delete(fc, size, cs); in fuse_notify()
1856 struct fuse_conn *fc = fud->fc; in fuse_dev_do_write() local
1878 err = fuse_notify(fc, oh.error, nbytes - sizeof(oh), cs); in fuse_dev_do_write()
1906 fc->no_interrupt = 1; in fuse_dev_do_write()
2068 fiq = &fud->fc->iq; in fuse_dev_poll()
2094 static void end_polls(struct fuse_conn *fc) in end_polls() argument
2098 p = rb_first(&fc->polled_files); in end_polls()
2127 void fuse_abort_conn(struct fuse_conn *fc) in fuse_abort_conn() argument
2129 struct fuse_iqueue *fiq = &fc->iq; in fuse_abort_conn()
2131 spin_lock(&fc->lock); in fuse_abort_conn()
2132 if (fc->connected) { in fuse_abort_conn()
2138 /* Background queuing checks fc->connected under bg_lock */ in fuse_abort_conn()
2139 spin_lock(&fc->bg_lock); in fuse_abort_conn()
2140 fc->connected = 0; in fuse_abort_conn()
2141 spin_unlock(&fc->bg_lock); in fuse_abort_conn()
2143 fuse_set_initialized(fc); in fuse_abort_conn()
2144 list_for_each_entry(fud, &fc->devices, entry) { in fuse_abort_conn()
2165 spin_lock(&fc->bg_lock); in fuse_abort_conn()
2166 fc->blocked = 0; in fuse_abort_conn()
2167 fc->max_background = UINT_MAX; in fuse_abort_conn()
2168 flush_bg_queue(fc); in fuse_abort_conn()
2169 spin_unlock(&fc->bg_lock); in fuse_abort_conn()
2181 end_polls(fc); in fuse_abort_conn()
2182 wake_up_all(&fc->blocked_waitq); in fuse_abort_conn()
2183 spin_unlock(&fc->lock); in fuse_abort_conn()
2187 spin_unlock(&fc->lock); in fuse_abort_conn()
2192 void fuse_wait_aborted(struct fuse_conn *fc) in fuse_wait_aborted() argument
2196 wait_event(fc->blocked_waitq, atomic_read(&fc->num_waiting) == 0); in fuse_wait_aborted()
2204 struct fuse_conn *fc = fud->fc; in fuse_dev_release() local
2218 if (atomic_dec_and_test(&fc->dev_count)) { in fuse_dev_release()
2219 WARN_ON(fc->iq.fasync != NULL); in fuse_dev_release()
2220 fuse_abort_conn(fc); in fuse_dev_release()
2236 return fasync_helper(fd, file, on, &fud->fc->iq.fasync); in fuse_dev_fasync()
2239 static int fuse_device_clone(struct fuse_conn *fc, struct file *new) in fuse_device_clone() argument
2246 fud = fuse_dev_alloc_install(fc); in fuse_device_clone()
2251 atomic_inc(&fc->dev_count); in fuse_device_clone()
2283 res = fuse_device_clone(fud->fc, file); in fuse_dev_ioctl()