oom_kill.c 22.2 KB
Newer Older
L
Linus Torvalds 已提交
1 2 3 4 5 6
/*
 *  linux/mm/oom_kill.c
 * 
 *  Copyright (C)  1998,2000  Rik van Riel
 *	Thanks go out to Claus Fischer for some serious inspiration and
 *	for goading me into coding this file...
D
David Rientjes 已提交
7 8
 *  Copyright (C)  2010  Google, Inc.
 *	Rewritten by David Rientjes
L
Linus Torvalds 已提交
9 10
 *
 *  The routines in this file are used to kill a process when
P
Paul Jackson 已提交
11 12
 *  we're seriously out of memory. This gets called from __alloc_pages()
 *  in mm/page_alloc.c when we really run out of memory.
L
Linus Torvalds 已提交
13 14 15 16 17 18 19
 *
 *  Since we won't call these routines often (on a well-configured
 *  machine) this file will double as a 'coding guide' and a signpost
 *  for newbie kernel hackers. It features several pointers to major
 *  kernel subsystems and hints as to where to find out what things do.
 */

20
#include <linux/oom.h>
L
Linus Torvalds 已提交
21
#include <linux/mm.h>
A
Alexey Dobriyan 已提交
22
#include <linux/err.h>
23
#include <linux/gfp.h>
L
Linus Torvalds 已提交
24 25 26 27
#include <linux/sched.h>
#include <linux/swap.h>
#include <linux/timex.h>
#include <linux/jiffies.h>
28
#include <linux/cpuset.h>
29
#include <linux/export.h>
30
#include <linux/notifier.h>
31
#include <linux/memcontrol.h>
32
#include <linux/mempolicy.h>
33
#include <linux/security.h>
34
#include <linux/ptrace.h>
35
#include <linux/freezer.h>
36 37 38 39
#include <linux/ftrace.h>

#define CREATE_TRACE_POINTS
#include <trace/events/oom.h>
L
Linus Torvalds 已提交
40

41
int sysctl_panic_on_oom;
42
int sysctl_oom_kill_allocating_task;
43
int sysctl_oom_dump_tasks = 1;
D
David Rientjes 已提交
44
static DEFINE_SPINLOCK(zone_scan_lock);
L
Linus Torvalds 已提交
45

46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61
/*
 * compare_swap_oom_score_adj() - compare and swap current's oom_score_adj
 * @old_val: old oom_score_adj for compare
 * @new_val: new oom_score_adj for swap
 *
 * Sets the oom_score_adj value for current to @new_val iff its present value is
 * @old_val.  Usually used to reinstate a previous value to prevent racing with
 * userspacing tuning the value in the interim.
 */
void compare_swap_oom_score_adj(int old_val, int new_val)
{
	struct sighand_struct *sighand = current->sighand;

	spin_lock_irq(&sighand->siglock);
	if (current->signal->oom_score_adj == old_val)
		current->signal->oom_score_adj = new_val;
62
	trace_oom_score_adj_update(current);
63 64 65
	spin_unlock_irq(&sighand->siglock);
}

66 67 68 69 70 71 72 73 74 75 76 77 78 79 80
/**
 * test_set_oom_score_adj() - set current's oom_score_adj and return old value
 * @new_val: new oom_score_adj value
 *
 * Sets the oom_score_adj value for current to @new_val with proper
 * synchronization and returns the old value.  Usually used to temporarily
 * set a value, save the old value in the caller, and then reinstate it later.
 */
int test_set_oom_score_adj(int new_val)
{
	struct sighand_struct *sighand = current->sighand;
	int old_val;

	spin_lock_irq(&sighand->siglock);
	old_val = current->signal->oom_score_adj;
D
David Rientjes 已提交
81
	current->signal->oom_score_adj = new_val;
82
	trace_oom_score_adj_update(current);
83 84 85 86 87
	spin_unlock_irq(&sighand->siglock);

	return old_val;
}

88 89 90 91 92 93 94 95 96
#ifdef CONFIG_NUMA
/**
 * has_intersects_mems_allowed() - check task eligiblity for kill
 * @tsk: task struct of which task to consider
 * @mask: nodemask passed to page allocator for mempolicy ooms
 *
 * Task eligibility is determined by whether or not a candidate task, @tsk,
 * shares the same mempolicy nodes as current if it is bound by such a policy
 * and whether or not it has the same set of allowed cpuset nodes.
97
 */
