Lines Matching refs:waitq

46 	init_waitqueue_head(&req->waitq);  in fuse_request_init()
331 wake_up_locked(&fiq->waitq); in queue_request()
343 spin_lock(&fiq->waitq.lock); in fuse_queue_forget()
347 wake_up_locked(&fiq->waitq); in fuse_queue_forget()
352 spin_unlock(&fiq->waitq.lock); in fuse_queue_forget()
365 spin_lock(&fiq->waitq.lock); in flush_bg_queue()
368 spin_unlock(&fiq->waitq.lock); in flush_bg_queue()
387 spin_lock(&fiq->waitq.lock); in request_end()
389 spin_unlock(&fiq->waitq.lock); in request_end()
412 wake_up(&req->waitq); in request_end()
420 spin_lock(&fiq->waitq.lock); in queue_interrupt()
423 wake_up_locked(&fiq->waitq); in queue_interrupt()
425 spin_unlock(&fiq->waitq.lock); in queue_interrupt()
436 err = wait_event_interruptible(req->waitq, in request_wait_answer()
453 err = wait_event_interruptible(req->waitq, in request_wait_answer()
460 spin_lock(&fiq->waitq.lock); in request_wait_answer()
464 spin_unlock(&fiq->waitq.lock); in request_wait_answer()
469 spin_unlock(&fiq->waitq.lock); in request_wait_answer()
476 wait_event(req->waitq, test_bit(FR_FINISHED, &req->flags)); in request_wait_answer()
484 spin_lock(&fiq->waitq.lock); in __fuse_request_send()
486 spin_unlock(&fiq->waitq.lock); in __fuse_request_send()
494 spin_unlock(&fiq->waitq.lock); in __fuse_request_send()
628 spin_lock(&fiq->waitq.lock); in fuse_request_send_notify_reply()
633 spin_unlock(&fiq->waitq.lock); in fuse_request_send_notify_reply()
668 spin_lock(&req->waitq.lock); in lock_request()
673 spin_unlock(&req->waitq.lock); in lock_request()
686 spin_lock(&req->waitq.lock); in unlock_request()
691 spin_unlock(&req->waitq.lock); in unlock_request()
906 spin_lock(&cs->req->waitq.lock); in fuse_try_move_page()
911 spin_unlock(&cs->req->waitq.lock); in fuse_try_move_page()
1083 __releases(fiq->waitq.lock) in fuse_read_interrupt()
1099 spin_unlock(&fiq->waitq.lock); in fuse_read_interrupt()
1136 __releases(fiq->waitq.lock) in fuse_read_single_forget()
1150 spin_unlock(&fiq->waitq.lock); in fuse_read_single_forget()
1168 __releases(fiq->waitq.lock) in fuse_read_batch_forget()
1182 spin_unlock(&fiq->waitq.lock); in fuse_read_batch_forget()
1188 spin_unlock(&fiq->waitq.lock); in fuse_read_batch_forget()
1218 __releases(fiq->waitq.lock) in fuse_read_forget()
1247 spin_lock(&fiq->waitq.lock); in fuse_dev_do_read()
1253 err = wait_event_interruptible_exclusive_locked(fiq->waitq, in fuse_dev_do_read()
1279 spin_unlock(&fiq->waitq.lock); in fuse_dev_do_read()
1333 spin_unlock(&fiq->waitq.lock); in fuse_dev_do_read()
2063 poll_wait(file, &fiq->waitq, wait); in fuse_dev_poll()
2065 spin_lock(&fiq->waitq.lock); in fuse_dev_poll()
2070 spin_unlock(&fiq->waitq.lock); in fuse_dev_poll()
2147 spin_lock(&req->waitq.lock); in fuse_abort_conn()
2153 spin_unlock(&req->waitq.lock); in fuse_abort_conn()
2161 spin_lock(&fiq->waitq.lock); in fuse_abort_conn()
2166 wake_up_all_locked(&fiq->waitq); in fuse_abort_conn()
2167 spin_unlock(&fiq->waitq.lock); in fuse_abort_conn()