Blame view
kernel/sched_cpupri.c
5.39 KB
6e0534f27 sched: use a 2-d ... |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 |
/* * kernel/sched_cpupri.c * * CPU priority management * * Copyright (C) 2007-2008 Novell * * Author: Gregory Haskins <ghaskins@novell.com> * * This code tracks the priority of each CPU so that global migration * decisions are easy to calculate. Each CPU can be in a state as follows: * * (INVALID), IDLE, NORMAL, RT1, ... RT99 * * going from the lowest priority to the highest. CPUs in the INVALID state * are not eligible for routing. The system maintains this state with * a 2 dimensional bitmap (the first for priority class, the second for cpus * in that class). Therefore a typical application without affinity * restrictions can find a suitable CPU with O(1) complexity (e.g. two bit * searches). For tasks with affinity restrictions, the algorithm has a * worst case complexity of O(min(102, nr_domcpus)), though the scenario that * yields the worst case search is fairly contrived. * * This program is free software; you can redistribute it and/or * modify it under the terms of the GNU General Public License * as published by the Free Software Foundation; version 2 * of the License. */ |
5a0e3ad6a include cleanup: ... |
29 |
#include <linux/gfp.h> |
6e0534f27 sched: use a 2-d ... |
30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 |
#include "sched_cpupri.h" /* Convert between a 140 based task->prio, and our 102 based cpupri */ static int convert_prio(int prio) { int cpupri; if (prio == CPUPRI_INVALID) cpupri = CPUPRI_INVALID; else if (prio == MAX_PRIO) cpupri = CPUPRI_IDLE; else if (prio >= MAX_RT_PRIO) cpupri = CPUPRI_NORMAL; else cpupri = MAX_RT_PRIO - prio + 1; return cpupri; } #define for_each_cpupri_active(array, idx) \ |
984b3f574 bitops: rename fo... |
50 |
for_each_set_bit(idx, array, CPUPRI_NR_PRIORITIES) |
6e0534f27 sched: use a 2-d ... |
51 52 53 54 55 |
/** * cpupri_find - find the best (lowest-pri) CPU in the system * @cp: The cpupri context * @p: The task |
13b8bd0a5 sched_rt: don't a... |
56 |
* @lowest_mask: A mask to fill in with selected CPUs (or NULL) |
6e0534f27 sched: use a 2-d ... |
57 58 |
* * Note: This function returns the recommended CPUs as calculated during the |
2a61aa401 Fix misspellings ... |
59 |
* current invocation. By the time the call returns, the CPUs may have in |
6e0534f27 sched: use a 2-d ... |
60 61 62 63 64 65 66 67 |
* fact changed priorities any number of times. While not ideal, it is not * an issue of correctness since the normal rebalancer logic will correct * any discrepancies created by racing against the uncertainty of the current * priority configuration. * * Returns: (int)bool - CPUs were found */ int cpupri_find(struct cpupri *cp, struct task_struct *p, |
68e74568f sched: convert st... |
68 |
struct cpumask *lowest_mask) |
6e0534f27 sched: use a 2-d ... |
69 70 71 72 73 74 |
{ int idx = 0; int task_pri = convert_prio(p->prio); for_each_cpupri_active(cp->pri_active, idx) { struct cpupri_vec *vec = &cp->pri_to_cpu[idx]; |
6e0534f27 sched: use a 2-d ... |
75 76 77 |
if (idx >= task_pri) break; |
68e74568f sched: convert st... |
78 |
if (cpumask_any_and(&p->cpus_allowed, vec->mask) >= nr_cpu_ids) |
6e0534f27 sched: use a 2-d ... |
79 |
continue; |
07903af15 sched: Fix race i... |
80 |
if (lowest_mask) { |
13b8bd0a5 sched_rt: don't a... |
81 |
cpumask_and(lowest_mask, &p->cpus_allowed, vec->mask); |
07903af15 sched: Fix race i... |
82 83 84 85 86 87 88 89 90 91 92 93 |
/* * We have to ensure that we have at least one bit * still set in the array, since the map could have * been concurrently emptied between the first and * second reads of vec->mask. If we hit this * condition, simply act as though we never hit this * priority level and continue on. */ if (cpumask_any(lowest_mask) >= nr_cpu_ids) continue; } |
6e0534f27 sched: use a 2-d ... |
94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 |
return 1; } return 0; } /** * cpupri_set - update the cpu priority setting * @cp: The cpupri context * @cpu: The target cpu * @pri: The priority (INVALID-RT99) to assign to this CPU * * Note: Assumes cpu_rq(cpu)->lock is locked * * Returns: (void) */ void cpupri_set(struct cpupri *cp, int cpu, int newpri) { int *currpri = &cp->cpu_to_pri[cpu]; int oldpri = *currpri; unsigned long flags; newpri = convert_prio(newpri); BUG_ON(newpri >= CPUPRI_NR_PRIORITIES); if (newpri == oldpri) return; /* * If the cpu was currently mapped to a different value, we |
c3a2ae3d9 sched: Add new pr... |
125 126 127 128 |
* need to map it to the new value then remove the old value. * Note, we must add the new value first, otherwise we risk the * cpu being cleared from pri_active, and this cpu could be * missed for a push or pull. |
6e0534f27 sched: use a 2-d ... |
129 |
*/ |
6e0534f27 sched: use a 2-d ... |
130 131 |
if (likely(newpri != CPUPRI_INVALID)) { struct cpupri_vec *vec = &cp->pri_to_cpu[newpri]; |
fe841226b sched: Convert cp... |
132 |
raw_spin_lock_irqsave(&vec->lock, flags); |
6e0534f27 sched: use a 2-d ... |
133 |
|
68e74568f sched: convert st... |
134 |
cpumask_set_cpu(cpu, vec->mask); |
6e0534f27 sched: use a 2-d ... |
135 136 137 |
vec->count++; if (vec->count == 1) set_bit(newpri, cp->pri_active); |
fe841226b sched: Convert cp... |
138 |
raw_spin_unlock_irqrestore(&vec->lock, flags); |
6e0534f27 sched: use a 2-d ... |
139 |
} |
c3a2ae3d9 sched: Add new pr... |
140 141 |
if (likely(oldpri != CPUPRI_INVALID)) { struct cpupri_vec *vec = &cp->pri_to_cpu[oldpri]; |
fe841226b sched: Convert cp... |
142 |
raw_spin_lock_irqsave(&vec->lock, flags); |
c3a2ae3d9 sched: Add new pr... |
143 144 145 146 147 |
vec->count--; if (!vec->count) clear_bit(oldpri, cp->pri_active); cpumask_clear_cpu(cpu, vec->mask); |
fe841226b sched: Convert cp... |
148 |
raw_spin_unlock_irqrestore(&vec->lock, flags); |
c3a2ae3d9 sched: Add new pr... |
149 |
} |
6e0534f27 sched: use a 2-d ... |
150 151 152 153 154 155 156 |
*currpri = newpri; } /** * cpupri_init - initialize the cpupri structure * @cp: The cpupri context |
68e74568f sched: convert st... |
157 |
* @bootmem: true if allocations need to use bootmem |
6e0534f27 sched: use a 2-d ... |
158 |
* |
68e74568f sched: convert st... |
159 |
* Returns: -ENOMEM if memory fails. |
6e0534f27 sched: use a 2-d ... |
160 |
*/ |
68c38fc3c sched: No need fo... |
161 |
int cpupri_init(struct cpupri *cp) |
6e0534f27 sched: use a 2-d ... |
162 163 164 165 166 167 168 |
{ int i; memset(cp, 0, sizeof(*cp)); for (i = 0; i < CPUPRI_NR_PRIORITIES; i++) { struct cpupri_vec *vec = &cp->pri_to_cpu[i]; |
fe841226b sched: Convert cp... |
169 |
raw_spin_lock_init(&vec->lock); |
6e0534f27 sched: use a 2-d ... |
170 |
vec->count = 0; |
68c38fc3c sched: No need fo... |
171 |
if (!zalloc_cpumask_var(&vec->mask, GFP_KERNEL)) |
68e74568f sched: convert st... |
172 |
goto cleanup; |
6e0534f27 sched: use a 2-d ... |
173 174 175 176 |
} for_each_possible_cpu(i) cp->cpu_to_pri[i] = CPUPRI_INVALID; |
68e74568f sched: convert st... |
177 178 179 180 181 182 |
return 0; cleanup: for (i--; i >= 0; i--) free_cpumask_var(cp->pri_to_cpu[i].mask); return -ENOMEM; |
6e0534f27 sched: use a 2-d ... |
183 |
} |
68e74568f sched: convert st... |
184 185 186 187 188 189 190 |
/** * cpupri_cleanup - clean up the cpupri structure * @cp: The cpupri context */ void cpupri_cleanup(struct cpupri *cp) { int i; |
6e0534f27 sched: use a 2-d ... |
191 |
|
68e74568f sched: convert st... |
192 193 194 |
for (i = 0; i < CPUPRI_NR_PRIORITIES; i++) free_cpumask_var(cp->pri_to_cpu[i].mask); } |