98 99
static bool has_intersects_mems_allowed(struct task_struct *tsk,
					const nodemask_t *mask)
100
{
101
	struct task_struct *start = tsk;
102 103

	do {
104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120
		if (mask) {
			/*
			 * If this is a mempolicy constrained oom, tsk's
			 * cpuset is irrelevant.  Only return true if its
			 * mempolicy intersects current, otherwise it may be
			 * needlessly killed.
			 */
			if (mempolicy_nodemask_intersects(tsk, mask))
				return true;
		} else {
			/*
			 * This is not a mempolicy constrained oom, so only
			 * check the mems of tsk's cpuset.
			 */
			if (cpuset_mems_allowed_intersects(current, tsk))
				return true;
		}
121 122
	} while_each_thread(start, tsk);

123 124 125 126 127 128 129
	return false;
}
#else
static bool has_intersects_mems_allowed(struct task_struct *tsk,
					const nodemask_t *mask)
{
	return true;
130
}
131
#endif /* CONFIG_NUMA */
132

133 134 135 136 137 138
/*
 * The process p may have detached its own ->mm while exiting or through
 * use_mm(), but one or more of its subthreads may still have a valid
 * pointer.  Return p, or any of its subthreads with a valid ->mm, with
 * task_lock() held.
 */
139
struct task_struct *find_lock_task_mm(struct task_struct *p)
140 141 142 143 144 145 146 147 148 149 150 151 152
{
	struct task_struct *t = p;

	do {
		task_lock(t);
		if (likely(t->mm))
			return t;
		task_unlock(t);
	} while_each_thread(p, t);

	return NULL;
}

153
/* return true if the task is not adequate as candidate victim task. */
154
static bool oom_unkillable_task(struct task_struct *p,
155
		const struct mem_cgroup *memcg, const nodemask_t *nodemask)
156 157 158 159 160 161 162
{
	if (is_global_init(p))
		return true;
	if (p->flags & PF_KTHREAD)
		return true;

	/* When mem_cgroup_out_of_memory() and p is not member of the group */
163
	if (memcg && !task_in_mem_cgroup(p, memcg))
164 165 166 167 168 169 170 171 172
		return true;

	/* p may not have freeable memory in nodemask */
	if (!has_intersects_mems_allowed(p, nodemask))
		return true;

	return false;
}

L
Linus Torvalds 已提交
173
/**
D
David Rientjes 已提交
174
 * oom_badness - heuristic function to determine which candidate task to kill
L
Linus Torvalds 已提交
175
 * @p: task struct of which task we should calculate
D
David Rientjes 已提交
176
 * @totalpages: total present RAM allowed for page allocation
L
Linus Torvalds 已提交
177
 *
D
David Rientjes 已提交
178 179 180
 * The heuristic for determining which task to kill is made to be as simple and
 * predictable as possible.  The goal is to return the highest value for the
 * task consuming the most memory to avoid subsequent oom failures.
L
Linus Torvalds 已提交
181
 */
182
unsigned int oom_badness(struct task_struct *p, struct mem_cgroup *memcg,
D
David Rientjes 已提交
183
		      const nodemask_t *nodemask, unsigned long totalpages)
