Lines Matching defs:queue
50 static void fuse_uring_flush_bg(struct fuse_ring_queue *queue) in fuse_uring_flush_bg()
81 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_req_end() local
105 static void fuse_uring_abort_end_queue_requests(struct fuse_ring_queue *queue) in fuse_uring_abort_end_queue_requests()
123 struct fuse_ring_queue *queue; in fuse_uring_abort_end_requests() local
152 struct fuse_ring_queue *queue = ring->queues[qid]; in fuse_uring_destruct() local
230 struct fuse_ring_queue *queue; in fuse_uring_create_queue() local
289 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_entry_teardown() local
319 struct fuse_ring_queue *queue, in fuse_uring_stop_list_entries()
348 static void fuse_uring_teardown_entries(struct fuse_ring_queue *queue) in fuse_uring_teardown_entries()
365 struct fuse_ring_queue *queue = ring->queues[qid]; in fuse_uring_log_ent_state() local
396 struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]); in fuse_uring_async_stop_queues() local
431 struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]); in fuse_uring_stop_queues() local
460 struct fuse_ring_queue *queue; in fuse_uring_cancel() local
623 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_copy_to_ring() local
679 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send_next_to_ring() local
702 struct fuse_ring_queue *queue) in fuse_uring_ent_avail()
713 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_add_to_pq() local
728 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_add_req_to_ring_ent() local
750 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_ent_assign_req() local
797 struct fuse_ring_queue *queue, in fuse_uring_next_fuse_req()
818 struct fuse_ring_queue *queue = ent->queue; in fuse_ring_ent_set_commit() local
839 struct fuse_ring_queue *queue; in fuse_uring_commit_fetch() local
909 struct fuse_ring_queue *queue; in is_ring_ready() local
938 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_do_register() local
989 struct fuse_ring_queue *queue) in fuse_uring_create_ring_ent()
1041 struct fuse_ring_queue *queue; in fuse_uring_register() local
1153 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send() local
1173 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send_in_task() local
1192 struct fuse_ring_queue *queue; in fuse_uring_task_to_queue() local
1220 struct fuse_ring_queue *queue; in fuse_uring_queue_fuse_req() local
1264 struct fuse_ring_queue *queue; in fuse_uring_queue_bq_req() local
1311 struct fuse_ring_queue *queue = req->ring_queue; in fuse_uring_remove_pending_req() local