122 	int qid;  in fuse_uring_abort_end_requests()  local
126 	for (qid = 0; qid < ring->nr_queues; qid++) {  in fuse_uring_abort_end_requests()
127 		queue = READ_ONCE(ring->queues[qid]);  in fuse_uring_abort_end_requests()
147 	int qid;  in fuse_uring_request_expired()  local
152 	for (qid = 0; qid < ring->nr_queues; qid++) {  in fuse_uring_request_expired()
153 		queue = READ_ONCE(ring->queues[qid]);  in fuse_uring_request_expired()
173 	int qid;  in fuse_uring_destruct()  local
178 	for (qid = 0; qid < ring->nr_queues; qid++) {  in fuse_uring_destruct()
179 		struct fuse_ring_queue *queue = ring->queues[qid];  in fuse_uring_destruct()
198 		ring->queues[qid] = NULL;  in fuse_uring_destruct()
253 						       int qid)  in fuse_uring_create_queue()  argument
268 	queue->qid = qid;  in fuse_uring_create_queue()
284 	if (ring->queues[qid]) {  in fuse_uring_create_queue()
288 		return ring->queues[qid];  in fuse_uring_create_queue()
294 	WRITE_ONCE(ring->queues[qid], queue);  in fuse_uring_create_queue()
357 				queue->qid, ent->state, exp_state);  in fuse_uring_stop_list_entries()
387 	int qid;  in fuse_uring_log_ent_state()  local
390 	for (qid = 0; qid < ring->nr_queues; qid++) {  in fuse_uring_log_ent_state()
391 		struct fuse_ring_queue *queue = ring->queues[qid];  in fuse_uring_log_ent_state()
403 				ring, qid, ent, ent->state);  in fuse_uring_log_ent_state()
407 				ring, qid, ent, ent->state);  in fuse_uring_log_ent_state()
416 	int qid;  in fuse_uring_async_stop_queues()  local
421 	for (qid = 0; qid < ring->nr_queues; qid++) {  in fuse_uring_async_stop_queues()
422 		struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]);  in fuse_uring_async_stop_queues()
454 	int qid;  in fuse_uring_stop_queues()  local
456 	for (qid = 0; qid < ring->nr_queues; qid++) {  in fuse_uring_stop_queues()
457 		struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]);  in fuse_uring_stop_queues()
656 		       queue->qid, ent, ent->state);  in fuse_uring_copy_to_ring()
760 		pr_warn("%s qid=%d state=%d\n", __func__, ent->queue->qid,  in fuse_uring_add_req_to_ring_ent()
867 	unsigned int qid = READ_ONCE(cmd_req->qid);  in fuse_uring_commit_fetch()  local
875 	if (qid >= ring->nr_queues)  in fuse_uring_commit_fetch()
878 	queue = ring->queues[qid];  in fuse_uring_commit_fetch()
895 		pr_info("qid=%d commit_id %llu not found\n", queue->qid,  in fuse_uring_commit_fetch()
907 				    queue->qid, commit_id, ent->state);  in fuse_uring_commit_fetch()
934 	int qid;  in is_ring_ready()  local
938 	for (qid = 0; qid < ring->nr_queues && ready; qid++) {  in is_ring_ready()
939 		if (current_qid == qid)  in is_ring_ready()
942 		queue = ring->queues[qid];  in is_ring_ready()
977 		bool ready = is_ring_ready(ring, queue->qid);  in fuse_uring_do_register()
1070 	unsigned int qid = READ_ONCE(cmd_req->qid);  in fuse_uring_register()  local
1079 	if (qid >= ring->nr_queues) {  in fuse_uring_register()
1080 		pr_info_ratelimited("fuse: Invalid ring qid %u\n", qid);  in fuse_uring_register()
1084 	queue = ring->queues[qid];  in fuse_uring_register()
1086 		queue = fuse_uring_create_queue(ring, qid);  in fuse_uring_register()
1217 	unsigned int qid;  in fuse_uring_task_to_queue()  local
1220 	qid = task_cpu(current);  in fuse_uring_task_to_queue()
1222 	if (WARN_ONCE(qid >= ring->nr_queues,  in fuse_uring_task_to_queue()
1223 		      "Core number (%u) exceeds nr queues (%zu)\n", qid,  in fuse_uring_task_to_queue()
1225 		qid = 0;  in fuse_uring_task_to_queue()
1227 	queue = ring->queues[qid];  in fuse_uring_task_to_queue()
1228 	WARN_ONCE(!queue, "Missing queue for qid %d\n", qid);  in fuse_uring_task_to_queue()