L
Linus Torvalds 已提交
184
{
185
	long points;
186

187
	if (oom_unkillable_task(p, memcg, nodemask))
188
		return 0;
L
Linus Torvalds 已提交
189

190 191
	p = find_lock_task_mm(p);
	if (!p)
L
Linus Torvalds 已提交
192 193
		return 0;

194 195 196 197 198
	if (p->signal->oom_score_adj == OOM_SCORE_ADJ_MIN) {
		task_unlock(p);
		return 0;
	}

L
Linus Torvalds 已提交
199
	/*
D
David Rientjes 已提交
200 201
	 * The memory controller may have a limit of 0 bytes, so avoid a divide
	 * by zero, if necessary.
L
Linus Torvalds 已提交
202
	 */
D
David Rientjes 已提交
203 204
	if (!totalpages)
		totalpages = 1;
L
Linus Torvalds 已提交
205 206

	/*
D
David Rientjes 已提交
207
	 * The baseline for the badness score is the proportion of RAM that each
208
	 * task's rss, pagetable and swap space use.
L
Linus Torvalds 已提交
209
	 */
210 211 212 213 214
	points = get_mm_rss(p->mm) + p->mm->nr_ptes;
	points += get_mm_counter(p->mm, MM_SWAPENTS);

	points *= 1000;
	points /= totalpages;
D
David Rientjes 已提交
215
	task_unlock(p);
L
Linus Torvalds 已提交
216 217

	/*
D
David Rientjes 已提交
218 219
	 * Root processes get 3% bonus, just like the __vm_enough_memory()
	 * implementation used by LSMs.
L
Linus Torvalds 已提交
220
	 */
D
David Rientjes 已提交
221 222
	if (has_capability_noaudit(p, CAP_SYS_ADMIN))
		points -= 30;
L
Linus Torvalds 已提交
223 224

	/*
D
David Rientjes 已提交
225 226 227
	 * /proc/pid/oom_score_adj ranges from -1000 to +1000 such that it may
	 * either completely disable oom killing or always prefer a certain
	 * task.
L
Linus Torvalds 已提交
228
	 */
D
David Rientjes 已提交
229
	points += p->signal->oom_score_adj;
L
Linus Torvalds 已提交
230

231 232 233 234 235 236 237
	/*
	 * Never return 0 for an eligible task that may be killed since it's
	 * possible that no single user task uses more than 0.1% of memory and
	 * no single admin tasks uses more than 3.0%.
	 */
	if (points <= 0)
		return 1;
D
David Rientjes 已提交
238
	return (points < 1000) ? points : 1000;
L
Linus Torvalds 已提交
239 240
}

241 242 243 244
/*
 * Determine the type of allocation constraint.
 */
#ifdef CONFIG_NUMA
245
static enum oom_constraint constrained_alloc(struct zonelist *zonelist,
D
David Rientjes 已提交
246 247
				gfp_t gfp_mask, nodemask_t *nodemask,
				unsigned long *totalpages)
248
{
249
	struct zone *zone;
250
	struct zoneref *z;
251
	enum zone_type high_zoneidx = gfp_zone(gfp_mask);
D
David Rientjes 已提交
252 253
	bool cpuset_limited = false;
	int nid;
254

D
David Rientjes 已提交
255 256 257 258 259
	/* Default to all available memory */
	*totalpages = totalram_pages + total_swap_pages;

	if (!zonelist)
		return CONSTRAINT_NONE;
260 261 262 263 264 265 266
	/*
	 * Reach here only when __GFP_NOFAIL is used. So, we should avoid
	 * to kill current.We have to random task kill in this case.
	 * Hopefully, CONSTRAINT_THISNODE...but no way to handle it, now.
	 */
	if (gfp_mask & __GFP_THISNODE)
		return CONSTRAINT_NONE;
267

268
	/*
D
David Rientjes 已提交
269 270 271
	 * This is not a __GFP_THISNODE allocation, so a truncated nodemask in
	 * the page allocator means a mempolicy is in effect.  Cpuset policy
	 * is enforced in get_page_from_freelist().
272
	 */
D
David Rientjes 已提交
273 274 275 276
	if (nodemask && !nodes_subset(node_states[N_HIGH_MEMORY], *nodemask)) {
		*totalpages = total_swap_pages;
		for_each_node_mask(nid, *nodemask)
			*totalpages += node_spanned_pages(nid);
277
		return CONSTRAINT_MEMORY_POLICY;
D
David Rientjes 已提交
278
	}
279 280 281 282 283

	/* Check this allocation failure is caused by cpuset's wall function */
	for_each_zone_zonelist_nodemask(zone, z, zonelist,
			high_zoneidx, nodemask)
		if (!cpuset_zone_allowed_softwall(zone, gfp_mask))
D
David Rientjes 已提交
284
			cpuset_limited = true;
285

D
David Rientjes 已提交
286 287 288 289 290 291
	if (cpuset_limited) {
		*totalpages = total_swap_pages;
		for_each_node_mask(nid, cpuset_current_mems_allowed)
			*totalpages += node_spanned_pages(nid);
		return CONSTRAINT_CPUSET;
	}
292 293
	return CONSTRAINT_NONE;
}
294 295
#else
static enum oom_constraint constrained_alloc(struct zonelist *zonelist,
D
David Rientjes 已提交
296 297
				gfp_t gfp_mask, nodemask_t *nodemask,
				unsigned long *totalpages)
298
{
D
David Rientjes 已提交
299
	*totalpages = totalram_pages + total_swap_pages;
300 301 302
	return CONSTRAINT_NONE;
}
#endif
303

