Lines Matching refs:fuse_ring_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()
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()
161 struct fuse_ring_queue *queue; in fuse_uring_request_expired()
195 struct fuse_ring_queue *queue = ring->queues[qid]; in fuse_uring_destruct()
236 ring->queues = kcalloc(nr_queues, sizeof(struct fuse_ring_queue *), in fuse_uring_create()
268 static struct fuse_ring_queue *fuse_uring_create_queue(struct fuse_ring *ring, in fuse_uring_create_queue()
272 struct fuse_ring_queue *queue; in fuse_uring_create_queue()
331 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_entry_teardown()
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()
438 struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]); in fuse_uring_async_stop_queues()
473 struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]); in fuse_uring_stop_queues()
502 struct fuse_ring_queue *queue; in fuse_uring_cancel()
665 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_copy_to_ring()
721 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send_next_to_ring()
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()
770 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_add_req_to_ring_ent()
792 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_ent_assign_req()
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()
881 struct fuse_ring_queue *queue; in fuse_uring_commit_fetch()
951 struct fuse_ring_queue *queue; in is_ring_ready()
980 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_do_register()
1031 struct fuse_ring_queue *queue) in fuse_uring_create_ring_ent()
1083 struct fuse_ring_queue *queue; in fuse_uring_register()
1195 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send()
1215 struct fuse_ring_queue *queue = ent->queue; in fuse_uring_send_in_task()
1231 static struct fuse_ring_queue *fuse_uring_task_to_queue(struct fuse_ring *ring) in fuse_uring_task_to_queue()
1234 struct fuse_ring_queue *queue; in fuse_uring_task_to_queue()
1262 struct fuse_ring_queue *queue; in fuse_uring_queue_fuse_req()
1306 struct fuse_ring_queue *queue; in fuse_uring_queue_bq_req()
1353 struct fuse_ring_queue *queue = req->ring_queue; in fuse_uring_remove_pending_req()