Searched refs:src_rq (Results 1 – 6 of 6) sorted by relevance
| /linux/kernel/sched/ |
| H A D | ext.c | 1669 struct rq *src_rq, struct rq *dst_rq) in move_remote_task_to_local_dsq() argument
1671 lockdep_assert_rq_held(src_rq); in move_remote_task_to_local_dsq()
1674 deactivate_task(src_rq, p, 0); in move_remote_task_to_local_dsq()
1678 raw_spin_rq_unlock(src_rq); in move_remote_task_to_local_dsq()
1792 struct rq *src_rq) in unlink_dsq_and_lock_src_rq() argument
1803 raw_spin_rq_lock(src_rq); in unlink_dsq_and_lock_src_rq()
1807 !WARN_ON_ONCE(src_rq != task_rq(p)); in unlink_dsq_and_lock_src_rq()
1811 struct scx_dispatch_q *dsq, struct rq *src_rq) in consume_remote_task() argument
1815 if (unlink_dsq_and_lock_src_rq(p, dsq, src_rq)) { in consume_remote_task()
1816 move_remote_task_to_local_dsq(p, 0, src_rq, this_rq); in consume_remote_task()
[all …]
|
| H A D | rt.c | 2245 struct rq *src_rq; in pull_rt_task() local
2273 src_rq = cpu_rq(cpu); in pull_rt_task()
2282 if (src_rq->rt.highest_prio.next >= in pull_rt_task()
2292 double_lock_balance(this_rq, src_rq); in pull_rt_task()
2298 p = pick_highest_pushable_task(src_rq, this_cpu); in pull_rt_task()
2305 WARN_ON(p == src_rq->curr); in pull_rt_task()
2316 if (p->prio < src_rq->donor->prio) in pull_rt_task()
2320 push_task = get_push_task(src_rq); in pull_rt_task()
2322 move_queued_task_locked(src_rq, this_rq, p); in pull_rt_task()
2333 double_unlock_balance(this_rq, src_rq); in pull_rt_task()
[all …]
|
| H A D | deadline.c | 2991 struct rq *src_rq; in pull_dl_task() local
3007 src_rq = cpu_rq(cpu); in pull_dl_task()
3015 src_rq->dl.earliest_dl.next)) in pull_dl_task()
3020 double_lock_balance(this_rq, src_rq); in pull_dl_task()
3026 if (src_rq->dl.dl_nr_running <= 1) in pull_dl_task()
3029 p = pick_earliest_pushable_dl_task(src_rq, this_cpu); in pull_dl_task()
3038 WARN_ON(p == src_rq->curr); in pull_dl_task()
3046 src_rq->donor->dl.deadline)) in pull_dl_task()
3050 push_task = get_push_task(src_rq); in pull_dl_task()
3052 move_queued_task_locked(src_rq, this_rq, p); in pull_dl_task()
[all …]
|
| H A D | fair.c | 9258 struct rq *src_rq; member
9289 lockdep_assert_rq_held(env->src_rq); in task_hot()
9321 delta = rq_clock_task(env->src_rq) - p->se.exec_start; in task_hot()
9352 if (env->src_rq->nr_running > env->src_rq->nr_preferred_running) in migrate_degrades_locality()
9418 lockdep_assert_rq_held(env->src_rq); in can_migrate_task()
9489 if (task_on_cpu(env->src_rq, p) || in can_migrate_task()
9490 task_current_donor(env->src_rq, p)) { in can_migrate_task()
9526 lockdep_assert_rq_held(env->src_rq); in detach_task()
9534 WARN_ON(task_current(env->src_rq, p)); in detach_task()
9535 WARN_ON(task_current_donor(env->src_rq, p)); in detach_task()
[all …]
|
| H A D | core.c | 3300 struct rq *src_rq, *dst_rq; in __migrate_swap_task() local
3303 src_rq = task_rq(p); in __migrate_swap_task()
3306 rq_pin_lock(src_rq, &srf); in __migrate_swap_task()
3309 move_queued_task_locked(src_rq, dst_rq, p); in __migrate_swap_task()
3313 rq_unpin_lock(src_rq, &srf); in __migrate_swap_task()
3333 struct rq *src_rq, *dst_rq; in migrate_swap_stop() local
3338 src_rq = cpu_rq(arg->src_cpu); in migrate_swap_stop()
3342 guard(double_rq_lock)(src_rq, dst_rq); in migrate_swap_stop()
|
| H A D | sched.h | 4002 void move_queued_task_locked(struct rq *src_rq, struct rq *dst_rq, struct task_struct *task) in move_queued_task_locked() argument
4004 lockdep_assert_rq_held(src_rq); in move_queued_task_locked()
4007 deactivate_task(src_rq, task, 0); in move_queued_task_locked()
|