Lines Matching defs:queue
51 static void fuse_uring_flush_bg(struct fuse_ring_queue *queue) in fuse_uring_flush_bg()
82 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_req_end() local
107 static void fuse_uring_abort_end_queue_requests(struct fuse_ring_queue *queue) in fuse_uring_abort_end_queue_requests()
125 struct fuse_ring_queue *queue; in fuse_uring_abort_end_requests() local
163 struct fuse_ring_queue *queue; in fuse_uring_request_expired() local
197 struct fuse_ring_queue *queue = ring->queues[qid]; in fuse_uring_destruct() local
274 struct fuse_ring_queue *queue; in fuse_uring_create_queue() local
333 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_entry_teardown() local
363 struct fuse_ring_queue *queue, in fuse_uring_stop_list_entries()
392 static void fuse_uring_teardown_entries(struct fuse_ring_queue *queue) in fuse_uring_teardown_entries()
409 struct fuse_ring_queue *queue = ring->queues[qid]; in fuse_uring_log_ent_state() local
440 struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]); in fuse_uring_async_stop_queues() local
475 struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]); in fuse_uring_stop_queues() local
504 struct fuse_ring_queue *queue; in fuse_uring_cancel() local
670 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_copy_to_ring() local
726 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send_next_to_ring() local
749 struct fuse_ring_queue *queue) in fuse_uring_ent_avail()
760 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_add_to_pq() local
775 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_add_req_to_ring_ent() local
797 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_ent_assign_req() local
844 struct fuse_ring_queue *queue, in fuse_uring_next_fuse_req()
865 struct fuse_ring_queue *queue = ent->queue; in fuse_ring_ent_set_commit() local
887 struct fuse_ring_queue *queue; in fuse_uring_commit_fetch() local
957 struct fuse_ring_queue *queue; in is_ring_ready() local
986 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_do_register() local
1037 struct fuse_ring_queue *queue) in fuse_uring_create_ring_ent()
1090 struct fuse_ring_queue *queue; in fuse_uring_register() local
1202 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send() local
1223 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send_in_task() local
1242 struct fuse_ring_queue *queue; in fuse_uring_task_to_queue() local
1270 struct fuse_ring_queue *queue; in fuse_uring_queue_fuse_req() local
1313 struct fuse_ring_queue *queue; in fuse_uring_queue_bq_req() local
1360 struct fuse_ring_queue *queue = req->ring_queue; in fuse_uring_remove_pending_req() local