L
Linus Torvalds 已提交
304 305 306 307 308 309
/*
 * Simple selection loop. We chose the process with the highest
 * number of 'points'. We expect the caller will lock the tasklist.
 *
 * (not docbooked, we don't want this one cluttering up the manual)
 */
D
David Rientjes 已提交
310
static struct task_struct *select_bad_process(unsigned int *ppoints,
311
		unsigned long totalpages, struct mem_cgroup *memcg,
D
David Rientjes 已提交
312
		const nodemask_t *nodemask)
L
Linus Torvalds 已提交
313
{
314
	struct task_struct *g, *p;
L
Linus Torvalds 已提交
315
	struct task_struct *chosen = NULL;
316
	*ppoints = 0;
L
Linus Torvalds 已提交
317

318
	do_each_thread(g, p) {
D
David Rientjes 已提交
319
		unsigned int points;
P
Paul Jackson 已提交
320

321
		if (p->exit_state)
322
			continue;
323
		if (oom_unkillable_task(p, memcg, nodemask))
324
			continue;
325

326 327 328 329 330 331 332 333 334
		/*
		 * This task already has access to memory reserves and is
		 * being killed. Don't allow any other task access to the
		 * memory reserve.
		 *
		 * Note: this may have a chance of deadlock if it gets
		 * blocked waiting for another task which itself is waiting
		 * for memory. Is there a better alternative?
		 */
335 336
		if (test_tsk_thread_flag(p, TIF_MEMDIE)) {
			if (unlikely(frozen(p)))
337
				__thaw_task(p);
338
			return ERR_PTR(-1UL);
339
		}
340 341
		if (!p->mm)
			continue;
342

343
		if (p->flags & PF_EXITING) {
344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361
			/*
			 * If p is the current task and is in the process of
			 * releasing memory, we allow the "kill" to set
			 * TIF_MEMDIE, which will allow it to gain access to
			 * memory reserves.  Otherwise, it may stall forever.
			 *
			 * The loop isn't broken here, however, in case other
			 * threads are found to have already been oom killed.
			 */
			if (p == current) {
				chosen = p;
				*ppoints = 1000;
			} else {
				/*
				 * If this task is not being ptraced on exit,
				 * then wait for it to finish before killing
				 * some other task unnecessarily.
				 */
T
Tejun Heo 已提交
362
				if (!(p->group_leader->ptrace & PT_TRACE_EXIT))
363 364
					return ERR_PTR(-1UL);
			}
365
		}
366

367
		points = oom_badness(p, memcg, nodemask, totalpages);
D
David Rientjes 已提交
368
		if (points > *ppoints) {
P
Paul Jackson 已提交
369
			chosen = p;
370
			*ppoints = points;
L
Linus Torvalds 已提交
371
		}
372
	} while_each_thread(g, p);
373

L
Linus Torvalds 已提交
374 375 376
	return chosen;
}

377
/**
R
Randy Dunlap 已提交
378
 * dump_tasks - dump current memory state of all system tasks
379
 * @mem: current's memory controller, if constrained
380
 * @nodemask: nodemask passed to page allocator for mempolicy ooms
R
Randy Dunlap 已提交
381
 *
382 383 384
 * Dumps the current memory state of all eligible tasks.  Tasks not in the same
 * memcg, not in the same cpuset, or bound to a disjoint set of mempolicy nodes
 * are not shown.
385
 * State information includes task's pid, uid, tgid, vm size, rss, cpu, oom_adj
D
David Rientjes 已提交
386
 * value, oom_score_adj value, and name.
387 388 389
 *
 * Call with tasklist_lock read-locked.
 */
390
static void dump_tasks(const struct mem_cgroup *memcg, const nodemask_t *nodemask)
391
{
392 393
	struct task_struct *p;
	struct task_struct *task;
394

D
David Rientjes 已提交
395
	pr_info("[ pid ]   uid  tgid total_vm      rss cpu oom_adj oom_score_adj name\n");
396
	for_each_process(p) {
397
		if (oom_unkillable_task(p, memcg, nodemask))
398
			continue;
399

400 401
		task = find_lock_task_mm(p);
		if (!task) {
402
			/*
403 404
			 * This is a kthread or all of p's threads have already
			 * detached their mm's.  There's no need to report
405
			 * them; they can't be oom killed anyway.
406 407 408
			 */
			continue;
		}
409

D
David Rientjes 已提交
410
		pr_info("[%5d] %5d %5d %8lu %8lu %3u     %3d         %5d %s\n",
411
			task->pid, task_uid(task), task->tgid,
D
David Rientjes 已提交
412 413 414
			task->mm->total_vm, get_mm_rss(task->mm),
			task_cpu(task), task->signal->oom_adj,
			task->signal->oom_score_adj, task->comm);
415 416
		task_unlock(task);
	}
417 418
}

