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
146 struct fuse_ring_queue *queue; in fuse_uring_request_expired() local
179 struct fuse_ring_queue *queue = ring->queues[qid]; in fuse_uring_destruct() local
256 struct fuse_ring_queue *queue; in fuse_uring_create_queue() local
315 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_entry_teardown() local
345 struct fuse_ring_queue *queue, in fuse_uring_stop_list_entries()
374 static void fuse_uring_teardown_entries(struct fuse_ring_queue *queue) in fuse_uring_teardown_entries()
391 struct fuse_ring_queue *queue = ring->queues[qid]; in fuse_uring_log_ent_state() local
422 struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]); in fuse_uring_async_stop_queues() local
457 struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]); in fuse_uring_stop_queues() local
486 struct fuse_ring_queue *queue; in fuse_uring_cancel() local
649 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_copy_to_ring() local
705 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send_next_to_ring() local
728 struct fuse_ring_queue *queue) in fuse_uring_ent_avail()
739 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_add_to_pq() local
754 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_add_req_to_ring_ent() local
776 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_ent_assign_req() local
823 struct fuse_ring_queue *queue, in fuse_uring_next_fuse_req()
844 struct fuse_ring_queue *queue = ent->queue; in fuse_ring_ent_set_commit() local
865 struct fuse_ring_queue *queue; in fuse_uring_commit_fetch() local
935 struct fuse_ring_queue *queue; in is_ring_ready() local
964 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_do_register() local
1015 struct fuse_ring_queue *queue) in fuse_uring_create_ring_ent()
1067 struct fuse_ring_queue *queue; in fuse_uring_register() local
1179 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send() local
1199 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send_in_task() local
1218 struct fuse_ring_queue *queue; in fuse_uring_task_to_queue() local
1246 struct fuse_ring_queue *queue; in fuse_uring_queue_fuse_req() local
1290 struct fuse_ring_queue *queue; in fuse_uring_queue_bq_req() local
1337 struct fuse_ring_queue *queue = req->ring_queue; in fuse_uring_remove_pending_req() local