diff options
Diffstat (limited to 'kernel')
| -rw-r--r-- | kernel/Makefile | 1 | ||||
| -rw-r--r-- | kernel/cpuset.c | 260 | ||||
| -rw-r--r-- | kernel/groups.c | 288 | ||||
| -rw-r--r-- | kernel/kfifo.c | 4 | ||||
| -rw-r--r-- | kernel/kthread.c | 2 | ||||
| -rw-r--r-- | kernel/power/process.c | 5 | ||||
| -rw-r--r-- | kernel/profile.c | 8 | ||||
| -rw-r--r-- | kernel/slow-work.c | 23 | ||||
| -rw-r--r-- | kernel/sys.c | 283 | ||||
| -rw-r--r-- | kernel/sysctl.c | 2 |
10 files changed, 431 insertions, 445 deletions
diff --git a/kernel/Makefile b/kernel/Makefile index 90b53f6dc226..9df4501cb921 100644 --- a/kernel/Makefile +++ b/kernel/Makefile | |||
| @@ -11,6 +11,7 @@ obj-y = sched.o fork.o exec_domain.o panic.o printk.o \ | |||
| 11 | hrtimer.o rwsem.o nsproxy.o srcu.o semaphore.o \ | 11 | hrtimer.o rwsem.o nsproxy.o srcu.o semaphore.o \ |
| 12 | notifier.o ksysfs.o pm_qos_params.o sched_clock.o cred.o \ | 12 | notifier.o ksysfs.o pm_qos_params.o sched_clock.o cred.o \ |
| 13 | async.o | 13 | async.o |
| 14 | obj-y += groups.o | ||
| 14 | 15 | ||
| 15 | ifdef CONFIG_FUNCTION_TRACER | 16 | ifdef CONFIG_FUNCTION_TRACER |
| 16 | # Do not trace debug files and internal ftrace files | 17 | # Do not trace debug files and internal ftrace files |
diff --git a/kernel/cpuset.c b/kernel/cpuset.c index d5a7e17474ee..7e75a41bd508 100644 --- a/kernel/cpuset.c +++ b/kernel/cpuset.c | |||
| @@ -97,12 +97,6 @@ struct cpuset { | |||
| 97 | 97 | ||
| 98 | struct cpuset *parent; /* my parent */ | 98 | struct cpuset *parent; /* my parent */ |
| 99 | 99 | ||
| 100 | /* | ||
| 101 | * Copy of global cpuset_mems_generation as of the most | ||
| 102 | * recent time this cpuset changed its mems_allowed. | ||
| 103 | */ | ||
| 104 | int mems_generation; | ||
| 105 | |||
| 106 | struct fmeter fmeter; /* memory_pressure filter */ | 100 | struct fmeter fmeter; /* memory_pressure filter */ |
| 107 | 101 | ||
| 108 | /* partition number for rebuild_sched_domains() */ | 102 | /* partition number for rebuild_sched_domains() */ |
| @@ -176,27 +170,6 @@ static inline int is_spread_slab(const struct cpuset *cs) | |||
| 176 | return test_bit(CS_SPREAD_SLAB, &cs->flags); | 170 | return test_bit(CS_SPREAD_SLAB, &cs->flags); |
| 177 | } | 171 | } |
| 178 | 172 | ||
| 179 | /* | ||
| 180 | * Increment this integer everytime any cpuset changes its | ||
| 181 | * mems_allowed value. Users of cpusets can track this generation | ||
| 182 | * number, and avoid having to lock and reload mems_allowed unless | ||
| 183 | * the cpuset they're using changes generation. | ||
| 184 | * | ||
| 185 | * A single, global generation is needed because cpuset_attach_task() could | ||
| 186 | * reattach a task to a different cpuset, which must not have its | ||
| 187 | * generation numbers aliased with those of that tasks previous cpuset. | ||
| 188 | * | ||
| 189 | * Generations are needed for mems_allowed because one task cannot | ||
| 190 | * modify another's memory placement. So we must enable every task, | ||
| 191 | * on every visit to __alloc_pages(), to efficiently check whether | ||
| 192 | * its current->cpuset->mems_allowed has changed, requiring an update | ||
| 193 | * of its current->mems_allowed. | ||
| 194 | * | ||
| 195 | * Since writes to cpuset_mems_generation are guarded by the cgroup lock | ||
| 196 | * there is no need to mark it atomic. | ||
| 197 | */ | ||
| 198 | static int cpuset_mems_generation; | ||
| 199 | |||
| 200 | static struct cpuset top_cpuset = { | 173 | static struct cpuset top_cpuset = { |
| 201 | .flags = ((1 << CS_CPU_EXCLUSIVE) | (1 << CS_MEM_EXCLUSIVE)), | 174 | .flags = ((1 << CS_CPU_EXCLUSIVE) | (1 << CS_MEM_EXCLUSIVE)), |
| 202 | }; | 175 | }; |
| @@ -228,8 +201,9 @@ static struct cpuset top_cpuset = { | |||
| 228 | * If a task is only holding callback_mutex, then it has read-only | 201 | * If a task is only holding callback_mutex, then it has read-only |
| 229 | * access to cpusets. | 202 | * access to cpusets. |
| 230 | * | 203 | * |
| 231 | * The task_struct fields mems_allowed and mems_generation may only | 204 | * Now, the task_struct fields mems_allowed and mempolicy may be changed |
| 232 | * be accessed in the context of that task, so require no locks. | 205 | * by other task, we use alloc_lock in the task_struct fields to protect |
| 206 | * them. | ||
| 233 | * | 207 | * |
| 234 | * The cpuset_common_file_read() handlers only hold callback_mutex across | 208 | * The cpuset_common_file_read() handlers only hold callback_mutex across |
| 235 | * small pieces of code, such as when reading out possibly multi-word | 209 | * small pieces of code, such as when reading out possibly multi-word |
| @@ -331,75 +305,22 @@ static void guarantee_online_mems(const struct cpuset *cs, nodemask_t *pmask) | |||
| 331 | BUG_ON(!nodes_intersects(*pmask, node_states[N_HIGH_MEMORY])); | 305 | BUG_ON(!nodes_intersects(*pmask, node_states[N_HIGH_MEMORY])); |
| 332 | } | 306 | } |
| 333 | 307 | ||
| 334 | /** | 308 | /* |
| 335 | * cpuset_update_task_memory_state - update task memory placement | 309 | * update task's spread flag if cpuset's page/slab spread flag is set |
| 336 | * | 310 | * |
| 337 | * If the current tasks cpusets mems_allowed changed behind our | 311 | * Called with callback_mutex/cgroup_mutex held |
| 338 | * backs, update current->mems_allowed, mems_generation and task NUMA | ||
| 339 | * mempolicy to the new value. | ||
| 340 | * | ||
| 341 | * Task mempolicy is updated by rebinding it relative to the | ||
| 342 | * current->cpuset if a task has its memory placement changed. | ||
| 343 | * Do not call this routine if in_interrupt(). | ||
| 344 | * | ||
| 345 | * Call without callback_mutex or task_lock() held. May be | ||
| 346 | * called with or without cgroup_mutex held. Thanks in part to | ||
| 347 | * 'the_top_cpuset_hack', the task's cpuset pointer will never | ||
| 348 | * be NULL. This routine also might acquire callback_mutex during | ||
| 349 | * call. | ||
| 350 | * | ||
| 351 | * Reading current->cpuset->mems_generation doesn't need task_lock | ||
| 352 | * to guard the current->cpuset derefence, because it is guarded | ||
| 353 | * from concurrent freeing of current->cpuset using RCU. | ||
| 354 | * | ||
| 355 | * The rcu_dereference() is technically probably not needed, | ||
| 356 | * as I don't actually mind if I see a new cpuset pointer but | ||
| 357 | * an old value of mems_generation. However this really only | ||
| 358 | * matters on alpha systems using cpusets heavily. If I dropped | ||
| 359 | * that rcu_dereference(), it would save them a memory barrier. | ||
| 360 | * For all other arch's, rcu_dereference is a no-op anyway, and for | ||
| 361 | * alpha systems not using cpusets, another planned optimization, | ||
| 362 | * avoiding the rcu critical section for tasks in the root cpuset | ||
| 363 | * which is statically allocated, so can't vanish, will make this | ||
| 364 | * irrelevant. Better to use RCU as intended, than to engage in | ||
| 365 | * some cute trick to save a memory barrier that is impossible to | ||
| 366 | * test, for alpha systems using cpusets heavily, which might not | ||
| 367 | * even exist. | ||
| 368 | * | ||
| 369 | * This routine is needed to update the per-task mems_allowed data, | ||
| 370 | * within the tasks context, when it is trying to allocate memory | ||
| 371 | * (in various mm/mempolicy.c routines) and notices that some other | ||
| 372 | * task has been modifying its cpuset. | ||
| 373 | */ | 312 | */ |
| 374 | 313 | static void cpuset_update_task_spread_flag(struct cpuset *cs, | |
| 375 | void cpuset_update_task_memory_state(void) | 314 | struct task_struct *tsk) |
| 376 | { | 315 | { |
| 377 | int my_cpusets_mem_gen; | 316 | if (is_spread_page(cs)) |
| 378 | struct task_struct *tsk = current; | 317 | tsk->flags |= PF_SPREAD_PAGE; |
| 379 | struct cpuset *cs; | 318 | else |
| 380 | 319 | tsk->flags &= ~PF_SPREAD_PAGE; | |
| 381 | rcu_read_lock(); | 320 | if (is_spread_slab(cs)) |
| 382 | my_cpusets_mem_gen = task_cs(tsk)->mems_generation; | 321 | tsk->flags |= PF_SPREAD_SLAB; |
| 383 | rcu_read_unlock(); | 322 | else |
| 384 | 323 | tsk->flags &= ~PF_SPREAD_SLAB; | |
| 385 | if (my_cpusets_mem_gen != tsk->cpuset_mems_generation) { | ||
| 386 | mutex_lock(&callback_mutex); | ||
| 387 | task_lock(tsk); | ||
| 388 | cs = task_cs(tsk); /* Maybe changed when task not locked */ | ||
| 389 | guarantee_online_mems(cs, &tsk->mems_allowed); | ||
| 390 | tsk->cpuset_mems_generation = cs->mems_generation; | ||
| 391 | if (is_spread_page(cs)) | ||
| 392 | tsk->flags |= PF_SPREAD_PAGE; | ||
| 393 | else | ||
| 394 | tsk->flags &= ~PF_SPREAD_PAGE; | ||
| 395 | if (is_spread_slab(cs)) | ||
| 396 | tsk->flags |= PF_SPREAD_SLAB; | ||
| 397 | else | ||
| 398 | tsk->flags &= ~PF_SPREAD_SLAB; | ||
| 399 | task_unlock(tsk); | ||
| 400 | mutex_unlock(&callback_mutex); | ||
| 401 | mpol_rebind_task(tsk, &tsk->mems_allowed); | ||
| 402 | } | ||
| 403 | } | 324 | } |
| 404 | 325 | ||
| 405 | /* | 326 | /* |
| @@ -1007,14 +928,6 @@ static int update_cpumask(struct cpuset *cs, struct cpuset *trialcs, | |||
| 1007 | * other task, the task_struct mems_allowed that we are hacking | 928 | * other task, the task_struct mems_allowed that we are hacking |
| 1008 | * is for our current task, which must allocate new pages for that | 929 | * is for our current task, which must allocate new pages for that |
| 1009 | * migrating memory region. | 930 | * migrating memory region. |
| 1010 | * | ||
| 1011 | * We call cpuset_update_task_memory_state() before hacking | ||
| 1012 | * our tasks mems_allowed, so that we are assured of being in | ||
| 1013 | * sync with our tasks cpuset, and in particular, callbacks to | ||
| 1014 | * cpuset_update_task_memory_state() from nested page allocations | ||
| 1015 | * won't see any mismatch of our cpuset and task mems_generation | ||
| 1016 | * values, so won't overwrite our hacked tasks mems_allowed | ||
| 1017 | * nodemask. | ||
| 1018 | */ | 931 | */ |
| 1019 | 932 | ||
| 1020 | static void cpuset_migrate_mm(struct mm_struct *mm, const nodemask_t *from, | 933 | static void cpuset_migrate_mm(struct mm_struct *mm, const nodemask_t *from, |
| @@ -1022,22 +935,37 @@ static void cpuset_migrate_mm(struct mm_struct *mm, const nodemask_t *from, | |||
| 1022 | { | 935 | { |
| 1023 | struct task_struct *tsk = current; | 936 | struct task_struct *tsk = current; |
| 1024 | 937 | ||
| 1025 | cpuset_update_task_memory_state(); | ||
| 1026 | |||
| 1027 | mutex_lock(&callback_mutex); | ||
| 1028 | tsk->mems_allowed = *to; | 938 | tsk->mems_allowed = *to; |
| 1029 | mutex_unlock(&callback_mutex); | ||
| 1030 | 939 | ||
| 1031 | do_migrate_pages(mm, from, to, MPOL_MF_MOVE_ALL); | 940 | do_migrate_pages(mm, from, to, MPOL_MF_MOVE_ALL); |
| 1032 | 941 | ||
| 1033 | mutex_lock(&callback_mutex); | ||
| 1034 | guarantee_online_mems(task_cs(tsk),&tsk->mems_allowed); | 942 | guarantee_online_mems(task_cs(tsk),&tsk->mems_allowed); |
| 1035 | mutex_unlock(&callback_mutex); | ||
| 1036 | } | 943 | } |
| 1037 | 944 | ||
| 1038 | /* | 945 | /* |
| 1039 | * Rebind task's vmas to cpuset's new mems_allowed, and migrate pages to new | 946 | * cpuset_change_task_nodemask - change task's mems_allowed and mempolicy |
| 1040 | * nodes if memory_migrate flag is set. Called with cgroup_mutex held. | 947 | * @tsk: the task to change |
| 948 | * @newmems: new nodes that the task will be set | ||
| 949 | * | ||
| 950 | * In order to avoid seeing no nodes if the old and new nodes are disjoint, | ||
| 951 | * we structure updates as setting all new allowed nodes, then clearing newly | ||
| 952 | * disallowed ones. | ||
| 953 | * | ||
| 954 | * Called with task's alloc_lock held | ||
| 955 | */ | ||
| 956 | static void cpuset_change_task_nodemask(struct task_struct *tsk, | ||
| 957 | nodemask_t *newmems) | ||
| 958 | { | ||
| 959 | nodes_or(tsk->mems_allowed, tsk->mems_allowed, *newmems); | ||
| 960 | mpol_rebind_task(tsk, &tsk->mems_allowed); | ||
| 961 | mpol_rebind_task(tsk, newmems); | ||
| 962 | tsk->mems_allowed = *newmems; | ||
| 963 | } | ||
| 964 | |||
| 965 | /* | ||
| 966 | * Update task's mems_allowed and rebind its mempolicy and vmas' mempolicy | ||
| 967 | * of it to cpuset's new mems_allowed, and migrate pages to new nodes if | ||
| 968 | * memory_migrate flag is set. Called with cgroup_mutex held. | ||
| 1041 | */ | 969 | */ |
| 1042 | static void cpuset_change_nodemask(struct task_struct *p, | 970 | static void cpuset_change_nodemask(struct task_struct *p, |
| 1043 | struct cgroup_scanner *scan) | 971 | struct cgroup_scanner *scan) |
| @@ -1046,12 +974,19 @@ static void cpuset_change_nodemask(struct task_struct *p, | |||
| 1046 | struct cpuset *cs; | 974 | struct cpuset *cs; |
| 1047 | int migrate; | 975 | int migrate; |
| 1048 | const nodemask_t *oldmem = scan->data; | 976 | const nodemask_t *oldmem = scan->data; |
| 977 | nodemask_t newmems; | ||
| 978 | |||
| 979 | cs = cgroup_cs(scan->cg); | ||
| 980 | guarantee_online_mems(cs, &newmems); | ||
| 981 | |||
| 982 | task_lock(p); | ||
| 983 | cpuset_change_task_nodemask(p, &newmems); | ||
| 984 | task_unlock(p); | ||
| 1049 | 985 | ||
| 1050 | mm = get_task_mm(p); | 986 | mm = get_task_mm(p); |
| 1051 | if (!mm) | 987 | if (!mm) |
| 1052 | return; | 988 | return; |
| 1053 | 989 | ||
| 1054 | cs = cgroup_cs(scan->cg); | ||
| 1055 | migrate = is_memory_migrate(cs); | 990 | migrate = is_memory_migrate(cs); |
| 1056 | 991 | ||
| 1057 | mpol_rebind_mm(mm, &cs->mems_allowed); | 992 | mpol_rebind_mm(mm, &cs->mems_allowed); |
| @@ -1104,10 +1039,10 @@ static void update_tasks_nodemask(struct cpuset *cs, const nodemask_t *oldmem, | |||
| 1104 | /* | 1039 | /* |
| 1105 | * Handle user request to change the 'mems' memory placement | 1040 | * Handle user request to change the 'mems' memory placement |
| 1106 | * of a cpuset. Needs to validate the request, update the | 1041 | * of a cpuset. Needs to validate the request, update the |
| 1107 | * cpusets mems_allowed and mems_generation, and for each | 1042 | * cpusets mems_allowed, and for each task in the cpuset, |
| 1108 | * task in the cpuset, rebind any vma mempolicies and if | 1043 | * update mems_allowed and rebind task's mempolicy and any vma |
| 1109 | * the cpuset is marked 'memory_migrate', migrate the tasks | 1044 | * mempolicies and if the cpuset is marked 'memory_migrate', |
| 1110 | * pages to the new memory. | 1045 | * migrate the tasks pages to the new memory. |
| 1111 | * | 1046 | * |
| 1112 | * Call with cgroup_mutex held. May take callback_mutex during call. | 1047 | * Call with cgroup_mutex held. May take callback_mutex during call. |
| 1113 | * Will take tasklist_lock, scan tasklist for tasks in cpuset cs, | 1048 | * Will take tasklist_lock, scan tasklist for tasks in cpuset cs, |
| @@ -1160,7 +1095,6 @@ static int update_nodemask(struct cpuset *cs, struct cpuset *trialcs, | |||
| 1160 | 1095 | ||
| 1161 | mutex_lock(&callback_mutex); | 1096 | mutex_lock(&callback_mutex); |
| 1162 | cs->mems_allowed = trialcs->mems_allowed; | 1097 | cs->mems_allowed = trialcs->mems_allowed; |
| 1163 | cs->mems_generation = cpuset_mems_generation++; | ||
| 1164 | mutex_unlock(&callback_mutex); | 1098 | mutex_unlock(&callback_mutex); |
| 1165 | 1099 | ||
| 1166 | update_tasks_nodemask(cs, &oldmem, &heap); | 1100 | update_tasks_nodemask(cs, &oldmem, &heap); |
| @@ -1193,6 +1127,46 @@ static int update_relax_domain_level(struct cpuset *cs, s64 val) | |||
| 1193 | } | 1127 | } |
| 1194 | 1128 | ||
| 1195 | /* | 1129 | /* |
| 1130 | * cpuset_change_flag - make a task's spread flags the same as its cpuset's | ||
| 1131 | * @tsk: task to be updated | ||
| 1132 | * @scan: struct cgroup_scanner containing the cgroup of the task | ||
| 1133 | * | ||
| 1134 | * Called by cgroup_scan_tasks() for each task in a cgroup. | ||
| 1135 | * | ||
| 1136 | * We don't need to re-check for the cgroup/cpuset membership, since we're | ||
| 1137 | * holding cgroup_lock() at this point. | ||
| 1138 | */ | ||
| 1139 | static void cpuset_change_flag(struct task_struct *tsk, | ||
| 1140 | struct cgroup_scanner *scan) | ||
| 1141 | { | ||
| 1142 | cpuset_update_task_spread_flag(cgroup_cs(scan->cg), tsk); | ||
| 1143 | } | ||
| 1144 | |||
| 1145 | /* | ||
| 1146 | * update_tasks_flags - update the spread flags of tasks in the cpuset. | ||
| 1147 | * @cs: the cpuset in which each task's spread flags needs to be changed | ||
| 1148 | * @heap: if NULL, defer allocating heap memory to cgroup_scan_tasks() | ||
| 1149 | * | ||
| 1150 | * Called with cgroup_mutex held | ||
| 1151 | * | ||
| 1152 | * The cgroup_scan_tasks() function will scan all the tasks in a cgroup, | ||
| 1153 | * calling callback functions for each. | ||
| 1154 | * | ||
| 1155 | * No return value. It's guaranteed that cgroup_scan_tasks() always returns 0 | ||
| 1156 | * if @heap != NULL. | ||
| 1157 | */ | ||
| 1158 | static void update_tasks_flags(struct cpuset *cs, struct ptr_heap *heap) | ||
| 1159 | { | ||
| 1160 | struct cgroup_scanner scan; | ||
| 1161 | |||
| 1162 | scan.cg = cs->css.cgroup; | ||
| 1163 | scan.test_task = NULL; | ||
| 1164 | scan.process_task = cpuset_change_flag; | ||
| 1165 | scan.heap = heap; | ||
| 1166 | cgroup_scan_tasks(&scan); | ||
| 1167 | } | ||
| 1168 | |||
| 1169 | /* | ||
| 1196 | * update_flag - read a 0 or a 1 in a file and update associated flag | 1170 | * update_flag - read a 0 or a 1 in a file and update associated flag |
| 1197 | * bit: the bit to update (see cpuset_flagbits_t) | 1171 | * bit: the bit to update (see cpuset_flagbits_t) |
| 1198 | * cs: the cpuset to update | 1172 | * cs: the cpuset to update |
| @@ -1205,8 +1179,10 @@ static int update_flag(cpuset_flagbits_t bit, struct cpuset *cs, | |||
| 1205 | int turning_on) | 1179 | int turning_on) |
| 1206 | { | 1180 | { |
| 1207 | struct cpuset *trialcs; | 1181 | struct cpuset *trialcs; |
| 1208 | int err; | ||
| 1209 | int balance_flag_changed; | 1182 | int balance_flag_changed; |
| 1183 | int spread_flag_changed; | ||
| 1184 | struct ptr_heap heap; | ||
| 1185 | int err; | ||
| 1210 | 1186 | ||
| 1211 | trialcs = alloc_trial_cpuset(cs); | 1187 | trialcs = alloc_trial_cpuset(cs); |
| 1212 | if (!trialcs) | 1188 | if (!trialcs) |
| @@ -1221,9 +1197,16 @@ static int update_flag(cpuset_flagbits_t bit, struct cpuset *cs, | |||
| 1221 | if (err < 0) | 1197 | if (err < 0) |
| 1222 | goto out; | 1198 | goto out; |
| 1223 | 1199 | ||
| 1200 | err = heap_init(&heap, PAGE_SIZE, GFP_KERNEL, NULL); | ||
| 1201 | if (err < 0) | ||
| 1202 | goto out; | ||
| 1203 | |||
| 1224 | balance_flag_changed = (is_sched_load_balance(cs) != | 1204 | balance_flag_changed = (is_sched_load_balance(cs) != |
| 1225 | is_sched_load_balance(trialcs)); | 1205 | is_sched_load_balance(trialcs)); |
| 1226 | 1206 | ||
| 1207 | spread_flag_changed = ((is_spread_slab(cs) != is_spread_slab(trialcs)) | ||
| 1208 | || (is_spread_page(cs) != is_spread_page(trialcs))); | ||
| 1209 | |||
| 1227 | mutex_lock(&callback_mutex); | 1210 | mutex_lock(&callback_mutex); |
| 1228 | cs->flags = trialcs->flags; | 1211 | cs->flags = trialcs->flags; |
| 1229 | mutex_unlock(&callback_mutex); | 1212 | mutex_unlock(&callback_mutex); |
| @@ -1231,6 +1214,9 @@ static int update_flag(cpuset_flagbits_t bit, struct cpuset *cs, | |||
| 1231 | if (!cpumask_empty(trialcs->cpus_allowed) && balance_flag_changed) | 1214 | if (!cpumask_empty(trialcs->cpus_allowed) && balance_flag_changed) |
| 1232 | async_rebuild_sched_domains(); | 1215 | async_rebuild_sched_domains(); |
| 1233 | 1216 | ||
| 1217 | if (spread_flag_changed) | ||
| 1218 | update_tasks_flags(cs, &heap); | ||
| 1219 | heap_free(&heap); | ||
| 1234 | out: | 1220 | out: |
| 1235 | free_trial_cpuset(trialcs); | 1221 | free_trial_cpuset(trialcs); |
| 1236 | return err; | 1222 | return err; |
| @@ -1372,15 +1358,20 @@ static void cpuset_attach(struct cgroup_subsys *ss, | |||
| 1372 | 1358 | ||
| 1373 | if (cs == &top_cpuset) { | 1359 | if (cs == &top_cpuset) { |
| 1374 | cpumask_copy(cpus_attach, cpu_possible_mask); | 1360 | cpumask_copy(cpus_attach, cpu_possible_mask); |
| 1361 | to = node_possible_map; | ||
| 1375 | } else { | 1362 | } else { |
| 1376 | mutex_lock(&callback_mutex); | ||
| 1377 | guarantee_online_cpus(cs, cpus_attach); | 1363 | guarantee_online_cpus(cs, cpus_attach); |
| 1378 | mutex_unlock(&callback_mutex); | 1364 | guarantee_online_mems(cs, &to); |
| 1379 | } | 1365 | } |
| 1380 | err = set_cpus_allowed_ptr(tsk, cpus_attach); | 1366 | err = set_cpus_allowed_ptr(tsk, cpus_attach); |
| 1381 | if (err) | 1367 | if (err) |
| 1382 | return; | 1368 | return; |
| 1383 | 1369 | ||
| 1370 | task_lock(tsk); | ||
| 1371 | cpuset_change_task_nodemask(tsk, &to); | ||
| 1372 | task_unlock(tsk); | ||
| 1373 | cpuset_update_task_spread_flag(cs, tsk); | ||
| 1374 | |||
| 1384 | from = oldcs->mems_allowed; | 1375 | from = oldcs->mems_allowed; |
| 1385 | to = cs->mems_allowed; | 1376 | to = cs->mems_allowed; |
| 1386 | mm = get_task_mm(tsk); | 1377 | mm = get_task_mm(tsk); |
| @@ -1442,11 +1433,9 @@ static int cpuset_write_u64(struct cgroup *cgrp, struct cftype *cft, u64 val) | |||
| 1442 | break; | 1433 | break; |
| 1443 | case FILE_SPREAD_PAGE: | 1434 | case FILE_SPREAD_PAGE: |
| 1444 | retval = update_flag(CS_SPREAD_PAGE, cs, val); | 1435 | retval = update_flag(CS_SPREAD_PAGE, cs, val); |
| 1445 | cs->mems_generation = cpuset_mems_generation++; | ||
| 1446 | break; | 1436 | break; |
| 1447 | case FILE_SPREAD_SLAB: | 1437 | case FILE_SPREAD_SLAB: |
| 1448 | retval = update_flag(CS_SPREAD_SLAB, cs, val); | 1438 | retval = update_flag(CS_SPREAD_SLAB, cs, val); |
| 1449 | cs->mems_generation = cpuset_mems_generation++; | ||
| 1450 | break; | 1439 | break; |
| 1451 | default: | 1440 | default: |
| 1452 | retval = -EINVAL; | 1441 | retval = -EINVAL; |
| @@ -1786,8 +1775,6 @@ static struct cgroup_subsys_state *cpuset_create( | |||
| 1786 | struct cpuset *parent; | 1775 | struct cpuset *parent; |
| 1787 | 1776 | ||
| 1788 | if (!cont->parent) { | 1777 | if (!cont->parent) { |
| 1789 | /* This is early initialization for the top cgroup */ | ||
| 1790 | top_cpuset.mems_generation = cpuset_mems_generation++; | ||
| 1791 | return &top_cpuset.css; | 1778 | return &top_cpuset.css; |
| 1792 | } | 1779 | } |
| 1793 | parent = cgroup_cs(cont->parent); | 1780 | parent = cgroup_cs(cont->parent); |
| @@ -1799,7 +1786,6 @@ static struct cgroup_subsys_state *cpuset_create( | |||
| 1799 | return ERR_PTR(-ENOMEM); | 1786 | return ERR_PTR(-ENOMEM); |
| 1800 | } | 1787 | } |
| 1801 | 1788 | ||
| 1802 | cpuset_update_task_memory_state(); | ||
| 1803 | cs->flags = 0; | 1789 | cs->flags = 0; |
| 1804 | if (is_spread_page(parent)) | 1790 | if (is_spread_page(parent)) |
| 1805 | set_bit(CS_SPREAD_PAGE, &cs->flags); | 1791 | set_bit(CS_SPREAD_PAGE, &cs->flags); |
| @@ -1808,7 +1794,6 @@ static struct cgroup_subsys_state *cpuset_create( | |||
| 1808 | set_bit(CS_SCHED_LOAD_BALANCE, &cs->flags); | 1794 | set_bit(CS_SCHED_LOAD_BALANCE, &cs->flags); |
| 1809 | cpumask_clear(cs->cpus_allowed); | 1795 | cpumask_clear(cs->cpus_allowed); |
| 1810 | nodes_clear(cs->mems_allowed); | 1796 | nodes_clear(cs->mems_allowed); |
| 1811 | cs->mems_generation = cpuset_mems_generation++; | ||
| 1812 | fmeter_init(&cs->fmeter); | 1797 | fmeter_init(&cs->fmeter); |
| 1813 | cs->relax_domain_level = -1; | 1798 | cs->relax_domain_level = -1; |
| 1814 | 1799 | ||
| @@ -1827,8 +1812,6 @@ static void cpuset_destroy(struct cgroup_subsys *ss, struct cgroup *cont) | |||
| 1827 | { | 1812 | { |
| 1828 | struct cpuset *cs = cgroup_cs(cont); | 1813 | struct cpuset *cs = cgroup_cs(cont); |
| 1829 | 1814 | ||
| 1830 | cpuset_update_task_memory_state(); | ||
| 1831 | |||
| 1832 | if (is_sched_load_balance(cs)) | 1815 | if (is_sched_load_balance(cs)) |
| 1833 | update_flag(CS_SCHED_LOAD_BALANCE, cs, 0); | 1816 | update_flag(CS_SCHED_LOAD_BALANCE, cs, 0); |
| 1834 | 1817 | ||
| @@ -1849,21 +1832,6 @@ struct cgroup_subsys cpuset_subsys = { | |||
| 1849 | .early_init = 1, | 1832 | .early_init = 1, |
| 1850 | }; | 1833 | }; |
| 1851 | 1834 | ||
| 1852 | /* | ||
| 1853 | * cpuset_init_early - just enough so that the calls to | ||
| 1854 | * cpuset_update_task_memory_state() in early init code | ||
| 1855 | * are harmless. | ||
| 1856 | */ | ||
| 1857 | |||
| 1858 | int __init cpuset_init_early(void) | ||
| 1859 | { | ||
| 1860 | alloc_cpumask_var(&top_cpuset.cpus_allowed, GFP_NOWAIT); | ||
| 1861 | |||
| 1862 | top_cpuset.mems_generation = cpuset_mems_generation++; | ||
| 1863 | return 0; | ||
| 1864 | } | ||
| 1865 | |||
| 1866 | |||
| 1867 | /** | 1835 | /** |
| 1868 | * cpuset_init - initialize cpusets at system boot | 1836 | * cpuset_init - initialize cpusets at system boot |
| 1869 | * | 1837 | * |
| @@ -1874,11 +1842,13 @@ int __init cpuset_init(void) | |||
| 1874 | { | 1842 | { |
| 1875 | int err = 0; | 1843 | int err = 0; |
| 1876 | 1844 | ||
| 1845 | if (!alloc_cpumask_var(&top_cpuset.cpus_allowed, GFP_KERNEL)) | ||
| 1846 | BUG(); | ||
| 1847 | |||
| 1877 | cpumask_setall(top_cpuset.cpus_allowed); | 1848 | cpumask_setall(top_cpuset.cpus_allowed); |
| 1878 | nodes_setall(top_cpuset.mems_allowed); | 1849 | nodes_setall(top_cpuset.mems_allowed); |
| 1879 | 1850 | ||
| 1880 | fmeter_init(&top_cpuset.fmeter); | 1851 | fmeter_init(&top_cpuset.fmeter); |
| 1881 | top_cpuset.mems_generation = cpuset_mems_generation++; | ||
| 1882 | set_bit(CS_SCHED_LOAD_BALANCE, &top_cpuset.flags); | 1852 | set_bit(CS_SCHED_LOAD_BALANCE, &top_cpuset.flags); |
| 1883 | top_cpuset.relax_domain_level = -1; | 1853 | top_cpuset.relax_domain_level = -1; |
| 1884 | 1854 | ||
diff --git a/kernel/groups.c b/kernel/groups.c new file mode 100644 index 000000000000..2b45b2ee3964 --- /dev/null +++ b/kernel/groups.c | |||
| @@ -0,0 +1,288 @@ | |||
| 1 | /* | ||
| 2 | * Supplementary group IDs | ||
| 3 | */ | ||
| 4 | #include <linux/cred.h> | ||
| 5 | #include <linux/module.h> | ||
| 6 | #include <linux/slab.h> | ||
| 7 | #include <linux/security.h> | ||
| 8 | #include <linux/syscalls.h> | ||
| 9 | #include <asm/uaccess.h> | ||
| 10 | |||
| 11 | /* init to 2 - one for init_task, one to ensure it is never freed */ | ||
| 12 | struct group_info init_groups = { .usage = ATOMIC_INIT(2) }; | ||
| 13 | |||
| 14 | struct group_info *groups_alloc(int gidsetsize) | ||
| 15 | { | ||
| 16 | struct group_info *group_info; | ||
| 17 | int nblocks; | ||
| 18 | int i; | ||
| 19 | |||
| 20 | nblocks = (gidsetsize + NGROUPS_PER_BLOCK - 1) / NGROUPS_PER_BLOCK; | ||
| 21 | /* Make sure we always allocate at least one indirect block pointer */ | ||
| 22 | nblocks = nblocks ? : 1; | ||
| 23 | group_info = kmalloc(sizeof(*group_info) + nblocks*sizeof(gid_t *), GFP_USER); | ||
| 24 | if (!group_info) | ||
| 25 | return NULL; | ||
| 26 | group_info->ngroups = gidsetsize; | ||
| 27 | group_info->nblocks = nblocks; | ||
| 28 | atomic_set(&group_info->usage, 1); | ||
| 29 | |||
| 30 | if (gidsetsize <= NGROUPS_SMALL) | ||
| 31 | group_info->blocks[0] = group_info->small_block; | ||
| 32 | else { | ||
| 33 | for (i = 0; i < nblocks; i++) { | ||
| 34 | gid_t *b; | ||
| 35 | b = (void *)__get_free_page(GFP_USER); | ||
| 36 | if (!b) | ||
| 37 | goto out_undo_partial_alloc; | ||
| 38 | group_info->blocks[i] = b; | ||
| 39 | } | ||
| 40 | } | ||
| 41 | return group_info; | ||
| 42 | |||
| 43 | out_undo_partial_alloc: | ||
| 44 | while (--i >= 0) { | ||
| 45 | free_page((unsigned long)group_info->blocks[i]); | ||
| 46 | } | ||
| 47 | kfree(group_info); | ||
| 48 | return NULL; | ||
| 49 | } | ||
| 50 | |||
| 51 | EXPORT_SYMBOL(groups_alloc); | ||
| 52 | |||
| 53 | void groups_free(struct group_info *group_info) | ||
| 54 | { | ||
| 55 | if (group_info->blocks[0] != group_info->small_block) { | ||
| 56 | int i; | ||
| 57 | for (i = 0; i < group_info->nblocks; i++) | ||
| 58 | free_page((unsigned long)group_info->blocks[i]); | ||
| 59 | } | ||
| 60 | kfree(group_info); | ||
| 61 | } | ||
| 62 | |||
| 63 | EXPORT_SYMBOL(groups_free); | ||
| 64 | |||
| 65 | /* export the group_info to a user-space array */ | ||
| 66 | static int groups_to_user(gid_t __user *grouplist, | ||
| 67 | const struct group_info *group_info) | ||
| 68 | { | ||
| 69 | int i; | ||
| 70 | unsigned int count = group_info->ngroups; | ||
| 71 | |||
| 72 | for (i = 0; i < group_info->nblocks; i++) { | ||
| 73 | unsigned int cp_count = min(NGROUPS_PER_BLOCK, count); | ||
| 74 | unsigned int len = cp_count * sizeof(*grouplist); | ||
| 75 | |||
| 76 | if (copy_to_user(grouplist, group_info->blocks[i], len)) | ||
| 77 | return -EFAULT; | ||
| 78 | |||
| 79 | grouplist += NGROUPS_PER_BLOCK; | ||
| 80 | count -= cp_count; | ||
| 81 | } | ||
| 82 | return 0; | ||
| 83 | } | ||
| 84 | |||
| 85 | /* fill a group_info from a user-space array - it must be allocated already */ | ||
| 86 | static int groups_from_user(struct group_info *group_info, | ||
| 87 | gid_t __user *grouplist) | ||
| 88 | { | ||
| 89 | int i; | ||
| 90 | unsigned int count = group_info->ngroups; | ||
| 91 | |||
| 92 | for (i = 0; i < group_info->nblocks; i++) { | ||
| 93 | unsigned int cp_count = min(NGROUPS_PER_BLOCK, count); | ||
| 94 | unsigned int len = cp_count * sizeof(*grouplist); | ||
| 95 | |||
| 96 | if (copy_from_user(group_info->blocks[i], grouplist, len)) | ||
| 97 | return -EFAULT; | ||
| 98 | |||
| 99 | grouplist += NGROUPS_PER_BLOCK; | ||
| 100 | count -= cp_count; | ||
| 101 | } | ||
| 102 | return 0; | ||
| 103 | } | ||
| 104 | |||
| 105 | /* a simple Shell sort */ | ||
| 106 | static void groups_sort(struct group_info *group_info) | ||
| 107 | { | ||
| 108 | int base, max, stride; | ||
| 109 | int gidsetsize = group_info->ngroups; | ||
| 110 | |||
| 111 | for (stride = 1; stride < gidsetsize; stride = 3 * stride + 1) | ||
| 112 | ; /* nothing */ | ||
| 113 | stride /= 3; | ||
| 114 | |||
| 115 | while (stride) { | ||
| 116 | max = gidsetsize - stride; | ||
| 117 | for (base = 0; base < max; base++) { | ||
| 118 | int left = base; | ||
| 119 | int right = left + stride; | ||
| 120 | gid_t tmp = GROUP_AT(group_info, right); | ||
| 121 | |||
| 122 | while (left >= 0 && GROUP_AT(group_info, left) > tmp) { | ||
| 123 | GROUP_AT(group_info, right) = | ||
| 124 | GROUP_AT(group_info, left); | ||
| 125 | right = left; | ||
| 126 | left -= stride; | ||
| 127 | } | ||
| 128 | GROUP_AT(group_info, right) = tmp; | ||
| 129 | } | ||
| 130 | stride /= 3; | ||
| 131 | } | ||
| 132 | } | ||
| 133 | |||
| 134 | /* a simple bsearch */ | ||
| 135 | int groups_search(const struct group_info *group_info, gid_t grp) | ||
| 136 | { | ||
| 137 | unsigned int left, right; | ||
| 138 | |||
| 139 | if (!group_info) | ||
| 140 | return 0; | ||
| 141 | |||
| 142 | left = 0; | ||
| 143 | right = group_info->ngroups; | ||
| 144 | while (left < right) { | ||
| 145 | unsigned int mid = (left+right)/2; | ||
| 146 | int cmp = grp - GROUP_AT(group_info, mid); | ||
| 147 | if (cmp > 0) | ||
| 148 | left = mid + 1; | ||
| 149 | else if (cmp < 0) | ||
| 150 | right = mid; | ||
| 151 | else | ||
| 152 | return 1; | ||
| 153 | } | ||
| 154 | return 0; | ||
| 155 | } | ||
| 156 | |||
| 157 | /** | ||
| 158 | * set_groups - Change a group subscription in a set of credentials | ||
| 159 | * @new: The newly prepared set of credentials to alter | ||
| 160 | * @group_info: The group list to install | ||
| 161 | * | ||
| 162 | * Validate a group subscription and, if valid, insert it into a set | ||
| 163 | * of credentials. | ||
| 164 | */ | ||
| 165 | int set_groups(struct cred *new, struct group_info *group_info) | ||
| 166 | { | ||
| 167 | int retval; | ||
| 168 | |||
| 169 | retval = security_task_setgroups(group_info); | ||
| 170 | if (retval) | ||
| 171 | return retval; | ||
| 172 | |||
| 173 | put_group_info(new->group_info); | ||
| 174 | groups_sort(group_info); | ||
| 175 | get_group_info(group_info); | ||
| 176 | new->group_info = group_info; | ||
| 177 | return 0; | ||
| 178 | } | ||
| 179 | |||
| 180 | EXPORT_SYMBOL(set_groups); | ||
| 181 | |||
| 182 | /** | ||
| 183 | * set_current_groups - Change current's group subscription | ||
| 184 | * @group_info: The group list to impose | ||
| 185 | * | ||
| 186 | * Validate a group subscription and, if valid, impose it upon current's task | ||
| 187 | * security record. | ||
| 188 | */ | ||
| 189 | int set_current_groups(struct group_info *group_info) | ||
| 190 | { | ||
| 191 | struct cred *new; | ||
| 192 | int ret; | ||
| 193 | |||
| 194 | new = prepare_creds(); | ||
| 195 | if (!new) | ||
| 196 | return -ENOMEM; | ||
| 197 | |||
| 198 | ret = set_groups(new, group_info); | ||
| 199 | if (ret < 0) { | ||
| 200 | abort_creds(new); | ||
| 201 | return ret; | ||
| 202 | } | ||
| 203 | |||
| 204 | return commit_creds(new); | ||
| 205 | } | ||
| 206 | |||
| 207 | EXPORT_SYMBOL(set_current_groups); | ||
| 208 | |||
| 209 | SYSCALL_DEFINE2(getgroups, int, gidsetsize, gid_t __user *, grouplist) | ||
| 210 | { | ||
| 211 | const struct cred *cred = current_cred(); | ||
| 212 | int i; | ||
| 213 | |||
| 214 | if (gidsetsize < 0) | ||
| 215 | return -EINVAL; | ||
| 216 | |||
| 217 | /* no need to grab task_lock here; it cannot change */ | ||
| 218 | i = cred->group_info->ngroups; | ||
| 219 | if (gidsetsize) { | ||
| 220 | if (i > gidsetsize) { | ||
| 221 | i = -EINVAL; | ||
| 222 | goto out; | ||
| 223 | } | ||
| 224 | if (groups_to_user(grouplist, cred->group_info)) { | ||
| 225 | i = -EFAULT; | ||
| 226 | goto out; | ||
| 227 | } | ||
| 228 | } | ||
| 229 | out: | ||
| 230 | return i; | ||
| 231 | } | ||
| 232 | |||
| 233 | /* | ||
| 234 | * SMP: Our groups are copy-on-write. We can set them safely | ||
| 235 | * without another task interfering. | ||
| 236 | */ | ||
| 237 | |||
| 238 | SYSCALL_DEFINE2(setgroups, int, gidsetsize, gid_t __user *, grouplist) | ||
| 239 | { | ||
| 240 | struct group_info *group_info; | ||
| 241 | int retval; | ||
| 242 | |||
| 243 | if (!capable(CAP_SETGID)) | ||
| 244 | return -EPERM; | ||
| 245 | if ((unsigned)gidsetsize > NGROUPS_MAX) | ||
| 246 | return -EINVAL; | ||
| 247 | |||
| 248 | group_info = groups_alloc(gidsetsize); | ||
| 249 | if (!group_info) | ||
| 250 | return -ENOMEM; | ||
| 251 | retval = groups_from_user(group_info, grouplist); | ||
| 252 | if (retval) { | ||
| 253 | put_group_info(group_info); | ||
| 254 | return retval; | ||
| 255 | } | ||
| 256 | |||
| 257 | retval = set_current_groups(group_info); | ||
| 258 | put_group_info(group_info); | ||
| 259 | |||
| 260 | return retval; | ||
| 261 | } | ||
| 262 | |||
| 263 | /* | ||
| 264 | * Check whether we're fsgid/egid or in the supplemental group.. | ||
| 265 | */ | ||
| 266 | int in_group_p(gid_t grp) | ||
| 267 | { | ||
| 268 | const struct cred *cred = current_cred(); | ||
| 269 | int retval = 1; | ||
| 270 | |||
| 271 | if (grp != cred->fsgid) | ||
| 272 | retval = groups_search(cred->group_info, grp); | ||
| 273 | return retval; | ||
| 274 | } | ||
| 275 | |||
| 276 | EXPORT_SYMBOL(in_group_p); | ||
| 277 | |||
| 278 | int in_egroup_p(gid_t grp) | ||
| 279 | { | ||
| 280 | const struct cred *cred = current_cred(); | ||
| 281 | int retval = 1; | ||
| 282 | |||
| 283 | if (grp != cred->egid) | ||
| 284 | retval = groups_search(cred->group_info, grp); | ||
| 285 | return retval; | ||
| 286 | } | ||
| 287 | |||
| 288 | EXPORT_SYMBOL(in_egroup_p); | ||
diff --git a/kernel/kfifo.c b/kernel/kfifo.c index bc41ad0f24f8..26539e3228e5 100644 --- a/kernel/kfifo.c +++ b/kernel/kfifo.c | |||
| @@ -72,9 +72,9 @@ struct kfifo *kfifo_alloc(unsigned int size, gfp_t gfp_mask, spinlock_t *lock) | |||
| 72 | 72 | ||
| 73 | /* | 73 | /* |
| 74 | * round up to the next power of 2, since our 'let the indices | 74 | * round up to the next power of 2, since our 'let the indices |
| 75 | * wrap' tachnique works only in this case. | 75 | * wrap' technique works only in this case. |
| 76 | */ | 76 | */ |
| 77 | if (size & (size - 1)) { | 77 | if (!is_power_of_2(size)) { |
| 78 | BUG_ON(size > 0x80000000); | 78 | BUG_ON(size > 0x80000000); |
| 79 | size = roundup_pow_of_two(size); | 79 | size = roundup_pow_of_two(size); |
| 80 | } | 80 | } |
diff --git a/kernel/kthread.c b/kernel/kthread.c index 41c88fe40500..7fa441333529 100644 --- a/kernel/kthread.c +++ b/kernel/kthread.c | |||
| @@ -9,6 +9,7 @@ | |||
| 9 | #include <linux/kthread.h> | 9 | #include <linux/kthread.h> |
| 10 | #include <linux/completion.h> | 10 | #include <linux/completion.h> |
| 11 | #include <linux/err.h> | 11 | #include <linux/err.h> |
| 12 | #include <linux/cpuset.h> | ||
| 12 | #include <linux/unistd.h> | 13 | #include <linux/unistd.h> |
| 13 | #include <linux/file.h> | 14 | #include <linux/file.h> |
| 14 | #include <linux/module.h> | 15 | #include <linux/module.h> |
| @@ -236,6 +237,7 @@ int kthreadd(void *unused) | |||
| 236 | ignore_signals(tsk); | 237 | ignore_signals(tsk); |
| 237 | set_user_nice(tsk, KTHREAD_NICE_LEVEL); | 238 | set_user_nice(tsk, KTHREAD_NICE_LEVEL); |
| 238 | set_cpus_allowed_ptr(tsk, cpu_all_mask); | 239 | set_cpus_allowed_ptr(tsk, cpu_all_mask); |
| 240 | set_mems_allowed(node_possible_map); | ||
| 239 | 241 | ||
| 240 | current->flags |= PF_NOFREEZE | PF_FREEZER_NOSIG; | 242 | current->flags |= PF_NOFREEZE | PF_FREEZER_NOSIG; |
| 241 | 243 | ||
diff --git a/kernel/power/process.c b/kernel/power/process.c index ca634019497a..da2072d73811 100644 --- a/kernel/power/process.c +++ b/kernel/power/process.c | |||
| @@ -117,9 +117,12 @@ int freeze_processes(void) | |||
| 117 | if (error) | 117 | if (error) |
| 118 | goto Exit; | 118 | goto Exit; |
| 119 | printk("done."); | 119 | printk("done."); |
| 120 | |||
| 121 | oom_killer_disable(); | ||
| 120 | Exit: | 122 | Exit: |
| 121 | BUG_ON(in_atomic()); | 123 | BUG_ON(in_atomic()); |
| 122 | printk("\n"); | 124 | printk("\n"); |
| 125 | |||
| 123 | return error; | 126 | return error; |
| 124 | } | 127 | } |
| 125 | 128 | ||
| @@ -145,6 +148,8 @@ static void thaw_tasks(bool nosig_only) | |||
| 145 | 148 | ||
| 146 | void thaw_processes(void) | 149 | void thaw_processes(void) |
| 147 | { | 150 | { |
| 151 | oom_killer_enable(); | ||
| 152 | |||
| 148 | printk("Restarting tasks ... "); | 153 | printk("Restarting tasks ... "); |
| 149 | thaw_tasks(true); | 154 | thaw_tasks(true); |
| 150 | thaw_tasks(false); | 155 | thaw_tasks(false); |
diff --git a/kernel/profile.c b/kernel/profile.c index 28cf26ad2d24..69911b5745eb 100644 --- a/kernel/profile.c +++ b/kernel/profile.c | |||
| @@ -365,7 +365,7 @@ static int __cpuinit profile_cpu_callback(struct notifier_block *info, | |||
| 365 | node = cpu_to_node(cpu); | 365 | node = cpu_to_node(cpu); |
| 366 | per_cpu(cpu_profile_flip, cpu) = 0; | 366 | per_cpu(cpu_profile_flip, cpu) = 0; |
| 367 | if (!per_cpu(cpu_profile_hits, cpu)[1]) { | 367 | if (!per_cpu(cpu_profile_hits, cpu)[1]) { |
| 368 | page = alloc_pages_node(node, | 368 | page = alloc_pages_exact_node(node, |
| 369 | GFP_KERNEL | __GFP_ZERO, | 369 | GFP_KERNEL | __GFP_ZERO, |
| 370 | 0); | 370 | 0); |
| 371 | if (!page) | 371 | if (!page) |
| @@ -373,7 +373,7 @@ static int __cpuinit profile_cpu_callback(struct notifier_block *info, | |||
| 373 | per_cpu(cpu_profile_hits, cpu)[1] = page_address(page); | 373 | per_cpu(cpu_profile_hits, cpu)[1] = page_address(page); |
| 374 | } | 374 | } |
| 375 | if (!per_cpu(cpu_profile_hits, cpu)[0]) { | 375 | if (!per_cpu(cpu_profile_hits, cpu)[0]) { |
| 376 | page = alloc_pages_node(node, | 376 | page = alloc_pages_exact_node(node, |
| 377 | GFP_KERNEL | __GFP_ZERO, | 377 | GFP_KERNEL | __GFP_ZERO, |
| 378 | 0); | 378 | 0); |
| 379 | if (!page) | 379 | if (!page) |
| @@ -564,14 +564,14 @@ static int create_hash_tables(void) | |||
| 564 | int node = cpu_to_node(cpu); | 564 | int node = cpu_to_node(cpu); |
| 565 | struct page *page; | 565 | struct page *page; |
| 566 | 566 | ||
| 567 | page = alloc_pages_node(node, | 567 | page = alloc_pages_exact_node(node, |
| 568 | GFP_KERNEL | __GFP_ZERO | GFP_THISNODE, | 568 | GFP_KERNEL | __GFP_ZERO | GFP_THISNODE, |
| 569 | 0); | 569 | 0); |
| 570 | if (!page) | 570 | if (!page) |
| 571 | goto out_cleanup; | 571 | goto out_cleanup; |
| 572 | per_cpu(cpu_profile_hits, cpu)[1] | 572 | per_cpu(cpu_profile_hits, cpu)[1] |
| 573 | = (struct profile_hit *)page_address(page); | 573 | = (struct profile_hit *)page_address(page); |
| 574 | page = alloc_pages_node(node, | 574 | page = alloc_pages_exact_node(node, |
| 575 | GFP_KERNEL | __GFP_ZERO | GFP_THISNODE, | 575 | GFP_KERNEL | __GFP_ZERO | GFP_THISNODE, |
| 576 | 0); | 576 | 0); |
| 577 | if (!page) | 577 | if (!page) |
diff --git a/kernel/slow-work.c b/kernel/slow-work.c index 521ed2004d63..09d7519557d3 100644 --- a/kernel/slow-work.c +++ b/kernel/slow-work.c | |||
| @@ -319,6 +319,15 @@ cant_get_ref: | |||
| 319 | EXPORT_SYMBOL(slow_work_enqueue); | 319 | EXPORT_SYMBOL(slow_work_enqueue); |
| 320 | 320 | ||
| 321 | /* | 321 | /* |
| 322 | * Schedule a cull of the thread pool at some time in the near future | ||
| 323 | */ | ||
| 324 | static void slow_work_schedule_cull(void) | ||
| 325 | { | ||
| 326 | mod_timer(&slow_work_cull_timer, | ||
| 327 | round_jiffies(jiffies + SLOW_WORK_CULL_TIMEOUT)); | ||
| 328 | } | ||
| 329 | |||
| 330 | /* | ||
| 322 | * Worker thread culling algorithm | 331 | * Worker thread culling algorithm |
| 323 | */ | 332 | */ |
| 324 | static bool slow_work_cull_thread(void) | 333 | static bool slow_work_cull_thread(void) |
| @@ -335,8 +344,7 @@ static bool slow_work_cull_thread(void) | |||
| 335 | list_empty(&vslow_work_queue) && | 344 | list_empty(&vslow_work_queue) && |
| 336 | atomic_read(&slow_work_thread_count) > | 345 | atomic_read(&slow_work_thread_count) > |
| 337 | slow_work_min_threads) { | 346 | slow_work_min_threads) { |
| 338 | mod_timer(&slow_work_cull_timer, | 347 | slow_work_schedule_cull(); |
| 339 | jiffies + SLOW_WORK_CULL_TIMEOUT); | ||
| 340 | do_cull = true; | 348 | do_cull = true; |
| 341 | } | 349 | } |
| 342 | } | 350 | } |
| @@ -393,8 +401,7 @@ static int slow_work_thread(void *_data) | |||
| 393 | list_empty(&vslow_work_queue) && | 401 | list_empty(&vslow_work_queue) && |
| 394 | atomic_read(&slow_work_thread_count) > | 402 | atomic_read(&slow_work_thread_count) > |
| 395 | slow_work_min_threads) | 403 | slow_work_min_threads) |
| 396 | mod_timer(&slow_work_cull_timer, | 404 | slow_work_schedule_cull(); |
| 397 | jiffies + SLOW_WORK_CULL_TIMEOUT); | ||
| 398 | continue; | 405 | continue; |
| 399 | } | 406 | } |
| 400 | 407 | ||
| @@ -458,7 +465,7 @@ static void slow_work_new_thread_execute(struct slow_work *work) | |||
| 458 | if (atomic_dec_and_test(&slow_work_thread_count)) | 465 | if (atomic_dec_and_test(&slow_work_thread_count)) |
| 459 | BUG(); /* we're running on a slow work thread... */ | 466 | BUG(); /* we're running on a slow work thread... */ |
| 460 | mod_timer(&slow_work_oom_timer, | 467 | mod_timer(&slow_work_oom_timer, |
| 461 | jiffies + SLOW_WORK_OOM_TIMEOUT); | 468 | round_jiffies(jiffies + SLOW_WORK_OOM_TIMEOUT)); |
| 462 | } else { | 469 | } else { |
| 463 | /* ratelimit the starting of new threads */ | 470 | /* ratelimit the starting of new threads */ |
| 464 | mod_timer(&slow_work_oom_timer, jiffies + 1); | 471 | mod_timer(&slow_work_oom_timer, jiffies + 1); |
| @@ -502,8 +509,7 @@ static int slow_work_min_threads_sysctl(struct ctl_table *table, int write, | |||
| 502 | if (n < 0 && !slow_work_may_not_start_new_thread) | 509 | if (n < 0 && !slow_work_may_not_start_new_thread) |
| 503 | slow_work_enqueue(&slow_work_new_thread); | 510 | slow_work_enqueue(&slow_work_new_thread); |
| 504 | else if (n > 0) | 511 | else if (n > 0) |
| 505 | mod_timer(&slow_work_cull_timer, | 512 | slow_work_schedule_cull(); |
| 506 | jiffies + SLOW_WORK_CULL_TIMEOUT); | ||
| 507 | } | 513 | } |
| 508 | mutex_unlock(&slow_work_user_lock); | 514 | mutex_unlock(&slow_work_user_lock); |
| 509 | } | 515 | } |
| @@ -529,8 +535,7 @@ static int slow_work_max_threads_sysctl(struct ctl_table *table, int write, | |||
| 529 | atomic_read(&slow_work_thread_count); | 535 | atomic_read(&slow_work_thread_count); |
| 530 | 536 | ||
| 531 | if (n < 0) | 537 | if (n < 0) |
| 532 | mod_timer(&slow_work_cull_timer, | 538 | slow_work_schedule_cull(); |
| 533 | jiffies + SLOW_WORK_CULL_TIMEOUT); | ||
| 534 | } | 539 | } |
| 535 | mutex_unlock(&slow_work_user_lock); | 540 | mutex_unlock(&slow_work_user_lock); |
| 536 | } | 541 | } |
diff --git a/kernel/sys.c b/kernel/sys.c index 438d99a38c87..b3f1097c76fa 100644 --- a/kernel/sys.c +++ b/kernel/sys.c | |||
| @@ -1113,289 +1113,6 @@ out: | |||
| 1113 | return err; | 1113 | return err; |
| 1114 | } | 1114 | } |
| 1115 | 1115 | ||
| 1116 | /* | ||
| 1117 | * Supplementary group IDs | ||
| 1118 | */ | ||
| 1119 | |||
| 1120 | /* init to 2 - one for init_task, one to ensure it is never freed */ | ||
| 1121 | struct group_info init_groups = { .usage = ATOMIC_INIT(2) }; | ||
| 1122 | |||
| 1123 | struct group_info *groups_alloc(int gidsetsize) | ||
| 1124 | { | ||
| 1125 | struct group_info *group_info; | ||
| 1126 | int nblocks; | ||
| 1127 | int i; | ||
| 1128 | |||
| 1129 | nblocks = (gidsetsize + NGROUPS_PER_BLOCK - 1) / NGROUPS_PER_BLOCK; | ||
| 1130 | /* Make sure we always allocate at least one indirect block pointer */ | ||
| 1131 | nblocks = nblocks ? : 1; | ||
| 1132 | group_info = kmalloc(sizeof(*group_info) + nblocks*sizeof(gid_t *), GFP_USER); | ||
| 1133 | if (!group_info) | ||
| 1134 | return NULL; | ||
| 1135 | group_info->ngroups = gidsetsize; | ||
| 1136 | group_info->nblocks = nblocks; | ||
| 1137 | atomic_set(&group_info->usage, 1); | ||
| 1138 | |||
| 1139 | if (gidsetsize <= NGROUPS_SMALL) | ||
| 1140 | group_info->blocks[0] = group_info->small_block; | ||
| 1141 | else { | ||
| 1142 | for (i = 0; i < nblocks; i++) { | ||
| 1143 | gid_t *b; | ||
| 1144 | b = (void *)__get_free_page(GFP_USER); | ||
| 1145 | if (!b) | ||
| 1146 | goto out_undo_partial_alloc; | ||
| 1147 | group_info->blocks[i] = b; | ||
| 1148 | } | ||
| 1149 | } | ||
| 1150 | return group_info; | ||
| 1151 | |||
| 1152 | out_undo_partial_alloc: | ||
| 1153 | while (--i >= 0) { | ||
| 1154 | free_page((unsigned long)group_info->blocks[i]); | ||
| 1155 | } | ||
| 1156 | kfree(group_info); | ||
| 1157 | return NULL; | ||
| 1158 | } | ||
| 1159 | |||
| 1160 | EXPORT_SYMBOL(groups_alloc); | ||
| 1161 | |||
| 1162 | void groups_free(struct group_info *group_info) | ||
| 1163 | { | ||
| 1164 | if (group_info->blocks[0] != group_info->small_block) { | ||
| 1165 | int i; | ||
| 1166 | for (i = 0; i < group_info->nblocks; i++) | ||
| 1167 | free_page((unsigned long)group_info->blocks[i]); | ||
| 1168 | } | ||
| 1169 | kfree(group_info); | ||
| 1170 | } | ||
| 1171 | |||
| 1172 | EXPORT_SYMBOL(groups_free); | ||
| 1173 | |||
| 1174 | /* export the group_info to a user-space array */ | ||
| 1175 | static int groups_to_user(gid_t __user *grouplist, | ||
| 1176 | const struct group_info *group_info) | ||
| 1177 | { | ||
| 1178 | int i; | ||
| 1179 | unsigned int count = group_info->ngroups; | ||
| 1180 | |||
| 1181 | for (i = 0; i < group_info->nblocks; i++) { | ||
| 1182 | unsigned int cp_count = min(NGROUPS_PER_BLOCK, count); | ||
| 1183 | unsigned int len = cp_count * sizeof(*grouplist); | ||
| 1184 | |||
| 1185 | if (copy_to_user(grouplist, group_info->blocks[i], len)) | ||
| 1186 | return -EFAULT; | ||
| 1187 | |||
| 1188 | grouplist += NGROUPS_PER_BLOCK; | ||
| 1189 | count -= cp_count; | ||
| 1190 | } | ||
| 1191 | return 0; | ||
| 1192 | } | ||
| 1193 | |||
| 1194 | /* fill a group_info from a user-space array - it must be allocated already */ | ||
| 1195 | static int groups_from_user(struct group_info *group_info, | ||
| 1196 | gid_t __user *grouplist) | ||
| 1197 | { | ||
| 1198 | int i; | ||
| 1199 | unsigned int count = group_info->ngroups; | ||
| 1200 | |||
| 1201 | for (i = 0; i < group_info->nblocks; i++) { | ||
| 1202 | unsigned int cp_count = min(NGROUPS_PER_BLOCK, count); | ||
| 1203 | unsigned int len = cp_count * sizeof(*grouplist); | ||
| 1204 | |||
| 1205 | if (copy_from_user(group_info->blocks[i], grouplist, len)) | ||
| 1206 | return -EFAULT; | ||
| 1207 | |||
| 1208 | grouplist += NGROUPS_PER_BLOCK; | ||
| 1209 | count -= cp_count; | ||
| 1210 | } | ||
| 1211 | return 0; | ||
| 1212 | } | ||
| 1213 | |||
| 1214 | /* a simple Shell sort */ | ||
| 1215 | static void groups_sort(struct group_info *group_info) | ||
| 1216 | { | ||
| 1217 | int base, max, stride; | ||
| 1218 | int gidsetsize = group_info->ngroups; | ||
| 1219 | |||
| 1220 | for (stride = 1; stride < gidsetsize; stride = 3 * stride + 1) | ||
| 1221 | ; /* nothing */ | ||
| 1222 | stride /= 3; | ||
| 1223 | |||
| 1224 | while (stride) { | ||
| 1225 | max = gidsetsize - stride; | ||
| 1226 | for (base = 0; base < max; base++) { | ||
| 1227 | int left = base; | ||
| 1228 | int right = left + stride; | ||
| 1229 | gid_t tmp = GROUP_AT(group_info, right); | ||
| 1230 | |||
| 1231 | while (left >= 0 && GROUP_AT(group_info, left) > tmp) { | ||
| 1232 | GROUP_AT(group_info, right) = | ||
| 1233 | GROUP_AT(group_info, left); | ||
| 1234 | right = left; | ||
| 1235 | left -= stride; | ||
| 1236 | } | ||
| 1237 | GROUP_AT(group_info, right) = tmp; | ||
| 1238 | } | ||
| 1239 | stride /= 3; | ||
| 1240 | } | ||
| 1241 | } | ||
| 1242 | |||
| 1243 | /* a simple bsearch */ | ||
| 1244 | int groups_search(const struct group_info *group_info, gid_t grp) | ||
| 1245 | { | ||
| 1246 | unsigned int left, right; | ||
| 1247 | |||
| 1248 | if (!group_info) | ||
| 1249 | return 0; | ||
| 1250 | |||
| 1251 | left = 0; | ||
| 1252 | right = group_info->ngroups; | ||
| 1253 | while (left < right) { | ||
| 1254 | unsigned int mid = (left+right)/2; | ||
| 1255 | int cmp = grp - GROUP_AT(group_info, mid); | ||
| 1256 | if (cmp > 0) | ||
| 1257 | left = mid + 1; | ||
| 1258 | else if (cmp < 0) | ||
| 1259 | right = mid; | ||
| 1260 | else | ||
| 1261 | return 1; | ||
| 1262 | } | ||
| 1263 | return 0; | ||
| 1264 | } | ||
| 1265 | |||
| 1266 | /** | ||
| 1267 | * set_groups - Change a group subscription in a set of credentials | ||
| 1268 | * @new: The newly prepared set of credentials to alter | ||
| 1269 | * @group_info: The group list to install | ||
| 1270 | * | ||
| 1271 | * Validate a group subscription and, if valid, insert it into a set | ||
| 1272 | * of credentials. | ||
| 1273 | */ | ||
| 1274 | int set_groups(struct cred *new, struct group_info *group_info) | ||
| 1275 | { | ||
| 1276 | int retval; | ||
| 1277 | |||
| 1278 | retval = security_task_setgroups(group_info); | ||
| 1279 | if (retval) | ||
| 1280 | return retval; | ||
| 1281 | |||
| 1282 | put_group_info(new->group_info); | ||
| 1283 | groups_sort(group_info); | ||
| 1284 | get_group_info(group_info); | ||
| 1285 | new->group_info = group_info; | ||
| 1286 | return 0; | ||
| 1287 | } | ||
| 1288 | |||
| 1289 | EXPORT_SYMBOL(set_groups); | ||
| 1290 | |||
| 1291 | /** | ||
| 1292 | * set_current_groups - Change current's group subscription | ||
| 1293 | * @group_info: The group list to impose | ||
| 1294 | * | ||
| 1295 | * Validate a group subscription and, if valid, impose it upon current's task | ||
| 1296 | * security record. | ||
| 1297 | */ | ||
| 1298 | int set_current_groups(struct group_info *group_info) | ||
| 1299 | { | ||
| 1300 | struct cred *new; | ||
| 1301 | int ret; | ||
| 1302 | |||
| 1303 | new = prepare_creds(); | ||
| 1304 | if (!new) | ||
| 1305 | return -ENOMEM; | ||
| 1306 | |||
| 1307 | ret = set_groups(new, group_info); | ||
| 1308 | if (ret < 0) { | ||
| 1309 | abort_creds(new); | ||
| 1310 | return ret; | ||
| 1311 | } | ||
| 1312 | |||
| 1313 | return commit_creds(new); | ||
| 1314 | } | ||
| 1315 | |||
| 1316 | EXPORT_SYMBOL(set_current_groups); | ||
| 1317 | |||
| 1318 | SYSCALL_DEFINE2(getgroups, int, gidsetsize, gid_t __user *, grouplist) | ||
| 1319 | { | ||
| 1320 | const struct cred *cred = current_cred(); | ||
| 1321 | int i; | ||
| 1322 | |||
| 1323 | if (gidsetsize < 0) | ||
| 1324 | return -EINVAL; | ||
| 1325 | |||
| 1326 | /* no need to grab task_lock here; it cannot change */ | ||
| 1327 | i = cred->group_info->ngroups; | ||
| 1328 | if (gidsetsize) { | ||
| 1329 | if (i > gidsetsize) { | ||
| 1330 | i = -EINVAL; | ||
| 1331 | goto out; | ||
| 1332 | } | ||
| 1333 | if (groups_to_user(grouplist, cred->group_info)) { | ||
| 1334 | i = -EFAULT; | ||
| 1335 | goto out; | ||
| 1336 | } | ||
| 1337 | } | ||
| 1338 | out: | ||
| 1339 | return i; | ||
| 1340 | } | ||
| 1341 | |||
| 1342 | /* | ||
| 1343 | * SMP: Our groups are copy-on-write. We can set them safely | ||
| 1344 | * without another task interfering. | ||
| 1345 | */ | ||
| 1346 | |||
| 1347 | SYSCALL_DEFINE2(setgroups, int, gidsetsize, gid_t __user *, grouplist) | ||
| 1348 | { | ||
| 1349 | struct group_info *group_info; | ||
| 1350 | int retval; | ||
| 1351 | |||
| 1352 | if (!capable(CAP_SETGID)) | ||
| 1353 | return -EPERM; | ||
| 1354 | if ((unsigned)gidsetsize > NGROUPS_MAX) | ||
| 1355 | return -EINVAL; | ||
| 1356 | |||
| 1357 | group_info = groups_alloc(gidsetsize); | ||
| 1358 | if (!group_info) | ||
| 1359 | return -ENOMEM; | ||
| 1360 | retval = groups_from_user(group_info, grouplist); | ||
| 1361 | if (retval) { | ||
| 1362 | put_group_info(group_info); | ||
| 1363 | return retval; | ||
| 1364 | } | ||
| 1365 | |||
| 1366 | retval = set_current_groups(group_info); | ||
| 1367 | put_group_info(group_info); | ||
| 1368 | |||
| 1369 | return retval; | ||
| 1370 | } | ||
| 1371 | |||
| 1372 | /* | ||
| 1373 | * Check whether we're fsgid/egid or in the supplemental group.. | ||
| 1374 | */ | ||
| 1375 | int in_group_p(gid_t grp) | ||
| 1376 | { | ||
| 1377 | const struct cred *cred = current_cred(); | ||
| 1378 | int retval = 1; | ||
| 1379 | |||
| 1380 | if (grp != cred->fsgid) | ||
| 1381 | retval = groups_search(cred->group_info, grp); | ||
| 1382 | return retval; | ||
| 1383 | } | ||
| 1384 | |||
| 1385 | EXPORT_SYMBOL(in_group_p); | ||
| 1386 | |||
| 1387 | int in_egroup_p(gid_t grp) | ||
| 1388 | { | ||
| 1389 | const struct cred *cred = current_cred(); | ||
| 1390 | int retval = 1; | ||
| 1391 | |||
| 1392 | if (grp != cred->egid) | ||
| 1393 | retval = groups_search(cred->group_info, grp); | ||
| 1394 | return retval; | ||
| 1395 | } | ||
| 1396 | |||
| 1397 | EXPORT_SYMBOL(in_egroup_p); | ||
| 1398 | |||
| 1399 | DECLARE_RWSEM(uts_sem); | 1116 | DECLARE_RWSEM(uts_sem); |
| 1400 | 1117 | ||
| 1401 | SYSCALL_DEFINE1(newuname, struct new_utsname __user *, name) | 1118 | SYSCALL_DEFINE1(newuname, struct new_utsname __user *, name) |
diff --git a/kernel/sysctl.c b/kernel/sysctl.c index f5c76b6cd616..ab462b9968d5 100644 --- a/kernel/sysctl.c +++ b/kernel/sysctl.c | |||
| @@ -1337,7 +1337,6 @@ static struct ctl_table vm_table[] = { | |||
| 1337 | .extra2 = &one, | 1337 | .extra2 = &one, |
| 1338 | }, | 1338 | }, |
| 1339 | #endif | 1339 | #endif |
| 1340 | #ifdef CONFIG_UNEVICTABLE_LRU | ||
| 1341 | { | 1340 | { |
| 1342 | .ctl_name = CTL_UNNUMBERED, | 1341 | .ctl_name = CTL_UNNUMBERED, |
| 1343 | .procname = "scan_unevictable_pages", | 1342 | .procname = "scan_unevictable_pages", |
| @@ -1346,7 +1345,6 @@ static struct ctl_table vm_table[] = { | |||
| 1346 | .mode = 0644, | 1345 | .mode = 0644, |
| 1347 | .proc_handler = &scan_unevictable_handler, | 1346 | .proc_handler = &scan_unevictable_handler, |
| 1348 | }, | 1347 | }, |
| 1349 | #endif | ||
| 1350 | /* | 1348 | /* |
| 1351 | * NOTE: do not add new entries to this table unless you have read | 1349 | * NOTE: do not add new entries to this table unless you have read |
| 1352 | * Documentation/sysctl/ctl_unnumbered.txt | 1350 | * Documentation/sysctl/ctl_unnumbered.txt |