419
static void dump_header(struct task_struct *p, gfp_t gfp_mask, int order,
420
			struct mem_cgroup *memcg, const nodemask_t *nodemask)
421
{
422
	task_lock(current);
423
	pr_warning("%s invoked oom-killer: gfp_mask=0x%x, order=%d, "
D
David Rientjes 已提交
424 425 426
		"oom_adj=%d, oom_score_adj=%d\n",
		current->comm, gfp_mask, order, current->signal->oom_adj,
		current->signal->oom_score_adj);
427 428 429
	cpuset_print_task_mems_allowed(current);
	task_unlock(current);
	dump_stack();
430
	mem_cgroup_print_oom_info(memcg, p);
431
	show_mem(SHOW_MEM_FILTER_NODES);
432
	if (sysctl_oom_dump_tasks)
433
		dump_tasks(memcg, nodemask);
434 435
}

436
#define K(x) ((x) << (PAGE_SHIFT-10))
437
static int oom_kill_task(struct task_struct *p)
L
Linus Torvalds 已提交
438
{
439 440 441
	struct task_struct *q;
	struct mm_struct *mm;

442
	p = find_lock_task_mm(p);
443
	if (!p)
444
		return 1;
445

446 447 448
	/* mm cannot be safely dereferenced after task_unlock(p) */
	mm = p->mm;

449 450 451 452
	pr_err("Killed process %d (%s) total-vm:%lukB, anon-rss:%lukB, file-rss:%lukB\n",
		task_pid_nr(p), p->comm, K(p->mm->total_vm),
		K(get_mm_counter(p->mm, MM_ANONPAGES)),
		K(get_mm_counter(p->mm, MM_FILEPAGES)));
453
	task_unlock(p);
L
Linus Torvalds 已提交
454

455
	/*
456
	 * Kill all user processes sharing p->mm in other thread groups, if any.
457 458 459 460 461 462 463 464 465
	 * They don't get access to memory reserves or a higher scheduler
	 * priority, though, to avoid depletion of all memory or task
	 * starvation.  This prevents mm->mmap_sem livelock when an oom killed
	 * task cannot exit because it requires the semaphore and its contended
	 * by another thread trying to allocate memory itself.  That thread will
	 * now get access to memory reserves since it has a pending fatal
	 * signal.
	 */
	for_each_process(q)
466 467
		if (q->mm == mm && !same_thread_group(q, p) &&
		    !(q->flags & PF_KTHREAD)) {
D
David Rientjes 已提交
468 469 470
			if (q->signal->oom_score_adj == OOM_SCORE_ADJ_MIN)
				continue;

471 472 473 474 475 476
			task_lock(q);	/* Protect ->comm from prctl() */
			pr_err("Kill process %d (%s) sharing same memory\n",
				task_pid_nr(q), q->comm);
			task_unlock(q);
			force_sig(SIGKILL, q);
		}
477

L
Linus Torvalds 已提交
478 479
	set_tsk_thread_flag(p, TIF_MEMDIE);
	force_sig(SIGKILL, p);
480

481
	return 0;
L
Linus Torvalds 已提交
482
}
483
#undef K
L
Linus Torvalds 已提交
484

485
static int oom_kill_process(struct task_struct *p, gfp_t gfp_mask, int order,
D
David Rientjes 已提交
486
			    unsigned int points, unsigned long totalpages,
487
			    struct mem_cgroup *memcg, nodemask_t *nodemask,
D
David Rientjes 已提交
488
			    const char *message)
