124 	int qid;  in fuse_uring_abort_end_requests()  local
128 	for (qid = 0; qid < ring->nr_queues; qid++) {  in fuse_uring_abort_end_requests()
129 		queue = READ_ONCE(ring->queues[qid]);  in fuse_uring_abort_end_requests()
164 	int qid;  in fuse_uring_request_expired()  local
169 	for (qid = 0; qid < ring->nr_queues; qid++) {  in fuse_uring_request_expired()
170 		queue = READ_ONCE(ring->queues[qid]);  in fuse_uring_request_expired()
191 	int qid;  in fuse_uring_destruct()  local
196 	for (qid = 0; qid < ring->nr_queues; qid++) {  in fuse_uring_destruct()
197 		struct fuse_ring_queue *queue = ring->queues[qid];  in fuse_uring_destruct()
216 		ring->queues[qid] = NULL;  in fuse_uring_destruct()
271 						       int qid)  in fuse_uring_create_queue()  argument
286 	queue->qid = qid;  in fuse_uring_create_queue()
302 	if (ring->queues[qid]) {  in fuse_uring_create_queue()
306 		return ring->queues[qid];  in fuse_uring_create_queue()
312 	WRITE_ONCE(ring->queues[qid], queue);  in fuse_uring_create_queue()
375 				queue->qid, ent->state, exp_state);  in fuse_uring_stop_list_entries()
405 	int qid;  in fuse_uring_log_ent_state()  local
408 	for (qid = 0; qid < ring->nr_queues; qid++) {  in fuse_uring_log_ent_state()
409 		struct fuse_ring_queue *queue = ring->queues[qid];  in fuse_uring_log_ent_state()
421 				ring, qid, ent, ent->state);  in fuse_uring_log_ent_state()
425 				ring, qid, ent, ent->state);  in fuse_uring_log_ent_state()
434 	int qid;  in fuse_uring_async_stop_queues()  local
439 	for (qid = 0; qid < ring->nr_queues; qid++) {  in fuse_uring_async_stop_queues()
440 		struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]);  in fuse_uring_async_stop_queues()
472 	int qid;  in fuse_uring_stop_queues()  local
474 	for (qid = 0; qid < ring->nr_queues; qid++) {  in fuse_uring_stop_queues()
475 		struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]);  in fuse_uring_stop_queues()
677 		       queue->qid, ent, ent->state);  in fuse_uring_copy_to_ring()
781 		pr_warn("%s qid=%d state=%d\n", __func__, ent->queue->qid,  in fuse_uring_add_req_to_ring_ent()
888 	unsigned int qid = READ_ONCE(cmd_req->qid);  in fuse_uring_commit_fetch()  local
896 	if (qid >= ring->nr_queues)  in fuse_uring_commit_fetch()
899 	queue = ring->queues[qid];  in fuse_uring_commit_fetch()
916 		pr_info("qid=%d commit_id %llu not found\n", queue->qid,  in fuse_uring_commit_fetch()
928 				    queue->qid, commit_id, ent->state);  in fuse_uring_commit_fetch()
955 	int qid;  in is_ring_ready()  local
959 	for (qid = 0; qid < ring->nr_queues && ready; qid++) {  in is_ring_ready()
960 		if (current_qid == qid)  in is_ring_ready()
963 		queue = ring->queues[qid];  in is_ring_ready()
998 		bool ready = is_ring_ready(ring, queue->qid);  in fuse_uring_do_register()
1091 	unsigned int qid = READ_ONCE(cmd_req->qid);  in fuse_uring_register()  local
1100 	if (qid >= ring->nr_queues) {  in fuse_uring_register()
1101 		pr_info_ratelimited("fuse: Invalid ring qid %u\n", qid);  in fuse_uring_register()
1105 	queue = ring->queues[qid];  in fuse_uring_register()
1107 		queue = fuse_uring_create_queue(ring, qid);  in fuse_uring_register()
1239 	unsigned int qid;  in fuse_uring_task_to_queue()  local
1242 	qid = task_cpu(current);  in fuse_uring_task_to_queue()
1244 	if (WARN_ONCE(qid >= ring->nr_queues,  in fuse_uring_task_to_queue()
1245 		      "Core number (%u) exceeds nr queues (%zu)\n", qid,  in fuse_uring_task_to_queue()
1247 		qid = 0;  in fuse_uring_task_to_queue()
1249 	queue = ring->queues[qid];  in fuse_uring_task_to_queue()
1250 	WARN_ONCE(!queue, "Missing queue for qid %d\n", qid);  in fuse_uring_task_to_queue()