sched/deadline: Don't check CONFIG_SMP in switched_from_dl()
[linux-2.6-block.git] / kernel / sched / sched.h
CommitLineData
029632fb
PZ
1
2#include <linux/sched.h>
cf4aebc2 3#include <linux/sched/sysctl.h>
8bd75c77 4#include <linux/sched/rt.h>
aab03e05 5#include <linux/sched/deadline.h>
029632fb
PZ
6#include <linux/mutex.h>
7#include <linux/spinlock.h>
8#include <linux/stop_machine.h>
9f3660c2 9#include <linux/tick.h>
f809ca9a 10#include <linux/slab.h>
029632fb 11
391e43da 12#include "cpupri.h"
6bfd6d72 13#include "cpudeadline.h"
60fed789 14#include "cpuacct.h"
029632fb 15
45ceebf7 16struct rq;
442bf3aa 17struct cpuidle_state;
45ceebf7 18
da0c1e65
KT
19/* task_struct::on_rq states: */
20#define TASK_ON_RQ_QUEUED 1
cca26e80 21#define TASK_ON_RQ_MIGRATING 2
da0c1e65 22
029632fb
PZ
23extern __read_mostly int scheduler_running;
24
45ceebf7
PG
25extern unsigned long calc_load_update;
26extern atomic_long_t calc_load_tasks;
27
28extern long calc_load_fold_active(struct rq *this_rq);
29extern void update_cpu_load_active(struct rq *this_rq);
30
029632fb
PZ
31/*
32 * Helpers for converting nanosecond timing to jiffy resolution
33 */
34#define NS_TO_JIFFIES(TIME) ((unsigned long)(TIME) / (NSEC_PER_SEC / HZ))
35
cc1f4b1f
LZ
36/*
37 * Increase resolution of nice-level calculations for 64-bit architectures.
38 * The extra resolution improves shares distribution and load balancing of
39 * low-weight task groups (eg. nice +19 on an autogroup), deeper taskgroup
40 * hierarchies, especially on larger systems. This is not a user-visible change
41 * and does not change the user-interface for setting shares/weights.
42 *
43 * We increase resolution only if we have enough bits to allow this increased
44 * resolution (i.e. BITS_PER_LONG > 32). The costs for increasing resolution
45 * when BITS_PER_LONG <= 32 are pretty high and the returns do not justify the
46 * increased costs.
47 */
48#if 0 /* BITS_PER_LONG > 32 -- currently broken: it increases power usage under light load */
49# define SCHED_LOAD_RESOLUTION 10
50# define scale_load(w) ((w) << SCHED_LOAD_RESOLUTION)
51# define scale_load_down(w) ((w) >> SCHED_LOAD_RESOLUTION)
52#else
53# define SCHED_LOAD_RESOLUTION 0
54# define scale_load(w) (w)
55# define scale_load_down(w) (w)
56#endif
57
58#define SCHED_LOAD_SHIFT (10 + SCHED_LOAD_RESOLUTION)
59#define SCHED_LOAD_SCALE (1L << SCHED_LOAD_SHIFT)
60
029632fb
PZ
61#define NICE_0_LOAD SCHED_LOAD_SCALE
62#define NICE_0_SHIFT SCHED_LOAD_SHIFT
63
332ac17e
DF
64/*
65 * Single value that decides SCHED_DEADLINE internal math precision.
66 * 10 -> just above 1us
67 * 9 -> just above 0.5us
68 */
69#define DL_SCALE (10)
70
029632fb
PZ
71/*
72 * These are the 'tuning knobs' of the scheduler:
029632fb 73 */
029632fb
PZ
74
75/*
76 * single value that denotes runtime == period, ie unlimited time.
77 */
78#define RUNTIME_INF ((u64)~0ULL)
79
d50dde5a
DF
80static inline int fair_policy(int policy)
81{
82 return policy == SCHED_NORMAL || policy == SCHED_BATCH;
83}
84
029632fb
PZ
85static inline int rt_policy(int policy)
86{
d50dde5a 87 return policy == SCHED_FIFO || policy == SCHED_RR;
029632fb
PZ
88}
89
aab03e05
DF
90static inline int dl_policy(int policy)
91{
92 return policy == SCHED_DEADLINE;
93}
94
029632fb
PZ
95static inline int task_has_rt_policy(struct task_struct *p)
96{
97 return rt_policy(p->policy);
98}
99
aab03e05
DF
100static inline int task_has_dl_policy(struct task_struct *p)
101{
102 return dl_policy(p->policy);
103}
104
332ac17e 105static inline bool dl_time_before(u64 a, u64 b)
2d3d891d
DF
106{
107 return (s64)(a - b) < 0;
108}
109
110/*
111 * Tells if entity @a should preempt entity @b.
112 */
332ac17e
DF
113static inline bool
114dl_entity_preempt(struct sched_dl_entity *a, struct sched_dl_entity *b)
2d3d891d
DF
115{
116 return dl_time_before(a->deadline, b->deadline);
117}
118
029632fb
PZ
119/*
120 * This is the priority-queue data structure of the RT scheduling class:
121 */
122struct rt_prio_array {
123 DECLARE_BITMAP(bitmap, MAX_RT_PRIO+1); /* include 1 bit for delimiter */
124 struct list_head queue[MAX_RT_PRIO];
125};
126
127struct rt_bandwidth {
128 /* nests inside the rq lock: */
129 raw_spinlock_t rt_runtime_lock;
130 ktime_t rt_period;
131 u64 rt_runtime;
132 struct hrtimer rt_period_timer;
133};
a5e7be3b
JL
134
135void __dl_clear_params(struct task_struct *p);
136
332ac17e
DF
137/*
138 * To keep the bandwidth of -deadline tasks and groups under control
139 * we need some place where:
140 * - store the maximum -deadline bandwidth of the system (the group);
141 * - cache the fraction of that bandwidth that is currently allocated.
142 *
143 * This is all done in the data structure below. It is similar to the
144 * one used for RT-throttling (rt_bandwidth), with the main difference
145 * that, since here we are only interested in admission control, we
146 * do not decrease any runtime while the group "executes", neither we
147 * need a timer to replenish it.
148 *
149 * With respect to SMP, the bandwidth is given on a per-CPU basis,
150 * meaning that:
151 * - dl_bw (< 100%) is the bandwidth of the system (group) on each CPU;
152 * - dl_total_bw array contains, in the i-eth element, the currently
153 * allocated bandwidth on the i-eth CPU.
154 * Moreover, groups consume bandwidth on each CPU, while tasks only
155 * consume bandwidth on the CPU they're running on.
156 * Finally, dl_total_bw_cpu is used to cache the index of dl_total_bw
157 * that will be shown the next time the proc or cgroup controls will
158 * be red. It on its turn can be changed by writing on its own
159 * control.
160 */
161struct dl_bandwidth {
162 raw_spinlock_t dl_runtime_lock;
163 u64 dl_runtime;
164 u64 dl_period;
165};
166
167static inline int dl_bandwidth_enabled(void)
168{
1724813d 169 return sysctl_sched_rt_runtime >= 0;
332ac17e
DF
170}
171
172extern struct dl_bw *dl_bw_of(int i);
173
174struct dl_bw {
175 raw_spinlock_t lock;
176 u64 bw, total_bw;
177};
178
7f51412a
JL
179static inline
180void __dl_clear(struct dl_bw *dl_b, u64 tsk_bw)
181{
182 dl_b->total_bw -= tsk_bw;
183}
184
185static inline
186void __dl_add(struct dl_bw *dl_b, u64 tsk_bw)
187{
188 dl_b->total_bw += tsk_bw;
189}
190
191static inline
192bool __dl_overflow(struct dl_bw *dl_b, int cpus, u64 old_bw, u64 new_bw)
193{
194 return dl_b->bw != -1 &&
195 dl_b->bw * cpus < dl_b->total_bw - old_bw + new_bw;
196}
197
029632fb
PZ
198extern struct mutex sched_domains_mutex;
199
200#ifdef CONFIG_CGROUP_SCHED
201
202#include <linux/cgroup.h>
203
204struct cfs_rq;
205struct rt_rq;
206
35cf4e50 207extern struct list_head task_groups;
029632fb
PZ
208
209struct cfs_bandwidth {
210#ifdef CONFIG_CFS_BANDWIDTH
211 raw_spinlock_t lock;
212 ktime_t period;
213 u64 quota, runtime;
9c58c79a 214 s64 hierarchical_quota;
029632fb
PZ
215 u64 runtime_expires;
216
217 int idle, timer_active;
218 struct hrtimer period_timer, slack_timer;
219 struct list_head throttled_cfs_rq;
220
221 /* statistics */
222 int nr_periods, nr_throttled;
223 u64 throttled_time;
224#endif
225};
226
227/* task group related information */
228struct task_group {
229 struct cgroup_subsys_state css;
230
231#ifdef CONFIG_FAIR_GROUP_SCHED
232 /* schedulable entities of this group on each cpu */
233 struct sched_entity **se;
234 /* runqueue "owned" by this group on each cpu */
235 struct cfs_rq **cfs_rq;
236 unsigned long shares;
237
fa6bddeb 238#ifdef CONFIG_SMP
bf5b986e 239 atomic_long_t load_avg;
bb17f655 240 atomic_t runnable_avg;
029632fb 241#endif
fa6bddeb 242#endif
029632fb
PZ
243
244#ifdef CONFIG_RT_GROUP_SCHED
245 struct sched_rt_entity **rt_se;
246 struct rt_rq **rt_rq;
247
248 struct rt_bandwidth rt_bandwidth;
249#endif
250
251 struct rcu_head rcu;
252 struct list_head list;
253
254 struct task_group *parent;
255 struct list_head siblings;
256 struct list_head children;
257
258#ifdef CONFIG_SCHED_AUTOGROUP
259 struct autogroup *autogroup;
260#endif
261
262 struct cfs_bandwidth cfs_bandwidth;
263};
264
265#ifdef CONFIG_FAIR_GROUP_SCHED
266#define ROOT_TASK_GROUP_LOAD NICE_0_LOAD
267
268/*
269 * A weight of 0 or 1 can cause arithmetics problems.
270 * A weight of a cfs_rq is the sum of weights of which entities
271 * are queued on this cfs_rq, so a weight of a entity should not be
272 * too large, so as the shares value of a task group.
273 * (The default weight is 1024 - so there's no practical
274 * limitation from this.)
275 */
276#define MIN_SHARES (1UL << 1)
277#define MAX_SHARES (1UL << 18)
278#endif
279
029632fb
PZ
280typedef int (*tg_visitor)(struct task_group *, void *);
281
282extern int walk_tg_tree_from(struct task_group *from,
283 tg_visitor down, tg_visitor up, void *data);
284
285/*
286 * Iterate the full tree, calling @down when first entering a node and @up when
287 * leaving it for the final time.
288 *
289 * Caller must hold rcu_lock or sufficient equivalent.
290 */
291static inline int walk_tg_tree(tg_visitor down, tg_visitor up, void *data)
292{
293 return walk_tg_tree_from(&root_task_group, down, up, data);
294}
295
296extern int tg_nop(struct task_group *tg, void *data);
297
298extern void free_fair_sched_group(struct task_group *tg);
299extern int alloc_fair_sched_group(struct task_group *tg, struct task_group *parent);
300extern void unregister_fair_sched_group(struct task_group *tg, int cpu);
301extern void init_tg_cfs_entry(struct task_group *tg, struct cfs_rq *cfs_rq,
302 struct sched_entity *se, int cpu,
303 struct sched_entity *parent);
304extern void init_cfs_bandwidth(struct cfs_bandwidth *cfs_b);
305extern int sched_group_set_shares(struct task_group *tg, unsigned long shares);
306
307extern void __refill_cfs_bandwidth_runtime(struct cfs_bandwidth *cfs_b);
09dc4ab0 308extern void __start_cfs_bandwidth(struct cfs_bandwidth *cfs_b, bool force);
029632fb
PZ
309extern void unthrottle_cfs_rq(struct cfs_rq *cfs_rq);
310
311extern void free_rt_sched_group(struct task_group *tg);
312extern int alloc_rt_sched_group(struct task_group *tg, struct task_group *parent);
313extern void init_tg_rt_entry(struct task_group *tg, struct rt_rq *rt_rq,
314 struct sched_rt_entity *rt_se, int cpu,
315 struct sched_rt_entity *parent);
316
25cc7da7
LZ
317extern struct task_group *sched_create_group(struct task_group *parent);
318extern void sched_online_group(struct task_group *tg,
319 struct task_group *parent);
320extern void sched_destroy_group(struct task_group *tg);
321extern void sched_offline_group(struct task_group *tg);
322
323extern void sched_move_task(struct task_struct *tsk);
324
325#ifdef CONFIG_FAIR_GROUP_SCHED
326extern int sched_group_set_shares(struct task_group *tg, unsigned long shares);
327#endif
328
029632fb
PZ
329#else /* CONFIG_CGROUP_SCHED */
330
331struct cfs_bandwidth { };
332
333#endif /* CONFIG_CGROUP_SCHED */
334
335/* CFS-related fields in a runqueue */
336struct cfs_rq {
337 struct load_weight load;
c82513e5 338 unsigned int nr_running, h_nr_running;
029632fb
PZ
339
340 u64 exec_clock;
341 u64 min_vruntime;
342#ifndef CONFIG_64BIT
343 u64 min_vruntime_copy;
344#endif
345
346 struct rb_root tasks_timeline;
347 struct rb_node *rb_leftmost;
348
029632fb
PZ
349 /*
350 * 'curr' points to currently running entity on this cfs_rq.
351 * It is set to NULL otherwise (i.e when none are currently running).
352 */
353 struct sched_entity *curr, *next, *last, *skip;
354
355#ifdef CONFIG_SCHED_DEBUG
356 unsigned int nr_spread_over;
357#endif
358
2dac754e
PT
359#ifdef CONFIG_SMP
360 /*
361 * CFS Load tracking
362 * Under CFS, load is tracked on a per-entity basis and aggregated up.
363 * This allows for the description of both thread and group usage (in
364 * the FAIR_GROUP_SCHED case).
365 */
72a4cf20 366 unsigned long runnable_load_avg, blocked_load_avg;
2509940f 367 atomic64_t decay_counter;
9ee474f5 368 u64 last_decay;
2509940f 369 atomic_long_t removed_load;
141965c7 370
c566e8e9 371#ifdef CONFIG_FAIR_GROUP_SCHED
141965c7 372 /* Required to track per-cpu representation of a task_group */
bb17f655 373 u32 tg_runnable_contrib;
bf5b986e 374 unsigned long tg_load_contrib;
82958366
PT
375
376 /*
377 * h_load = weight * f(tg)
378 *
379 * Where f(tg) is the recursive weight fraction assigned to
380 * this group.
381 */
382 unsigned long h_load;
68520796
VD
383 u64 last_h_load_update;
384 struct sched_entity *h_load_next;
385#endif /* CONFIG_FAIR_GROUP_SCHED */
82958366
PT
386#endif /* CONFIG_SMP */
387
029632fb
PZ
388#ifdef CONFIG_FAIR_GROUP_SCHED
389 struct rq *rq; /* cpu runqueue to which this cfs_rq is attached */
390
391 /*
392 * leaf cfs_rqs are those that hold tasks (lowest schedulable entity in
393 * a hierarchy). Non-leaf lrqs hold other higher schedulable entities
394 * (like users, containers etc.)
395 *
396 * leaf_cfs_rq_list ties together list of leaf cfs_rq's in a cpu. This
397 * list is used during load balance.
398 */
399 int on_list;
400 struct list_head leaf_cfs_rq_list;
401 struct task_group *tg; /* group that "owns" this runqueue */
402
029632fb
PZ
403#ifdef CONFIG_CFS_BANDWIDTH
404 int runtime_enabled;
405 u64 runtime_expires;
406 s64 runtime_remaining;
407
f1b17280
PT
408 u64 throttled_clock, throttled_clock_task;
409 u64 throttled_clock_task_time;
029632fb
PZ
410 int throttled, throttle_count;
411 struct list_head throttled_list;
412#endif /* CONFIG_CFS_BANDWIDTH */
413#endif /* CONFIG_FAIR_GROUP_SCHED */
414};
415
416static inline int rt_bandwidth_enabled(void)
417{
418 return sysctl_sched_rt_runtime >= 0;
419}
420
421/* Real-Time classes' related field in a runqueue: */
422struct rt_rq {
423 struct rt_prio_array active;
c82513e5 424 unsigned int rt_nr_running;
029632fb
PZ
425#if defined CONFIG_SMP || defined CONFIG_RT_GROUP_SCHED
426 struct {
427 int curr; /* highest queued rt task prio */
428#ifdef CONFIG_SMP
429 int next; /* next highest */
430#endif
431 } highest_prio;
432#endif
433#ifdef CONFIG_SMP
434 unsigned long rt_nr_migratory;
435 unsigned long rt_nr_total;
436 int overloaded;
437 struct plist_head pushable_tasks;
438#endif
f4ebcbc0
KT
439 int rt_queued;
440
029632fb
PZ
441 int rt_throttled;
442 u64 rt_time;
443 u64 rt_runtime;
444 /* Nests inside the rq lock: */
445 raw_spinlock_t rt_runtime_lock;
446
447#ifdef CONFIG_RT_GROUP_SCHED
448 unsigned long rt_nr_boosted;
449
450 struct rq *rq;
029632fb
PZ
451 struct task_group *tg;
452#endif
453};
454
aab03e05
DF
455/* Deadline class' related fields in a runqueue */
456struct dl_rq {
457 /* runqueue is an rbtree, ordered by deadline */
458 struct rb_root rb_root;
459 struct rb_node *rb_leftmost;
460
461 unsigned long dl_nr_running;
1baca4ce
JL
462
463#ifdef CONFIG_SMP
464 /*
465 * Deadline values of the currently executing and the
466 * earliest ready task on this rq. Caching these facilitates
467 * the decision wether or not a ready but not running task
468 * should migrate somewhere else.
469 */
470 struct {
471 u64 curr;
472 u64 next;
473 } earliest_dl;
474
475 unsigned long dl_nr_migratory;
1baca4ce
JL
476 int overloaded;
477
478 /*
479 * Tasks on this rq that can be pushed away. They are kept in
480 * an rb-tree, ordered by tasks' deadlines, with caching
481 * of the leftmost (earliest deadline) element.
482 */
483 struct rb_root pushable_dl_tasks_root;
484 struct rb_node *pushable_dl_tasks_leftmost;
332ac17e
DF
485#else
486 struct dl_bw dl_bw;
1baca4ce 487#endif
aab03e05
DF
488};
489
029632fb
PZ
490#ifdef CONFIG_SMP
491
492/*
493 * We add the notion of a root-domain which will be used to define per-domain
494 * variables. Each exclusive cpuset essentially defines an island domain by
495 * fully partitioning the member cpus from any other cpuset. Whenever a new
496 * exclusive cpuset is created, we also create and attach a new root-domain
497 * object.
498 *
499 */
500struct root_domain {
501 atomic_t refcount;
502 atomic_t rto_count;
503 struct rcu_head rcu;
504 cpumask_var_t span;
505 cpumask_var_t online;
506
4486edd1
TC
507 /* Indicate more than one runnable task for any CPU */
508 bool overload;
509
1baca4ce
JL
510 /*
511 * The bit corresponding to a CPU gets set here if such CPU has more
512 * than one runnable -deadline task (as it is below for RT tasks).
513 */
514 cpumask_var_t dlo_mask;
515 atomic_t dlo_count;
332ac17e 516 struct dl_bw dl_bw;
6bfd6d72 517 struct cpudl cpudl;
1baca4ce 518
029632fb
PZ
519 /*
520 * The "RT overload" flag: it gets set if a CPU has more than
521 * one runnable RT task.
522 */
523 cpumask_var_t rto_mask;
524 struct cpupri cpupri;
525};
526
527extern struct root_domain def_root_domain;
528
529#endif /* CONFIG_SMP */
530
531/*
532 * This is the main, per-CPU runqueue data structure.
533 *
534 * Locking rule: those places that want to lock multiple runqueues
535 * (such as the load balancing or the thread migration code), lock
536 * acquire operations must be ordered by ascending &runqueue.
537 */
538struct rq {
539 /* runqueue lock: */
540 raw_spinlock_t lock;
541
542 /*
543 * nr_running and cpu_load should be in the same cacheline because
544 * remote CPUs use both these fields when doing load calculation.
545 */
c82513e5 546 unsigned int nr_running;
0ec8aa00
PZ
547#ifdef CONFIG_NUMA_BALANCING
548 unsigned int nr_numa_running;
549 unsigned int nr_preferred_running;
550#endif
029632fb
PZ
551 #define CPU_LOAD_IDX_MAX 5
552 unsigned long cpu_load[CPU_LOAD_IDX_MAX];
553 unsigned long last_load_update_tick;
3451d024 554#ifdef CONFIG_NO_HZ_COMMON
029632fb 555 u64 nohz_stamp;
1c792db7 556 unsigned long nohz_flags;
265f22a9
FW
557#endif
558#ifdef CONFIG_NO_HZ_FULL
559 unsigned long last_sched_tick;
029632fb
PZ
560#endif
561 int skip_clock_update;
562
563 /* capture load from *all* tasks on this cpu: */
564 struct load_weight load;
565 unsigned long nr_load_updates;
566 u64 nr_switches;
567
568 struct cfs_rq cfs;
569 struct rt_rq rt;
aab03e05 570 struct dl_rq dl;
029632fb
PZ
571
572#ifdef CONFIG_FAIR_GROUP_SCHED
573 /* list of leaf cfs_rq on this cpu: */
574 struct list_head leaf_cfs_rq_list;
f5f9739d
DE
575
576 struct sched_avg avg;
a35b6466
PZ
577#endif /* CONFIG_FAIR_GROUP_SCHED */
578
029632fb
PZ
579 /*
580 * This is part of a global counter where only the total sum
581 * over all CPUs matters. A task can increase this counter on
582 * one CPU and if it got migrated afterwards it may decrease
583 * it on another CPU. Always updated under the runqueue lock:
584 */
585 unsigned long nr_uninterruptible;
586
587 struct task_struct *curr, *idle, *stop;
588 unsigned long next_balance;
589 struct mm_struct *prev_mm;
590
591 u64 clock;
592 u64 clock_task;
593
594 atomic_t nr_iowait;
595
596#ifdef CONFIG_SMP
597 struct root_domain *rd;
598 struct sched_domain *sd;
599
ced549fa 600 unsigned long cpu_capacity;
029632fb
PZ
601
602 unsigned char idle_balance;
603 /* For active balancing */
604 int post_schedule;
605 int active_balance;
606 int push_cpu;
607 struct cpu_stop_work active_balance_work;
608 /* cpu of this runqueue: */
609 int cpu;
610 int online;
611
367456c7
PZ
612 struct list_head cfs_tasks;
613
029632fb
PZ
614 u64 rt_avg;
615 u64 age_stamp;
616 u64 idle_stamp;
617 u64 avg_idle;
9bd721c5
JL
618
619 /* This is used to determine avg_idle's max value */
620 u64 max_idle_balance_cost;
029632fb
PZ
621#endif
622
623#ifdef CONFIG_IRQ_TIME_ACCOUNTING
624 u64 prev_irq_time;
625#endif
626#ifdef CONFIG_PARAVIRT
627 u64 prev_steal_time;
628#endif
629#ifdef CONFIG_PARAVIRT_TIME_ACCOUNTING
630 u64 prev_steal_time_rq;
631#endif
632
633 /* calc_load related fields */
634 unsigned long calc_load_update;
635 long calc_load_active;
636
637#ifdef CONFIG_SCHED_HRTICK
638#ifdef CONFIG_SMP
639 int hrtick_csd_pending;
640 struct call_single_data hrtick_csd;
641#endif
642 struct hrtimer hrtick_timer;
643#endif
644
645#ifdef CONFIG_SCHEDSTATS
646 /* latency stats */
647 struct sched_info rq_sched_info;
648 unsigned long long rq_cpu_time;
649 /* could above be rq->cfs_rq.exec_clock + rq->rt_rq.rt_runtime ? */
650
651 /* sys_sched_yield() stats */
652 unsigned int yld_count;
653
654 /* schedule() stats */
029632fb
PZ
655 unsigned int sched_count;
656 unsigned int sched_goidle;
657
658 /* try_to_wake_up() stats */
659 unsigned int ttwu_count;
660 unsigned int ttwu_local;
661#endif
662
663#ifdef CONFIG_SMP
664 struct llist_head wake_list;
665#endif
442bf3aa
DL
666
667#ifdef CONFIG_CPU_IDLE
668 /* Must be inspected within a rcu lock section */
669 struct cpuidle_state *idle_state;
670#endif
029632fb
PZ
671};
672
673static inline int cpu_of(struct rq *rq)
674{
675#ifdef CONFIG_SMP
676 return rq->cpu;
677#else
678 return 0;
679#endif
680}
681
8b06c55b 682DECLARE_PER_CPU_SHARED_ALIGNED(struct rq, runqueues);
029632fb 683
518cd623 684#define cpu_rq(cpu) (&per_cpu(runqueues, (cpu)))
4a32fea9 685#define this_rq() this_cpu_ptr(&runqueues)
518cd623
PZ
686#define task_rq(p) cpu_rq(task_cpu(p))
687#define cpu_curr(cpu) (cpu_rq(cpu)->curr)
4a32fea9 688#define raw_rq() raw_cpu_ptr(&runqueues)
518cd623 689
78becc27
FW
690static inline u64 rq_clock(struct rq *rq)
691{
692 return rq->clock;
693}
694
695static inline u64 rq_clock_task(struct rq *rq)
696{
697 return rq->clock_task;
698}
699
9942f79b 700#ifdef CONFIG_NUMA
e3fe70b1
RR
701enum numa_topology_type {
702 NUMA_DIRECT,
703 NUMA_GLUELESS_MESH,
704 NUMA_BACKPLANE,
705};
706extern enum numa_topology_type sched_numa_topology_type;
9942f79b
RR
707extern int sched_max_numa_distance;
708extern bool find_numa_distance(int distance);
709#endif
710
f809ca9a 711#ifdef CONFIG_NUMA_BALANCING
0ec8aa00 712extern void sched_setnuma(struct task_struct *p, int node);
e6628d5b 713extern int migrate_task_to(struct task_struct *p, int cpu);
ac66f547 714extern int migrate_swap(struct task_struct *, struct task_struct *);
f809ca9a
MG
715#endif /* CONFIG_NUMA_BALANCING */
716
518cd623
PZ
717#ifdef CONFIG_SMP
718
e3baac47
PZ
719extern void sched_ttwu_pending(void);
720
029632fb
PZ
721#define rcu_dereference_check_sched_domain(p) \
722 rcu_dereference_check((p), \
723 lockdep_is_held(&sched_domains_mutex))
724
725/*
726 * The domain tree (rq->sd) is protected by RCU's quiescent state transition.
727 * See detach_destroy_domains: synchronize_sched for details.
728 *
729 * The domain tree of any CPU may only be accessed from within
730 * preempt-disabled sections.
731 */
732#define for_each_domain(cpu, __sd) \
518cd623
PZ
733 for (__sd = rcu_dereference_check_sched_domain(cpu_rq(cpu)->sd); \
734 __sd; __sd = __sd->parent)
029632fb 735
77e81365
SS
736#define for_each_lower_domain(sd) for (; sd; sd = sd->child)
737
518cd623
PZ
738/**
739 * highest_flag_domain - Return highest sched_domain containing flag.
740 * @cpu: The cpu whose highest level of sched domain is to
741 * be returned.
742 * @flag: The flag to check for the highest sched_domain
743 * for the given cpu.
744 *
745 * Returns the highest sched_domain of a cpu which contains the given flag.
746 */
747static inline struct sched_domain *highest_flag_domain(int cpu, int flag)
748{
749 struct sched_domain *sd, *hsd = NULL;
750
751 for_each_domain(cpu, sd) {
752 if (!(sd->flags & flag))
753 break;
754 hsd = sd;
755 }
756
757 return hsd;
758}
759
fb13c7ee
MG
760static inline struct sched_domain *lowest_flag_domain(int cpu, int flag)
761{
762 struct sched_domain *sd;
763
764 for_each_domain(cpu, sd) {
765 if (sd->flags & flag)
766 break;
767 }
768
769 return sd;
770}
771
518cd623 772DECLARE_PER_CPU(struct sched_domain *, sd_llc);
7d9ffa89 773DECLARE_PER_CPU(int, sd_llc_size);
518cd623 774DECLARE_PER_CPU(int, sd_llc_id);
fb13c7ee 775DECLARE_PER_CPU(struct sched_domain *, sd_numa);
37dc6b50
PM
776DECLARE_PER_CPU(struct sched_domain *, sd_busy);
777DECLARE_PER_CPU(struct sched_domain *, sd_asym);
518cd623 778
63b2ca30 779struct sched_group_capacity {
5e6521ea
LZ
780 atomic_t ref;
781 /*
63b2ca30
NP
782 * CPU capacity of this group, SCHED_LOAD_SCALE being max capacity
783 * for a single CPU.
5e6521ea 784 */
63b2ca30 785 unsigned int capacity, capacity_orig;
5e6521ea 786 unsigned long next_update;
63b2ca30 787 int imbalance; /* XXX unrelated to capacity but shared group state */
5e6521ea
LZ
788 /*
789 * Number of busy cpus in this group.
790 */
791 atomic_t nr_busy_cpus;
792
793 unsigned long cpumask[0]; /* iteration mask */
794};
795
796struct sched_group {
797 struct sched_group *next; /* Must be a circular list */
798 atomic_t ref;
799
800 unsigned int group_weight;
63b2ca30 801 struct sched_group_capacity *sgc;
5e6521ea
LZ
802
803 /*
804 * The CPUs this group covers.
805 *
806 * NOTE: this field is variable length. (Allocated dynamically
807 * by attaching extra space to the end of the structure,
808 * depending on how many CPUs the kernel has booted up with)
809 */
810 unsigned long cpumask[0];
811};
812
813static inline struct cpumask *sched_group_cpus(struct sched_group *sg)
814{
815 return to_cpumask(sg->cpumask);
816}
817
818/*
819 * cpumask masking which cpus in the group are allowed to iterate up the domain
820 * tree.
821 */
822static inline struct cpumask *sched_group_mask(struct sched_group *sg)
823{
63b2ca30 824 return to_cpumask(sg->sgc->cpumask);
5e6521ea
LZ
825}
826
827/**
828 * group_first_cpu - Returns the first cpu in the cpumask of a sched_group.
829 * @group: The group whose first cpu is to be returned.
830 */
831static inline unsigned int group_first_cpu(struct sched_group *group)
832{
833 return cpumask_first(sched_group_cpus(group));
834}
835
c1174876
PZ
836extern int group_balance_cpu(struct sched_group *sg);
837
e3baac47
PZ
838#else
839
840static inline void sched_ttwu_pending(void) { }
841
518cd623 842#endif /* CONFIG_SMP */
029632fb 843
391e43da
PZ
844#include "stats.h"
845#include "auto_group.h"
029632fb
PZ
846
847#ifdef CONFIG_CGROUP_SCHED
848
849/*
850 * Return the group to which this tasks belongs.
851 *
8af01f56
TH
852 * We cannot use task_css() and friends because the cgroup subsystem
853 * changes that value before the cgroup_subsys::attach() method is called,
854 * therefore we cannot pin it and might observe the wrong value.
8323f26c
PZ
855 *
856 * The same is true for autogroup's p->signal->autogroup->tg, the autogroup
857 * core changes this before calling sched_move_task().
858 *
859 * Instead we use a 'copy' which is updated from sched_move_task() while
860 * holding both task_struct::pi_lock and rq::lock.
029632fb
PZ
861 */
862static inline struct task_group *task_group(struct task_struct *p)
863{
8323f26c 864 return p->sched_task_group;
029632fb
PZ
865}
866
867/* Change a task's cfs_rq and parent entity if it moves across CPUs/groups */
868static inline void set_task_rq(struct task_struct *p, unsigned int cpu)
869{
870#if defined(CONFIG_FAIR_GROUP_SCHED) || defined(CONFIG_RT_GROUP_SCHED)
871 struct task_group *tg = task_group(p);
872#endif
873
874#ifdef CONFIG_FAIR_GROUP_SCHED
875 p->se.cfs_rq = tg->cfs_rq[cpu];
876 p->se.parent = tg->se[cpu];
877#endif
878
879#ifdef CONFIG_RT_GROUP_SCHED
880 p->rt.rt_rq = tg->rt_rq[cpu];
881 p->rt.parent = tg->rt_se[cpu];
882#endif
883}
884
885#else /* CONFIG_CGROUP_SCHED */
886
887static inline void set_task_rq(struct task_struct *p, unsigned int cpu) { }
888static inline struct task_group *task_group(struct task_struct *p)
889{
890 return NULL;
891}
892
893#endif /* CONFIG_CGROUP_SCHED */
894
895static inline void __set_task_cpu(struct task_struct *p, unsigned int cpu)
896{
897 set_task_rq(p, cpu);
898#ifdef CONFIG_SMP
899 /*
900 * After ->cpu is set up to a new value, task_rq_lock(p, ...) can be
901 * successfuly executed on another CPU. We must ensure that updates of
902 * per-task data have been completed by this moment.
903 */
904 smp_wmb();
905 task_thread_info(p)->cpu = cpu;
ac66f547 906 p->wake_cpu = cpu;
029632fb
PZ
907#endif
908}
909
910/*
911 * Tunables that become constants when CONFIG_SCHED_DEBUG is off:
912 */
913#ifdef CONFIG_SCHED_DEBUG
c5905afb 914# include <linux/static_key.h>
029632fb
PZ
915# define const_debug __read_mostly
916#else
917# define const_debug const
918#endif
919
920extern const_debug unsigned int sysctl_sched_features;
921
922#define SCHED_FEAT(name, enabled) \
923 __SCHED_FEAT_##name ,
924
925enum {
391e43da 926#include "features.h"
f8b6d1cc 927 __SCHED_FEAT_NR,
029632fb
PZ
928};
929
930#undef SCHED_FEAT
931
f8b6d1cc 932#if defined(CONFIG_SCHED_DEBUG) && defined(HAVE_JUMP_LABEL)
f8b6d1cc 933#define SCHED_FEAT(name, enabled) \
c5905afb 934static __always_inline bool static_branch_##name(struct static_key *key) \
f8b6d1cc 935{ \
6e76ea8a 936 return static_key_##enabled(key); \
f8b6d1cc
PZ
937}
938
939#include "features.h"
940
941#undef SCHED_FEAT
942
c5905afb 943extern struct static_key sched_feat_keys[__SCHED_FEAT_NR];
f8b6d1cc
PZ
944#define sched_feat(x) (static_branch_##x(&sched_feat_keys[__SCHED_FEAT_##x]))
945#else /* !(SCHED_DEBUG && HAVE_JUMP_LABEL) */
029632fb 946#define sched_feat(x) (sysctl_sched_features & (1UL << __SCHED_FEAT_##x))
f8b6d1cc 947#endif /* SCHED_DEBUG && HAVE_JUMP_LABEL */
029632fb 948
cbee9f88
PZ
949#ifdef CONFIG_NUMA_BALANCING
950#define sched_feat_numa(x) sched_feat(x)
3105b86a
MG
951#ifdef CONFIG_SCHED_DEBUG
952#define numabalancing_enabled sched_feat_numa(NUMA)
953#else
954extern bool numabalancing_enabled;
955#endif /* CONFIG_SCHED_DEBUG */
cbee9f88
PZ
956#else
957#define sched_feat_numa(x) (0)
3105b86a
MG
958#define numabalancing_enabled (0)
959#endif /* CONFIG_NUMA_BALANCING */
cbee9f88 960
029632fb
PZ
961static inline u64 global_rt_period(void)
962{
963 return (u64)sysctl_sched_rt_period * NSEC_PER_USEC;
964}
965
966static inline u64 global_rt_runtime(void)
967{
968 if (sysctl_sched_rt_runtime < 0)
969 return RUNTIME_INF;
970
971 return (u64)sysctl_sched_rt_runtime * NSEC_PER_USEC;
972}
973
029632fb
PZ
974static inline int task_current(struct rq *rq, struct task_struct *p)
975{
976 return rq->curr == p;
977}
978
979static inline int task_running(struct rq *rq, struct task_struct *p)
980{
981#ifdef CONFIG_SMP
982 return p->on_cpu;
983#else
984 return task_current(rq, p);
985#endif
986}
987
da0c1e65
KT
988static inline int task_on_rq_queued(struct task_struct *p)
989{
990 return p->on_rq == TASK_ON_RQ_QUEUED;
991}
029632fb 992
cca26e80
KT
993static inline int task_on_rq_migrating(struct task_struct *p)
994{
995 return p->on_rq == TASK_ON_RQ_MIGRATING;
996}
997
029632fb
PZ
998#ifndef prepare_arch_switch
999# define prepare_arch_switch(next) do { } while (0)
1000#endif
1001#ifndef finish_arch_switch
1002# define finish_arch_switch(prev) do { } while (0)
1003#endif
01f23e16
CM
1004#ifndef finish_arch_post_lock_switch
1005# define finish_arch_post_lock_switch() do { } while (0)
1006#endif
029632fb 1007
029632fb
PZ
1008static inline void prepare_lock_switch(struct rq *rq, struct task_struct *next)
1009{
1010#ifdef CONFIG_SMP
1011 /*
1012 * We can optimise this out completely for !SMP, because the
1013 * SMP rebalancing from interrupt is the only thing that cares
1014 * here.
1015 */
1016 next->on_cpu = 1;
1017#endif
1018}
1019
1020static inline void finish_lock_switch(struct rq *rq, struct task_struct *prev)
1021{
1022#ifdef CONFIG_SMP
1023 /*
1024 * After ->on_cpu is cleared, the task can be moved to a different CPU.
1025 * We must ensure this doesn't happen until the switch is completely
1026 * finished.
1027 */
1028 smp_wmb();
1029 prev->on_cpu = 0;
1030#endif
1031#ifdef CONFIG_DEBUG_SPINLOCK
1032 /* this is a valid case when another task releases the spinlock */
1033 rq->lock.owner = current;
1034#endif
1035 /*
1036 * If we are tracking spinlock dependencies then we have to
1037 * fix up the runqueue lock - which gets 'carried over' from
1038 * prev into current:
1039 */
1040 spin_acquire(&rq->lock.dep_map, 0, 0, _THIS_IP_);
1041
1042 raw_spin_unlock_irq(&rq->lock);
1043}
1044
b13095f0
LZ
1045/*
1046 * wake flags
1047 */
1048#define WF_SYNC 0x01 /* waker goes to sleep after wakeup */
1049#define WF_FORK 0x02 /* child wakeup after fork */
1050#define WF_MIGRATED 0x4 /* internal use, task got migrated */
1051
029632fb
PZ
1052/*
1053 * To aid in avoiding the subversion of "niceness" due to uneven distribution
1054 * of tasks with abnormal "nice" values across CPUs the contribution that
1055 * each task makes to its run queue's load is weighted according to its
1056 * scheduling class and "nice" value. For SCHED_NORMAL tasks this is just a
1057 * scaled version of the new time slice allocation that they receive on time
1058 * slice expiry etc.
1059 */
1060
1061#define WEIGHT_IDLEPRIO 3
1062#define WMULT_IDLEPRIO 1431655765
1063
1064/*
1065 * Nice levels are multiplicative, with a gentle 10% change for every
1066 * nice level changed. I.e. when a CPU-bound task goes from nice 0 to
1067 * nice 1, it will get ~10% less CPU time than another CPU-bound task
1068 * that remained on nice 0.
1069 *
1070 * The "10% effect" is relative and cumulative: from _any_ nice level,
1071 * if you go up 1 level, it's -10% CPU usage, if you go down 1 level
1072 * it's +10% CPU usage. (to achieve that we use a multiplier of 1.25.
1073 * If a task goes up by ~10% and another task goes down by ~10% then
1074 * the relative distance between them is ~25%.)
1075 */
1076static const int prio_to_weight[40] = {
1077 /* -20 */ 88761, 71755, 56483, 46273, 36291,
1078 /* -15 */ 29154, 23254, 18705, 14949, 11916,
1079 /* -10 */ 9548, 7620, 6100, 4904, 3906,
1080 /* -5 */ 3121, 2501, 1991, 1586, 1277,
1081 /* 0 */ 1024, 820, 655, 526, 423,
1082 /* 5 */ 335, 272, 215, 172, 137,
1083 /* 10 */ 110, 87, 70, 56, 45,
1084 /* 15 */ 36, 29, 23, 18, 15,
1085};
1086
1087/*
1088 * Inverse (2^32/x) values of the prio_to_weight[] array, precalculated.
1089 *
1090 * In cases where the weight does not change often, we can use the
1091 * precalculated inverse to speed up arithmetics by turning divisions
1092 * into multiplications:
1093 */
1094static const u32 prio_to_wmult[40] = {
1095 /* -20 */ 48388, 59856, 76040, 92818, 118348,
1096 /* -15 */ 147320, 184698, 229616, 287308, 360437,
1097 /* -10 */ 449829, 563644, 704093, 875809, 1099582,
1098 /* -5 */ 1376151, 1717300, 2157191, 2708050, 3363326,
1099 /* 0 */ 4194304, 5237765, 6557202, 8165337, 10153587,
1100 /* 5 */ 12820798, 15790321, 19976592, 24970740, 31350126,
1101 /* 10 */ 39045157, 49367440, 61356676, 76695844, 95443717,
1102 /* 15 */ 119304647, 148102320, 186737708, 238609294, 286331153,
1103};
1104
c82ba9fa
LZ
1105#define ENQUEUE_WAKEUP 1
1106#define ENQUEUE_HEAD 2
1107#ifdef CONFIG_SMP
1108#define ENQUEUE_WAKING 4 /* sched_class::task_waking was called */
1109#else
1110#define ENQUEUE_WAKING 0
1111#endif
aab03e05 1112#define ENQUEUE_REPLENISH 8
c82ba9fa
LZ
1113
1114#define DEQUEUE_SLEEP 1
1115
37e117c0
PZ
1116#define RETRY_TASK ((void *)-1UL)
1117
c82ba9fa
LZ
1118struct sched_class {
1119 const struct sched_class *next;
1120
1121 void (*enqueue_task) (struct rq *rq, struct task_struct *p, int flags);
1122 void (*dequeue_task) (struct rq *rq, struct task_struct *p, int flags);
1123 void (*yield_task) (struct rq *rq);
1124 bool (*yield_to_task) (struct rq *rq, struct task_struct *p, bool preempt);
1125
1126 void (*check_preempt_curr) (struct rq *rq, struct task_struct *p, int flags);
1127
606dba2e
PZ
1128 /*
1129 * It is the responsibility of the pick_next_task() method that will
1130 * return the next task to call put_prev_task() on the @prev task or
1131 * something equivalent.
37e117c0
PZ
1132 *
1133 * May return RETRY_TASK when it finds a higher prio class has runnable
1134 * tasks.
606dba2e
PZ
1135 */
1136 struct task_struct * (*pick_next_task) (struct rq *rq,
1137 struct task_struct *prev);
c82ba9fa
LZ
1138 void (*put_prev_task) (struct rq *rq, struct task_struct *p);
1139
1140#ifdef CONFIG_SMP
ac66f547 1141 int (*select_task_rq)(struct task_struct *p, int task_cpu, int sd_flag, int flags);
c82ba9fa
LZ
1142 void (*migrate_task_rq)(struct task_struct *p, int next_cpu);
1143
c82ba9fa
LZ
1144 void (*post_schedule) (struct rq *this_rq);
1145 void (*task_waking) (struct task_struct *task);
1146 void (*task_woken) (struct rq *this_rq, struct task_struct *task);
1147
1148 void (*set_cpus_allowed)(struct task_struct *p,
1149 const struct cpumask *newmask);
1150
1151 void (*rq_online)(struct rq *rq);
1152 void (*rq_offline)(struct rq *rq);
1153#endif
1154
1155 void (*set_curr_task) (struct rq *rq);
1156 void (*task_tick) (struct rq *rq, struct task_struct *p, int queued);
1157 void (*task_fork) (struct task_struct *p);
e6c390f2 1158 void (*task_dead) (struct task_struct *p);
c82ba9fa 1159
67dfa1b7
KT
1160 /*
1161 * The switched_from() call is allowed to drop rq->lock, therefore we
1162 * cannot assume the switched_from/switched_to pair is serliazed by
1163 * rq->lock. They are however serialized by p->pi_lock.
1164 */
c82ba9fa
LZ
1165 void (*switched_from) (struct rq *this_rq, struct task_struct *task);
1166 void (*switched_to) (struct rq *this_rq, struct task_struct *task);
1167 void (*prio_changed) (struct rq *this_rq, struct task_struct *task,
1168 int oldprio);
1169
1170 unsigned int (*get_rr_interval) (struct rq *rq,
1171 struct task_struct *task);
1172
1173#ifdef CONFIG_FAIR_GROUP_SCHED
1174 void (*task_move_group) (struct task_struct *p, int on_rq);
1175#endif
1176};
029632fb 1177
3f1d2a31
PZ
1178static inline void put_prev_task(struct rq *rq, struct task_struct *prev)
1179{
1180 prev->sched_class->put_prev_task(rq, prev);
1181}
1182
029632fb
PZ
1183#define sched_class_highest (&stop_sched_class)
1184#define for_each_class(class) \
1185 for (class = sched_class_highest; class; class = class->next)
1186
1187extern const struct sched_class stop_sched_class;
aab03e05 1188extern const struct sched_class dl_sched_class;
029632fb
PZ
1189extern const struct sched_class rt_sched_class;
1190extern const struct sched_class fair_sched_class;
1191extern const struct sched_class idle_sched_class;
1192
1193
1194#ifdef CONFIG_SMP
1195
63b2ca30 1196extern void update_group_capacity(struct sched_domain *sd, int cpu);
b719203b 1197
7caff66f 1198extern void trigger_load_balance(struct rq *rq);
029632fb 1199
642dbc39
VG
1200extern void idle_enter_fair(struct rq *this_rq);
1201extern void idle_exit_fair(struct rq *this_rq);
642dbc39 1202
dc877341
PZ
1203#else
1204
1205static inline void idle_enter_fair(struct rq *rq) { }
1206static inline void idle_exit_fair(struct rq *rq) { }
1207
029632fb
PZ
1208#endif
1209
442bf3aa
DL
1210#ifdef CONFIG_CPU_IDLE
1211static inline void idle_set_state(struct rq *rq,
1212 struct cpuidle_state *idle_state)
1213{
1214 rq->idle_state = idle_state;
1215}
1216
1217static inline struct cpuidle_state *idle_get_state(struct rq *rq)
1218{
1219 WARN_ON(!rcu_read_lock_held());
1220 return rq->idle_state;
1221}
1222#else
1223static inline void idle_set_state(struct rq *rq,
1224 struct cpuidle_state *idle_state)
1225{
1226}
1227
1228static inline struct cpuidle_state *idle_get_state(struct rq *rq)
1229{
1230 return NULL;
1231}
1232#endif
1233
029632fb
PZ
1234extern void sysrq_sched_debug_show(void);
1235extern void sched_init_granularity(void);
1236extern void update_max_interval(void);
1baca4ce
JL
1237
1238extern void init_sched_dl_class(void);
029632fb
PZ
1239extern void init_sched_rt_class(void);
1240extern void init_sched_fair_class(void);
332ac17e 1241extern void init_sched_dl_class(void);
029632fb 1242
8875125e 1243extern void resched_curr(struct rq *rq);
029632fb
PZ
1244extern void resched_cpu(int cpu);
1245
1246extern struct rt_bandwidth def_rt_bandwidth;
1247extern void init_rt_bandwidth(struct rt_bandwidth *rt_b, u64 period, u64 runtime);
1248
332ac17e
DF
1249extern struct dl_bandwidth def_dl_bandwidth;
1250extern void init_dl_bandwidth(struct dl_bandwidth *dl_b, u64 period, u64 runtime);
aab03e05
DF
1251extern void init_dl_task_timer(struct sched_dl_entity *dl_se);
1252
332ac17e
DF
1253unsigned long to_ratio(u64 period, u64 runtime);
1254
556061b0 1255extern void update_idle_cpu_load(struct rq *this_rq);
029632fb 1256
a75cdaa9
AS
1257extern void init_task_runnable_average(struct task_struct *p);
1258
72465447 1259static inline void add_nr_running(struct rq *rq, unsigned count)
029632fb 1260{
72465447
KT
1261 unsigned prev_nr = rq->nr_running;
1262
1263 rq->nr_running = prev_nr + count;
9f3660c2 1264
72465447 1265 if (prev_nr < 2 && rq->nr_running >= 2) {
4486edd1
TC
1266#ifdef CONFIG_SMP
1267 if (!rq->rd->overload)
1268 rq->rd->overload = true;
1269#endif
1270
1271#ifdef CONFIG_NO_HZ_FULL
9f3660c2 1272 if (tick_nohz_full_cpu(rq->cpu)) {
3882ec64
FW
1273 /*
1274 * Tick is needed if more than one task runs on a CPU.
1275 * Send the target an IPI to kick it out of nohz mode.
1276 *
1277 * We assume that IPI implies full memory barrier and the
1278 * new value of rq->nr_running is visible on reception
1279 * from the target.
1280 */
fd2ac4f4 1281 tick_nohz_full_kick_cpu(rq->cpu);
9f3660c2 1282 }
9f3660c2 1283#endif
4486edd1 1284 }
029632fb
PZ
1285}
1286
72465447 1287static inline void sub_nr_running(struct rq *rq, unsigned count)
029632fb 1288{
72465447 1289 rq->nr_running -= count;
029632fb
PZ
1290}
1291
265f22a9
FW
1292static inline void rq_last_tick_reset(struct rq *rq)
1293{
1294#ifdef CONFIG_NO_HZ_FULL
1295 rq->last_sched_tick = jiffies;
1296#endif
1297}
1298
029632fb
PZ
1299extern void update_rq_clock(struct rq *rq);
1300
1301extern void activate_task(struct rq *rq, struct task_struct *p, int flags);
1302extern void deactivate_task(struct rq *rq, struct task_struct *p, int flags);
1303
1304extern void check_preempt_curr(struct rq *rq, struct task_struct *p, int flags);
1305
1306extern const_debug unsigned int sysctl_sched_time_avg;
1307extern const_debug unsigned int sysctl_sched_nr_migrate;
1308extern const_debug unsigned int sysctl_sched_migration_cost;
1309
1310static inline u64 sched_avg_period(void)
1311{
1312 return (u64)sysctl_sched_time_avg * NSEC_PER_MSEC / 2;
1313}
1314
029632fb
PZ
1315#ifdef CONFIG_SCHED_HRTICK
1316
1317/*
1318 * Use hrtick when:
1319 * - enabled by features
1320 * - hrtimer is actually high res
1321 */
1322static inline int hrtick_enabled(struct rq *rq)
1323{
1324 if (!sched_feat(HRTICK))
1325 return 0;
1326 if (!cpu_active(cpu_of(rq)))
1327 return 0;
1328 return hrtimer_is_hres_active(&rq->hrtick_timer);
1329}
1330
1331void hrtick_start(struct rq *rq, u64 delay);
1332
b39e66ea
MG
1333#else
1334
1335static inline int hrtick_enabled(struct rq *rq)
1336{
1337 return 0;
1338}
1339
029632fb
PZ
1340#endif /* CONFIG_SCHED_HRTICK */
1341
1342#ifdef CONFIG_SMP
1343extern void sched_avg_update(struct rq *rq);
1344static inline void sched_rt_avg_update(struct rq *rq, u64 rt_delta)
1345{
1346 rq->rt_avg += rt_delta;
1347 sched_avg_update(rq);
1348}
1349#else
1350static inline void sched_rt_avg_update(struct rq *rq, u64 rt_delta) { }
1351static inline void sched_avg_update(struct rq *rq) { }
1352#endif
1353
1354extern void start_bandwidth_timer(struct hrtimer *period_timer, ktime_t period);
1355
1356#ifdef CONFIG_SMP
1357#ifdef CONFIG_PREEMPT
1358
1359static inline void double_rq_lock(struct rq *rq1, struct rq *rq2);
1360
1361/*
1362 * fair double_lock_balance: Safely acquires both rq->locks in a fair
1363 * way at the expense of forcing extra atomic operations in all
1364 * invocations. This assures that the double_lock is acquired using the
1365 * same underlying policy as the spinlock_t on this architecture, which
1366 * reduces latency compared to the unfair variant below. However, it
1367 * also adds more overhead and therefore may reduce throughput.
1368 */
1369static inline int _double_lock_balance(struct rq *this_rq, struct rq *busiest)
1370 __releases(this_rq->lock)
1371 __acquires(busiest->lock)
1372 __acquires(this_rq->lock)
1373{
1374 raw_spin_unlock(&this_rq->lock);
1375 double_rq_lock(this_rq, busiest);
1376
1377 return 1;
1378}
1379
1380#else
1381/*
1382 * Unfair double_lock_balance: Optimizes throughput at the expense of
1383 * latency by eliminating extra atomic operations when the locks are
1384 * already in proper order on entry. This favors lower cpu-ids and will
1385 * grant the double lock to lower cpus over higher ids under contention,
1386 * regardless of entry order into the function.
1387 */
1388static inline int _double_lock_balance(struct rq *this_rq, struct rq *busiest)
1389 __releases(this_rq->lock)
1390 __acquires(busiest->lock)
1391 __acquires(this_rq->lock)
1392{
1393 int ret = 0;
1394
1395 if (unlikely(!raw_spin_trylock(&busiest->lock))) {
1396 if (busiest < this_rq) {
1397 raw_spin_unlock(&this_rq->lock);
1398 raw_spin_lock(&busiest->lock);
1399 raw_spin_lock_nested(&this_rq->lock,
1400 SINGLE_DEPTH_NESTING);
1401 ret = 1;
1402 } else
1403 raw_spin_lock_nested(&busiest->lock,
1404 SINGLE_DEPTH_NESTING);
1405 }
1406 return ret;
1407}
1408
1409#endif /* CONFIG_PREEMPT */
1410
1411/*
1412 * double_lock_balance - lock the busiest runqueue, this_rq is locked already.
1413 */
1414static inline int double_lock_balance(struct rq *this_rq, struct rq *busiest)
1415{
1416 if (unlikely(!irqs_disabled())) {
1417 /* printk() doesn't work good under rq->lock */
1418 raw_spin_unlock(&this_rq->lock);
1419 BUG_ON(1);
1420 }
1421
1422 return _double_lock_balance(this_rq, busiest);
1423}
1424
1425static inline void double_unlock_balance(struct rq *this_rq, struct rq *busiest)
1426 __releases(busiest->lock)
1427{
1428 raw_spin_unlock(&busiest->lock);
1429 lock_set_subclass(&this_rq->lock.dep_map, 0, _RET_IP_);
1430}
1431
74602315
PZ
1432static inline void double_lock(spinlock_t *l1, spinlock_t *l2)
1433{
1434 if (l1 > l2)
1435 swap(l1, l2);
1436
1437 spin_lock(l1);
1438 spin_lock_nested(l2, SINGLE_DEPTH_NESTING);
1439}
1440
60e69eed
MG
1441static inline void double_lock_irq(spinlock_t *l1, spinlock_t *l2)
1442{
1443 if (l1 > l2)
1444 swap(l1, l2);
1445
1446 spin_lock_irq(l1);
1447 spin_lock_nested(l2, SINGLE_DEPTH_NESTING);
1448}
1449
74602315
PZ
1450static inline void double_raw_lock(raw_spinlock_t *l1, raw_spinlock_t *l2)
1451{
1452 if (l1 > l2)
1453 swap(l1, l2);
1454
1455 raw_spin_lock(l1);
1456 raw_spin_lock_nested(l2, SINGLE_DEPTH_NESTING);
1457}
1458
029632fb
PZ
1459/*
1460 * double_rq_lock - safely lock two runqueues
1461 *
1462 * Note this does not disable interrupts like task_rq_lock,
1463 * you need to do so manually before calling.
1464 */
1465static inline void double_rq_lock(struct rq *rq1, struct rq *rq2)
1466 __acquires(rq1->lock)
1467 __acquires(rq2->lock)
1468{
1469 BUG_ON(!irqs_disabled());
1470 if (rq1 == rq2) {
1471 raw_spin_lock(&rq1->lock);
1472 __acquire(rq2->lock); /* Fake it out ;) */
1473 } else {
1474 if (rq1 < rq2) {
1475 raw_spin_lock(&rq1->lock);
1476 raw_spin_lock_nested(&rq2->lock, SINGLE_DEPTH_NESTING);
1477 } else {
1478 raw_spin_lock(&rq2->lock);
1479 raw_spin_lock_nested(&rq1->lock, SINGLE_DEPTH_NESTING);
1480 }
1481 }
1482}
1483
1484/*
1485 * double_rq_unlock - safely unlock two runqueues
1486 *
1487 * Note this does not restore interrupts like task_rq_unlock,
1488 * you need to do so manually after calling.
1489 */
1490static inline void double_rq_unlock(struct rq *rq1, struct rq *rq2)
1491 __releases(rq1->lock)
1492 __releases(rq2->lock)
1493{
1494 raw_spin_unlock(&rq1->lock);
1495 if (rq1 != rq2)
1496 raw_spin_unlock(&rq2->lock);
1497 else
1498 __release(rq2->lock);
1499}
1500
1501#else /* CONFIG_SMP */
1502
1503/*
1504 * double_rq_lock - safely lock two runqueues
1505 *
1506 * Note this does not disable interrupts like task_rq_lock,
1507 * you need to do so manually before calling.
1508 */
1509static inline void double_rq_lock(struct rq *rq1, struct rq *rq2)
1510 __acquires(rq1->lock)
1511 __acquires(rq2->lock)
1512{
1513 BUG_ON(!irqs_disabled());
1514 BUG_ON(rq1 != rq2);
1515 raw_spin_lock(&rq1->lock);
1516 __acquire(rq2->lock); /* Fake it out ;) */
1517}
1518
1519/*
1520 * double_rq_unlock - safely unlock two runqueues
1521 *
1522 * Note this does not restore interrupts like task_rq_unlock,
1523 * you need to do so manually after calling.
1524 */
1525static inline void double_rq_unlock(struct rq *rq1, struct rq *rq2)
1526 __releases(rq1->lock)
1527 __releases(rq2->lock)
1528{
1529 BUG_ON(rq1 != rq2);
1530 raw_spin_unlock(&rq1->lock);
1531 __release(rq2->lock);
1532}
1533
1534#endif
1535
1536extern struct sched_entity *__pick_first_entity(struct cfs_rq *cfs_rq);
1537extern struct sched_entity *__pick_last_entity(struct cfs_rq *cfs_rq);
1538extern void print_cfs_stats(struct seq_file *m, int cpu);
1539extern void print_rt_stats(struct seq_file *m, int cpu);
acb32132 1540extern void print_dl_stats(struct seq_file *m, int cpu);
029632fb
PZ
1541
1542extern void init_cfs_rq(struct cfs_rq *cfs_rq);
1543extern void init_rt_rq(struct rt_rq *rt_rq, struct rq *rq);
aab03e05 1544extern void init_dl_rq(struct dl_rq *dl_rq, struct rq *rq);
029632fb 1545
1ee14e6c
BS
1546extern void cfs_bandwidth_usage_inc(void);
1547extern void cfs_bandwidth_usage_dec(void);
1c792db7 1548
3451d024 1549#ifdef CONFIG_NO_HZ_COMMON
1c792db7
SS
1550enum rq_nohz_flag_bits {
1551 NOHZ_TICK_STOPPED,
1552 NOHZ_BALANCE_KICK,
1553};
1554
1555#define nohz_flags(cpu) (&cpu_rq(cpu)->nohz_flags)
1556#endif
73fbec60
FW
1557
1558#ifdef CONFIG_IRQ_TIME_ACCOUNTING
1559
1560DECLARE_PER_CPU(u64, cpu_hardirq_time);
1561DECLARE_PER_CPU(u64, cpu_softirq_time);
1562
1563#ifndef CONFIG_64BIT
1564DECLARE_PER_CPU(seqcount_t, irq_time_seq);
1565
1566static inline void irq_time_write_begin(void)
1567{
1568 __this_cpu_inc(irq_time_seq.sequence);
1569 smp_wmb();
1570}
1571
1572static inline void irq_time_write_end(void)
1573{
1574 smp_wmb();
1575 __this_cpu_inc(irq_time_seq.sequence);
1576}
1577
1578static inline u64 irq_time_read(int cpu)
1579{
1580 u64 irq_time;
1581 unsigned seq;
1582
1583 do {
1584 seq = read_seqcount_begin(&per_cpu(irq_time_seq, cpu));
1585 irq_time = per_cpu(cpu_softirq_time, cpu) +
1586 per_cpu(cpu_hardirq_time, cpu);
1587 } while (read_seqcount_retry(&per_cpu(irq_time_seq, cpu), seq));
1588
1589 return irq_time;
1590}
1591#else /* CONFIG_64BIT */
1592static inline void irq_time_write_begin(void)
1593{
1594}
1595
1596static inline void irq_time_write_end(void)
1597{
1598}
1599
1600static inline u64 irq_time_read(int cpu)
1601{
1602 return per_cpu(cpu_softirq_time, cpu) + per_cpu(cpu_hardirq_time, cpu);
1603}
1604#endif /* CONFIG_64BIT */
1605#endif /* CONFIG_IRQ_TIME_ACCOUNTING */