L
Linus Torvalds 已提交
489
{
490
	struct task_struct *victim = p;
491
	struct task_struct *child;
492 493
	struct task_struct *t = p;
	unsigned int victim_points = 0;
L
Linus Torvalds 已提交
494

495
	if (printk_ratelimit())
496
		dump_header(p, gfp_mask, order, memcg, nodemask);
497

498 499 500 501
	/*
	 * If the task is already exiting, don't alarm the sysadmin or kill
	 * its children or threads, just set TIF_MEMDIE so it can die quickly
	 */
502
	if (p->flags & PF_EXITING) {
503
		set_tsk_thread_flag(p, TIF_MEMDIE);
504 505 506
		return 0;
	}

507
	task_lock(p);
D
David Rientjes 已提交
508
	pr_err("%s: Kill process %d (%s) score %d or sacrifice child\n",
509 510
		message, task_pid_nr(p), p->comm, points);
	task_unlock(p);
N
Nick Piggin 已提交
511

512 513
	/*
	 * If any of p's children has a different mm and is eligible for kill,
514
	 * the one with the highest oom_badness() score is sacrificed for its
515 516 517
	 * parent.  This attempts to lose the minimal amount of work done while
	 * still freeing memory.
	 */
518
	do {
519
		list_for_each_entry(child, &t->children, sibling) {
D
David Rientjes 已提交
520
			unsigned int child_points;
521

522 523
			if (child->mm == p->mm)
				continue;
D
David Rientjes 已提交
524 525 526
			/*
			 * oom_badness() returns 0 if the thread is unkillable
			 */
527
			child_points = oom_badness(child, memcg, nodemask,
D
David Rientjes 已提交
528
								totalpages);
529 530 531 532
			if (child_points > victim_points) {
				victim = child;
				victim_points = child_points;
			}
533 534 535
		}
	} while_each_thread(p, t);

536
	return oom_kill_task(victim);
L
Linus Torvalds 已提交
537 538
}

539 540 541 542
/*
 * Determines whether the kernel must panic because of the panic_on_oom sysctl.
 */
static void check_panic_on_oom(enum oom_constraint constraint, gfp_t gfp_mask,
543
				int order, const nodemask_t *nodemask)
544 545 546 547 548 549 550 551 552 553 554 555 556
{
	if (likely(!sysctl_panic_on_oom))
		return;
	if (sysctl_panic_on_oom != 2) {
		/*
		 * panic_on_oom == 1 only affects CONSTRAINT_NONE, the kernel
		 * does not panic for cpuset, mempolicy, or memcg allocation
		 * failures.
		 */
		if (constraint != CONSTRAINT_NONE)
			return;
	}
	read_lock(&tasklist_lock);
557
	dump_header(NULL, gfp_mask, order, NULL, nodemask);
558 559 560 561 562
	read_unlock(&tasklist_lock);
	panic("Out of memory: %s panic_on_oom is enabled\n",
		sysctl_panic_on_oom == 2 ? "compulsory" : "system-wide");
}

563
#ifdef CONFIG_CGROUP_MEM_RES_CTLR
564
void mem_cgroup_out_of_memory(struct mem_cgroup *memcg, gfp_t gfp_mask)
565
{
D
David Rientjes 已提交
566 567
	unsigned long limit;
	unsigned int points = 0;
568 569
	struct task_struct *p;

570 571 572 573 574 575 576 577 578 579
	/*
	 * If current has a pending SIGKILL, then automatically select it.  The
	 * goal is to allow it to allocate so that it may quickly exit and free
	 * its memory.
	 */
	if (fatal_signal_pending(current)) {
		set_thread_flag(TIF_MEMDIE);
		return;
	}

580
	check_panic_on_oom(CONSTRAINT_MEMCG, gfp_mask, 0, NULL);
581
	limit = mem_cgroup_get_limit(memcg) >> PAGE_SHIFT;
L
Li Zefan 已提交
582
	read_lock(&tasklist_lock);
583
retry:
584
	p = select_bad_process(&points, limit, memcg, NULL);
585
	if (!p || PTR_ERR(p) == -1UL)
586 587
		goto out;

588
	if (oom_kill_process(p, gfp_mask, 0, points, limit, memcg, NULL,
589 590 591
				"Memory cgroup out of memory"))
		goto retry;
out:
L
Li Zefan 已提交
592
	read_unlock(&tasklist_lock);
593 594 595
}
#endif

596 597 598 599 600 601 602 603 604 605 606 607 608 609
static BLOCKING_NOTIFIER_HEAD(oom_notify_list);

int register_oom_notifier(struct notifier_block *nb)
{
	return blocking_notifier_chain_register(&oom_notify_list, nb);
}
EXPORT_SYMBOL_GPL(register_oom_notifier);

