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