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
161 struct fuse_ring_queue *queue; in fuse_uring_request_expired() local
195 struct fuse_ring_queue *queue = ring->queues[qid]; in fuse_uring_destruct() local
272 struct fuse_ring_queue *queue; in fuse_uring_create_queue() local
331 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_entry_teardown() local
361 struct fuse_ring_queue *queue, in fuse_uring_stop_list_entries()
390 static void fuse_uring_teardown_entries(struct fuse_ring_queue *queue) in fuse_uring_teardown_entries()
407 struct fuse_ring_queue *queue = ring->queues[qid]; in fuse_uring_log_ent_state() local
438 struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]); in fuse_uring_async_stop_queues() local
473 struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]); in fuse_uring_stop_queues() local
502 struct fuse_ring_queue *queue; in fuse_uring_cancel() local
665 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_copy_to_ring() local
721 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send_next_to_ring() local
744 struct fuse_ring_queue *queue) in fuse_uring_ent_avail()
755 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_add_to_pq() local
770 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_add_req_to_ring_ent() local
792 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_ent_assign_req() local
839 struct fuse_ring_queue *queue, in fuse_uring_next_fuse_req()
860 struct fuse_ring_queue *queue = ent->queue; in fuse_ring_ent_set_commit() local
881 struct fuse_ring_queue *queue; in fuse_uring_commit_fetch() local
951 struct fuse_ring_queue *queue; in is_ring_ready() local
980 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_do_register() local
1031 struct fuse_ring_queue *queue) in fuse_uring_create_ring_ent()
1083 struct fuse_ring_queue *queue; in fuse_uring_register() local
1195 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send() local
1215 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send_in_task() local
1234 struct fuse_ring_queue *queue; in fuse_uring_task_to_queue() local
1262 struct fuse_ring_queue *queue; in fuse_uring_queue_fuse_req() local
1306 struct fuse_ring_queue *queue; in fuse_uring_queue_bq_req() local
1353 struct fuse_ring_queue *queue = req->ring_queue; in fuse_uring_remove_pending_req() local