Lines Matching refs:cpu_q

202 	struct rnbd_cpu_qlist *cpu_q;  in rnbd_rerun_if_needed()  local
212 for (cpu_q = rnbd_get_cpu_qlist(sess, nxt_cpu(*cpup)); cpu_q; in rnbd_rerun_if_needed()
213 cpu_q = rnbd_get_cpu_qlist(sess, nxt_cpu(cpu_q->cpu))) { in rnbd_rerun_if_needed()
214 if (!spin_trylock_irqsave(&cpu_q->requeue_lock, flags)) in rnbd_rerun_if_needed()
216 if (!test_bit(cpu_q->cpu, sess->cpu_queues_bm)) in rnbd_rerun_if_needed()
218 q = list_first_entry_or_null(&cpu_q->requeue_list, in rnbd_rerun_if_needed()
225 if (list_empty(&cpu_q->requeue_list)) { in rnbd_rerun_if_needed()
228 clear_bit(cpu_q->cpu, sess->cpu_queues_bm); in rnbd_rerun_if_needed()
231 spin_unlock_irqrestore(&cpu_q->requeue_lock, flags); in rnbd_rerun_if_needed()
244 if (cpu_q) in rnbd_rerun_if_needed()
245 *cpup = cpu_q->cpu; in rnbd_rerun_if_needed()
724 struct rnbd_cpu_qlist *cpu_q; in rnbd_init_cpu_qlists() local
727 cpu_q = per_cpu_ptr(cpu_queues, cpu); in rnbd_init_cpu_qlists()
729 cpu_q->cpu = cpu; in rnbd_init_cpu_qlists()
730 INIT_LIST_HEAD(&cpu_q->requeue_list); in rnbd_init_cpu_qlists()
731 spin_lock_init(&cpu_q->requeue_lock); in rnbd_init_cpu_qlists()
1055 struct rnbd_cpu_qlist *cpu_q; in rnbd_clt_dev_add_to_requeue() local
1060 cpu_q = get_cpu_ptr(sess->cpu_queues); in rnbd_clt_dev_add_to_requeue()
1061 spin_lock_irqsave(&cpu_q->requeue_lock, flags); in rnbd_clt_dev_add_to_requeue()
1067 need_set = !test_bit(cpu_q->cpu, sess->cpu_queues_bm); in rnbd_clt_dev_add_to_requeue()
1069 set_bit(cpu_q->cpu, sess->cpu_queues_bm); in rnbd_clt_dev_add_to_requeue()
1076 list_add_tail(&q->requeue_list, &cpu_q->requeue_list); in rnbd_clt_dev_add_to_requeue()
1083 clear_bit(cpu_q->cpu, sess->cpu_queues_bm); in rnbd_clt_dev_add_to_requeue()
1089 spin_unlock_irqrestore(&cpu_q->requeue_lock, flags); in rnbd_clt_dev_add_to_requeue()