Lines Matching defs:this_rq
1250 rq = this_rq();
2426 static bool consume_remote_task(struct rq *this_rq,
2430 raw_spin_rq_unlock(this_rq);
2433 move_remote_task_to_local_dsq(p, enq_flags, src_rq, this_rq);
2437 raw_spin_rq_lock(this_rq);
2741 dsq = find_dsq_for_dispatch(sch, this_rq(), dsq_id, task_cpu(p));
3338 this_rq()->scx.in_select_cpu = true;
3340 this_rq()->scx.in_select_cpu = false;
7847 static bool kick_one_cpu(s32 cpu, struct rq *this_rq, unsigned long *ksyncs)
7850 struct scx_rq *this_scx = &this_rq->scx;
7864 if ((cpu_online(cpu) || cpu == cpu_of(this_rq)) &&
7892 static void kick_one_cpu_if_idle(s32 cpu, struct rq *this_rq)
7900 (cpu_online(cpu) || cpu == cpu_of(this_rq)))
7908 struct rq *this_rq = this_rq();
7909 struct scx_rq *this_scx = &this_rq->scx;
7922 should_wait |= kick_one_cpu(cpu, this_rq, ksyncs);
7928 kick_one_cpu_if_idle(cpu, this_rq);
7937 raw_spin_rq_lock(this_rq);
7939 resched_curr(this_rq);
7940 raw_spin_rq_unlock(this_rq);
8349 struct rq *this_rq, *src_rq, *locked_rq;
8381 * Can be called from either ops.dispatch() locking this_rq() or any
8388 this_rq = this_rq();
8389 in_balance = this_rq->scx.flags & SCX_RQ_IN_BALANCE;
8392 if (this_rq != src_rq) {
8393 raw_spin_rq_unlock(this_rq);
8410 dst_dsq = find_dsq_for_dispatch(sch, this_rq, dsq_id, task_cpu(p));
8427 if (this_rq != locked_rq) {
8429 raw_spin_rq_lock(this_rq);
8670 struct rq *this_rq = this_rq();
8689 return scx_dispatch_sched(child, this_rq, this_rq->scx.sub_dispatch_prev,
8883 struct rq *this_rq;
8891 this_rq = this_rq();
8898 if (scx_bypassing(sch, cpu_of(this_rq)))
8919 cpumask_set_cpu(cpu, this_rq->scx.cpus_to_kick_if_idle);
8921 cpumask_set_cpu(cpu, this_rq->scx.cpus_to_kick);
8924 cpumask_set_cpu(cpu, this_rq->scx.cpus_to_preempt);
8926 cpumask_set_cpu(cpu, this_rq->scx.cpus_to_wait);
8929 irq_work_queue(&this_rq->scx.kick_cpus_irq_work);
8978 ret = READ_ONCE(this_rq()->scx.local_dsq.nr);
9179 dsq = find_dsq_for_dispatch(sch, this_rq(), dsq_id, smp_processor_id());
9647 rq = this_rq();