Blame view
mm/thrash.c
2.05 KB
1da177e4c
|
1 2 3 4 5 6 7 8 9 |
/* * mm/thrash.c * * Copyright (C) 2004, Red Hat, Inc. * Copyright (C) 2004, Rik van Riel <riel@redhat.com> * Released under the GPL, see the file COPYING for details. * * Simple token based thrashing protection, using the algorithm * described in: http://www.cs.wm.edu/~sjiang/token.pdf |
7602bdf2f
|
10 11 12 13 14 15 16 17 |
* * Sep 2006, Ashwin Chaugule <ashwin.chaugule@celunite.com> * Improved algorithm to pass token: * Each task has a priority which is incremented if it contended * for the token in an interval less than its previous attempt. * If the token is acquired, that task's priority is boosted to prevent * the token from bouncing around too often and to let the task make * some progress in its execution. |
1da177e4c
|
18 |
*/ |
7602bdf2f
|
19 |
|
1da177e4c
|
20 21 22 23 24 25 |
#include <linux/jiffies.h> #include <linux/mm.h> #include <linux/sched.h> #include <linux/swap.h> static DEFINE_SPINLOCK(swap_token_lock); |
7602bdf2f
|
26 |
struct mm_struct *swap_token_mm; |
e30500557
|
27 |
static unsigned int global_faults; |
1da177e4c
|
28 |
|
1da177e4c
|
29 30 |
void grab_swap_token(void) { |
7602bdf2f
|
31 |
int current_interval; |
1da177e4c
|
32 |
|
7602bdf2f
|
33 |
global_faults++; |
1da177e4c
|
34 |
|
7602bdf2f
|
35 |
current_interval = global_faults - current->mm->faultstamp; |
1da177e4c
|
36 |
|
7602bdf2f
|
37 38 |
if (!spin_trylock(&swap_token_lock)) return; |
1da177e4c
|
39 |
|
7602bdf2f
|
40 41 42 43 44 45 |
/* First come first served */ if (swap_token_mm == NULL) { current->mm->token_priority = current->mm->token_priority + 2; swap_token_mm = current->mm; goto out; } |
1da177e4c
|
46 |
|
7602bdf2f
|
47 48 49 50 |
if (current->mm != swap_token_mm) { if (current_interval < current->mm->last_interval) current->mm->token_priority++; else { |
7faaa5f0b
|
51 52 |
if (likely(current->mm->token_priority > 0)) current->mm->token_priority--; |
7602bdf2f
|
53 54 55 56 57 |
} /* Check if we deserve the token */ if (current->mm->token_priority > swap_token_mm->token_priority) { current->mm->token_priority += 2; |
1da177e4c
|
58 59 |
swap_token_mm = current->mm; } |
7602bdf2f
|
60 61 62 |
} else { /* Token holder came in again! */ current->mm->token_priority += 2; |
1da177e4c
|
63 |
} |
7602bdf2f
|
64 65 66 67 68 69 |
out: current->mm->faultstamp = global_faults; current->mm->last_interval = current_interval; spin_unlock(&swap_token_lock); return; |
1da177e4c
|
70 71 72 73 74 75 |
} /* Called on process exit. */ void __put_swap_token(struct mm_struct *mm) { spin_lock(&swap_token_lock); |
7602bdf2f
|
76 77 |
if (likely(mm == swap_token_mm)) swap_token_mm = NULL; |
1da177e4c
|
78 79 |
spin_unlock(&swap_token_lock); } |