fs/fuse/dev_uring.c

122 	int qid;
126 	for (qid = 0; qid < ring->nr_queues; qid++) {
127 		queue = READ_ONCE(ring->queues[qid]);
162 	int qid;
167 	for (qid = 0; qid < ring->nr_queues; qid++) {
168 		queue = READ_ONCE(ring->queues[qid]);
189 	int qid;
194 	for (qid = 0; qid < ring->nr_queues; qid++) {
195 		struct fuse_ring_queue *queue = ring->queues[qid];
214 		ring->queues[qid] = NULL;
269 						       int qid)
284 	queue->qid = qid;
300 	if (ring->queues[qid]) {
304 		return ring->queues[qid];
310 	WRITE_ONCE(ring->queues[qid], queue);
372 			pr_warn("entry teardown qid=%d state=%d expected=%d",
373 				queue->qid, ent->state, exp_state);
403 	int qid;
406 	for (qid = 0; qid < ring->nr_queues; qid++) {
407 		struct fuse_ring_queue *queue = ring->queues[qid];
418 			pr_info(" ent-req-queue ring=%p qid=%d ent=%p state=%d\n",
419 				ring, qid, ent, ent->state);
422 			pr_info(" ent-commit-queue ring=%p qid=%d ent=%p state=%d\n",
423 				ring, qid, ent, ent->state);
432 	int qid;
437 	for (qid = 0; qid < ring->nr_queues; qid++) {
438 		struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]);
470 	int qid;
472 	for (qid = 0; qid < ring->nr_queues; qid++) {
473 		struct fuse_ring_queue *queue = READ_ONCE(ring->queues[qid]);
671 		pr_err("qid=%d ring-req=%p invalid state %d on send\n",
672 		       queue->qid, ent, ent->state);
776 		pr_warn("%s qid=%d state=%d\n", __func__, ent->queue->qid,
883 	unsigned int qid = READ_ONCE(cmd_req->qid);
891 	if (qid >= ring->nr_queues)
894 	queue = ring->queues[qid];
911 		pr_info("qid=%d commit_id %llu not found\n", queue->qid,
922 		pr_info_ratelimited("qid=%d commit_id %llu state %d",
923 				    queue->qid, commit_id, ent->state);
950 	int qid;
954 	for (qid = 0; qid < ring->nr_queues && ready; qid++) {
955 		if (current_qid == qid)
958 		queue = ring->queues[qid];
993 		bool ready = is_ring_ready(ring, queue->qid);
1086 	unsigned int qid = READ_ONCE(cmd_req->qid);
1095 	if (qid >= ring->nr_queues) {
1096 		pr_info_ratelimited("fuse: Invalid ring qid %u\n", qid);
1100 	queue = ring->queues[qid];
1102 		queue = fuse_uring_create_queue(ring, qid);
1233 	unsigned int qid;
1236 	qid = task_cpu(current);
1238 	if (WARN_ONCE(qid >= ring->nr_queues,
1239 		      "Core number (%u) exceeds nr queues (%zu)\n", qid,
1241 		qid = 0;
1243 	queue = ring->queues[qid];
1244 	WARN_ONCE(!queue, "Missing queue for qid %d\n", qid);