int unregister_oom_notifier(struct notifier_block *nb)
{
	return blocking_notifier_chain_unregister(&oom_notify_list, nb);
}
EXPORT_SYMBOL_GPL(unregister_oom_notifier);

D
David Rientjes 已提交
610 611 612 613 614
/*
 * Try to acquire the OOM killer lock for the zones in zonelist.  Returns zero
 * if a parallel OOM killing is already taking place that includes a zone in
 * the zonelist.  Otherwise, locks all zones in the zonelist and returns 1.
 */
615
int try_set_zonelist_oom(struct zonelist *zonelist, gfp_t gfp_mask)
D
David Rientjes 已提交
616
{
617 618
	struct zoneref *z;
	struct zone *zone;
D
David Rientjes 已提交
619 620
	int ret = 1;

D
David Rientjes 已提交
621
	spin_lock(&zone_scan_lock);
622 623
	for_each_zone_zonelist(zone, z, zonelist, gfp_zone(gfp_mask)) {
		if (zone_is_oom_locked(zone)) {
D
David Rientjes 已提交
624 625 626
			ret = 0;
			goto out;
		}
627 628 629 630
	}

	for_each_zone_zonelist(zone, z, zonelist, gfp_zone(gfp_mask)) {
		/*
D
David Rientjes 已提交
631
		 * Lock each zone in the zonelist under zone_scan_lock so a
632
		 * parallel invocation of try_set_zonelist_oom() doesn't succeed
633 634 635 636
		 * when it shouldn't.
		 */
		zone_set_flag(zone, ZONE_OOM_LOCKED);
	}
D
David Rientjes 已提交
637 638

out:
D
David Rientjes 已提交
639
	spin_unlock(&zone_scan_lock);
D
David Rientjes 已提交
640 641 642 643 644 645 646 647
	return ret;
}

/*
 * Clears the ZONE_OOM_LOCKED flag for all zones in the zonelist so that failed
 * allocation attempts with zonelists containing them may now recall the OOM
 * killer, if necessary.
 */
648
void clear_zonelist_oom(struct zonelist *zonelist, gfp_t gfp_mask)
D
David Rientjes 已提交
649
{
650 651
	struct zoneref *z;
	struct zone *zone;
D
David Rientjes 已提交
652

D
David Rientjes 已提交
653
	spin_lock(&zone_scan_lock);
654 655 656
	for_each_zone_zonelist(zone, z, zonelist, gfp_zone(gfp_mask)) {
		zone_clear_flag(zone, ZONE_OOM_LOCKED);
	}
D
David Rientjes 已提交
657
	spin_unlock(&zone_scan_lock);
D
David Rientjes 已提交
658 659
}

660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696
/*
 * Try to acquire the oom killer lock for all system zones.  Returns zero if a
 * parallel oom killing is taking place, otherwise locks all zones and returns
 * non-zero.
 */
static int try_set_system_oom(void)
{
	struct zone *zone;
	int ret = 1;

	spin_lock(&zone_scan_lock);
	for_each_populated_zone(zone)
		if (zone_is_oom_locked(zone)) {
			ret = 0;
			goto out;
		}
	for_each_populated_zone(zone)
		zone_set_flag(zone, ZONE_OOM_LOCKED);
out:
	spin_unlock(&zone_scan_lock);
	return ret;
}

/*
 * Clears ZONE_OOM_LOCKED for all system zones so that failed allocation
 * attempts or page faults may now recall the oom killer, if necessary.
 */
static void clear_system_oom(void)
{
	struct zone *zone;

	spin_lock(&zone_scan_lock);
	for_each_populated_zone(zone)
		zone_clear_flag(zone, ZONE_OOM_LOCKED);
	spin_unlock(&zone_scan_lock);
}

L
Linus Torvalds 已提交
697
/**
698
 * out_of_memory - kill the "best" process when we run out of memory
R
Randy Dunlap 已提交
699 700 701
 * @zonelist: zonelist pointer
 * @gfp_mask: memory allocation flags
 * @order: amount of memory being requested as a power of 2
702
 * @nodemask: nodemask passed to page allocator
L
Linus Torvalds 已提交
703 704 705 706 707 708
 *
 * If we run out of memory, we have the choice between either
 * killing a random task (bad), letting the system crash (worse)
 * OR try to be smart about which process to kill. Note that we
 * don't have to be perfect here, we just have to be good.
 */
