Lines Matching defs:cpu_q
226 struct rnbd_cpu_qlist *cpu_q;
236 for (cpu_q = rnbd_get_cpu_qlist(sess, nxt_cpu(*cpup)); cpu_q;
237 cpu_q = rnbd_get_cpu_qlist(sess, nxt_cpu(cpu_q->cpu))) {
238 if (!spin_trylock_irqsave(&cpu_q->requeue_lock, flags))
240 if (unlikely(!test_bit(cpu_q->cpu, sess->cpu_queues_bm)))
242 q = list_first_entry_or_null(&cpu_q->requeue_list,
249 if (list_empty(&cpu_q->requeue_list)) {
252 clear_bit(cpu_q->cpu, sess->cpu_queues_bm);
255 spin_unlock_irqrestore(&cpu_q->requeue_lock, flags);
268 if (cpu_q)
269 *cpup = cpu_q->cpu;
733 struct rnbd_cpu_qlist *cpu_q;
736 cpu_q = per_cpu_ptr(cpu_queues, cpu);
738 cpu_q->cpu = cpu;
739 INIT_LIST_HEAD(&cpu_q->requeue_list);
740 spin_lock_init(&cpu_q->requeue_lock);
1065 struct rnbd_cpu_qlist *cpu_q;
1070 cpu_q = get_cpu_ptr(sess->cpu_queues);
1071 spin_lock_irqsave(&cpu_q->requeue_lock, flags);
1077 need_set = !test_bit(cpu_q->cpu, sess->cpu_queues_bm);
1079 set_bit(cpu_q->cpu, sess->cpu_queues_bm);
1086 list_add_tail(&q->requeue_list, &cpu_q->requeue_list);
1093 clear_bit(cpu_q->cpu, sess->cpu_queues_bm);
1099 spin_unlock_irqrestore(&cpu_q->requeue_lock, flags);