709 710
void out_of_memory(struct zonelist *zonelist, gfp_t gfp_mask,
		int order, nodemask_t *nodemask)
L
Linus Torvalds 已提交
711
{
712
	const nodemask_t *mpol_mask;
713
	struct task_struct *p;
D
David Rientjes 已提交
714
	unsigned long totalpages;
715
	unsigned long freed = 0;
D
David Rientjes 已提交
716
	unsigned int points;
717
	enum oom_constraint constraint = CONSTRAINT_NONE;
K
KOSAKI Motohiro 已提交
718
	int killed = 0;
719 720 721 722 723

	blocking_notifier_call_chain(&oom_notify_list, 0, &freed);
	if (freed > 0)
		/* Got some memory back in the last second. */
		return;
L
Linus Torvalds 已提交
724

725 726 727 728 729 730 731 732 733 734
	/*
	 * If current has a pending SIGKILL, then automatically select it.  The
	 * goal is to allow it to allocate so that it may quickly exit and free
	 * its memory.
	 */
	if (fatal_signal_pending(current)) {
		set_thread_flag(TIF_MEMDIE);
		return;
	}

735 736 737 738
	/*
	 * Check if there were limitations on the allocation (only relevant for
	 * NUMA) that may require different handling.
	 */
D
David Rientjes 已提交
739 740
	constraint = constrained_alloc(zonelist, gfp_mask, nodemask,
						&totalpages);
741 742
	mpol_mask = (constraint == CONSTRAINT_MEMORY_POLICY) ? nodemask : NULL;
	check_panic_on_oom(constraint, gfp_mask, order, mpol_mask);
743

D
David Rientjes 已提交
744
	read_lock(&tasklist_lock);
745
	if (sysctl_oom_kill_allocating_task &&
746
	    !oom_unkillable_task(current, NULL, nodemask) &&
D
David Rientjes 已提交
747
	    current->mm) {
748 749 750 751 752
		/*
		 * oom_kill_process() needs tasklist_lock held.  If it returns
		 * non-zero, current could not be killed so we must fallback to
		 * the tasklist scan.
		 */
D
David Rientjes 已提交
753 754
		if (!oom_kill_process(current, gfp_mask, order, 0, totalpages,
				NULL, nodemask,
755
				"Out of memory (oom_kill_allocating_task)"))
K
KOSAKI Motohiro 已提交
756
			goto out;
757 758 759
	}

retry:
760
	p = select_bad_process(&points, totalpages, NULL, mpol_mask);
761
	if (PTR_ERR(p) == -1UL)
K
KOSAKI Motohiro 已提交
762
		goto out;
763 764 765

	/* Found nothing?!?! Either we hang forever, or we panic. */
	if (!p) {
766
		dump_header(NULL, gfp_mask, order, NULL, mpol_mask);
767 768 769 770
		read_unlock(&tasklist_lock);
		panic("Out of memory and no killable processes...\n");
	}

D
David Rientjes 已提交
771 772
	if (oom_kill_process(p, gfp_mask, order, points, totalpages, NULL,
				nodemask, "Out of memory"))
773
		goto retry;
K
KOSAKI Motohiro 已提交
774 775
	killed = 1;
out:
776
	read_unlock(&tasklist_lock);
L
Linus Torvalds 已提交
777 778 779

	/*
	 * Give "p" a good chance of killing itself before we
780
	 * retry to allocate memory unless "p" is current
L
Linus Torvalds 已提交
781
	 */
K
KOSAKI Motohiro 已提交
782
	if (killed && !test_thread_flag(TIF_MEMDIE))
783
		schedule_timeout_uninterruptible(1);
L
Linus Torvalds 已提交
784
}
785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800

/*
 * The pagefault handler calls here because it is out of memory, so kill a
 * memory-hogging task.  If a populated zone has ZONE_OOM_LOCKED set, a parallel
 * oom killing is already in progress so do nothing.  If a task is found with
 * TIF_MEMDIE set, it has been killed so do nothing and allow it to exit.
 */
void pagefault_out_of_memory(void)
{
	if (try_set_system_oom()) {
		out_of_memory(NULL, 0, 0, NULL);
		clear_system_oom();
	}
	if (!test_thread_flag(TIF_MEMDIE))
		schedule_timeout_uninterruptible(1);
}