diff options
| author | Linus Torvalds <torvalds@linux-foundation.org> | 2014-01-20 13:42:08 -0500 |
|---|---|---|
| committer | Linus Torvalds <torvalds@linux-foundation.org> | 2014-01-20 13:42:08 -0500 |
| commit | a0fa1dd3cdbccec9597fe53b6177a9aa6e20f2f8 (patch) | |
| tree | b249854573815eedf377e554f0ea516f86411841 /kernel/locking | |
| parent | 9326657abe1a83ed4b4f396b923ca1217fd50cba (diff) | |
| parent | eaad45132c564ce377e6dce05e78e08e456d5315 (diff) | |
Merge branch 'sched-core-for-linus' of git://git.kernel.org/pub/scm/linux/kernel/git/tip/tip
Pull scheduler changes from Ingo Molnar:
- Add the initial implementation of SCHED_DEADLINE support: a real-time
scheduling policy where tasks that meet their deadlines and
periodically execute their instances in less than their runtime quota
see real-time scheduling and won't miss any of their deadlines.
Tasks that go over their quota get delayed (Available to privileged
users for now)
- Clean up and fix preempt_enable_no_resched() abuse all around the
tree
- Do sched_clock() performance optimizations on x86 and elsewhere
- Fix and improve auto-NUMA balancing
- Fix and clean up the idle loop
- Apply various cleanups and fixes
* 'sched-core-for-linus' of git://git.kernel.org/pub/scm/linux/kernel/git/tip/tip: (60 commits)
sched: Fix __sched_setscheduler() nice test
sched: Move SCHED_RESET_ON_FORK into attr::sched_flags
sched: Fix up attr::sched_priority warning
sched: Fix up scheduler syscall LTP fails
sched: Preserve the nice level over sched_setscheduler() and sched_setparam() calls
sched/core: Fix htmldocs warnings
sched/deadline: No need to check p if dl_se is valid
sched/deadline: Remove unused variables
sched/deadline: Fix sparse static warnings
m68k: Fix build warning in mac_via.h
sched, thermal: Clean up preempt_enable_no_resched() abuse
sched, net: Fixup busy_loop_us_clock()
sched, net: Clean up preempt_enable_no_resched() abuse
sched/preempt: Fix up missed PREEMPT_NEED_RESCHED folding
sched/preempt, locking: Rework local_bh_{dis,en}able()
sched/clock, x86: Avoid a runtime condition in native_sched_clock()
sched/clock: Fix up clear_sched_clock_stable()
sched/clock, x86: Use a static_key for sched_clock_stable
sched/clock: Remove local_irq_disable() from the clocks
sched/clock, x86: Rewrite cyc2ns() to avoid the need to disable IRQs
...
Diffstat (limited to 'kernel/locking')
| -rw-r--r-- | kernel/locking/rtmutex-debug.c | 8 | ||||
| -rw-r--r-- | kernel/locking/rtmutex.c | 166 | ||||
| -rw-r--r-- | kernel/locking/rtmutex_common.h | 23 |
3 files changed, 149 insertions, 48 deletions
diff --git a/kernel/locking/rtmutex-debug.c b/kernel/locking/rtmutex-debug.c index 13b243a323fa..49b2ed3dced8 100644 --- a/kernel/locking/rtmutex-debug.c +++ b/kernel/locking/rtmutex-debug.c | |||
| @@ -24,7 +24,7 @@ | |||
| 24 | #include <linux/kallsyms.h> | 24 | #include <linux/kallsyms.h> |
| 25 | #include <linux/syscalls.h> | 25 | #include <linux/syscalls.h> |
| 26 | #include <linux/interrupt.h> | 26 | #include <linux/interrupt.h> |
| 27 | #include <linux/plist.h> | 27 | #include <linux/rbtree.h> |
| 28 | #include <linux/fs.h> | 28 | #include <linux/fs.h> |
| 29 | #include <linux/debug_locks.h> | 29 | #include <linux/debug_locks.h> |
| 30 | 30 | ||
| @@ -57,7 +57,7 @@ static void printk_lock(struct rt_mutex *lock, int print_owner) | |||
| 57 | 57 | ||
| 58 | void rt_mutex_debug_task_free(struct task_struct *task) | 58 | void rt_mutex_debug_task_free(struct task_struct *task) |
| 59 | { | 59 | { |
| 60 | DEBUG_LOCKS_WARN_ON(!plist_head_empty(&task->pi_waiters)); | 60 | DEBUG_LOCKS_WARN_ON(!RB_EMPTY_ROOT(&task->pi_waiters)); |
| 61 | DEBUG_LOCKS_WARN_ON(task->pi_blocked_on); | 61 | DEBUG_LOCKS_WARN_ON(task->pi_blocked_on); |
| 62 | } | 62 | } |
| 63 | 63 | ||
| @@ -154,16 +154,12 @@ void debug_rt_mutex_proxy_unlock(struct rt_mutex *lock) | |||
| 154 | void debug_rt_mutex_init_waiter(struct rt_mutex_waiter *waiter) | 154 | void debug_rt_mutex_init_waiter(struct rt_mutex_waiter *waiter) |
| 155 | { | 155 | { |
| 156 | memset(waiter, 0x11, sizeof(*waiter)); | 156 | memset(waiter, 0x11, sizeof(*waiter)); |
| 157 | plist_node_init(&waiter->list_entry, MAX_PRIO); | ||
| 158 | plist_node_init(&waiter->pi_list_entry, MAX_PRIO); | ||
| 159 | waiter->deadlock_task_pid = NULL; | 157 | waiter->deadlock_task_pid = NULL; |
| 160 | } | 158 | } |
| 161 | 159 | ||
| 162 | void debug_rt_mutex_free_waiter(struct rt_mutex_waiter *waiter) | 160 | void debug_rt_mutex_free_waiter(struct rt_mutex_waiter *waiter) |
| 163 | { | 161 | { |
| 164 | put_pid(waiter->deadlock_task_pid); | 162 | put_pid(waiter->deadlock_task_pid); |
| 165 | DEBUG_LOCKS_WARN_ON(!plist_node_empty(&waiter->list_entry)); | ||
| 166 | DEBUG_LOCKS_WARN_ON(!plist_node_empty(&waiter->pi_list_entry)); | ||
| 167 | memset(waiter, 0x22, sizeof(*waiter)); | 163 | memset(waiter, 0x22, sizeof(*waiter)); |
| 168 | } | 164 | } |
| 169 | 165 | ||
diff --git a/kernel/locking/rtmutex.c b/kernel/locking/rtmutex.c index 0dd6aec1cb6a..2e960a2bab81 100644 --- a/kernel/locking/rtmutex.c +++ b/kernel/locking/rtmutex.c | |||
| @@ -14,6 +14,7 @@ | |||
| 14 | #include <linux/export.h> | 14 | #include <linux/export.h> |
| 15 | #include <linux/sched.h> | 15 | #include <linux/sched.h> |
| 16 | #include <linux/sched/rt.h> | 16 | #include <linux/sched/rt.h> |
| 17 | #include <linux/sched/deadline.h> | ||
| 17 | #include <linux/timer.h> | 18 | #include <linux/timer.h> |
| 18 | 19 | ||
| 19 | #include "rtmutex_common.h" | 20 | #include "rtmutex_common.h" |
| @@ -91,10 +92,107 @@ static inline void mark_rt_mutex_waiters(struct rt_mutex *lock) | |||
| 91 | } | 92 | } |
| 92 | #endif | 93 | #endif |
| 93 | 94 | ||
| 95 | static inline int | ||
| 96 | rt_mutex_waiter_less(struct rt_mutex_waiter *left, | ||
| 97 | struct rt_mutex_waiter *right) | ||
| 98 | { | ||
| 99 | if (left->prio < right->prio) | ||
| 100 | return 1; | ||
| 101 | |||
| 102 | /* | ||
| 103 | * If both waiters have dl_prio(), we check the deadlines of the | ||
| 104 | * associated tasks. | ||
| 105 | * If left waiter has a dl_prio(), and we didn't return 1 above, | ||
| 106 | * then right waiter has a dl_prio() too. | ||
| 107 | */ | ||
| 108 | if (dl_prio(left->prio)) | ||
| 109 | return (left->task->dl.deadline < right->task->dl.deadline); | ||
| 110 | |||
| 111 | return 0; | ||
| 112 | } | ||
| 113 | |||
| 114 | static void | ||
| 115 | rt_mutex_enqueue(struct rt_mutex *lock, struct rt_mutex_waiter *waiter) | ||
| 116 | { | ||
| 117 | struct rb_node **link = &lock->waiters.rb_node; | ||
| 118 | struct rb_node *parent = NULL; | ||
| 119 | struct rt_mutex_waiter *entry; | ||
| 120 | int leftmost = 1; | ||
| 121 | |||
| 122 | while (*link) { | ||
| 123 | parent = *link; | ||
| 124 | entry = rb_entry(parent, struct rt_mutex_waiter, tree_entry); | ||
| 125 | if (rt_mutex_waiter_less(waiter, entry)) { | ||
| 126 | link = &parent->rb_left; | ||
| 127 | } else { | ||
| 128 | link = &parent->rb_right; | ||
| 129 | leftmost = 0; | ||
| 130 | } | ||
| 131 | } | ||
| 132 | |||
| 133 | if (leftmost) | ||
| 134 | lock->waiters_leftmost = &waiter->tree_entry; | ||
| 135 | |||
| 136 | rb_link_node(&waiter->tree_entry, parent, link); | ||
| 137 | rb_insert_color(&waiter->tree_entry, &lock->waiters); | ||
| 138 | } | ||
| 139 | |||
| 140 | static void | ||
| 141 | rt_mutex_dequeue(struct rt_mutex *lock, struct rt_mutex_waiter *waiter) | ||
| 142 | { | ||
| 143 | if (RB_EMPTY_NODE(&waiter->tree_entry)) | ||
| 144 | return; | ||
| 145 | |||
| 146 | if (lock->waiters_leftmost == &waiter->tree_entry) | ||
| 147 | lock->waiters_leftmost = rb_next(&waiter->tree_entry); | ||
| 148 | |||
| 149 | rb_erase(&waiter->tree_entry, &lock->waiters); | ||
| 150 | RB_CLEAR_NODE(&waiter->tree_entry); | ||
| 151 | } | ||
| 152 | |||
| 153 | static void | ||
| 154 | rt_mutex_enqueue_pi(struct task_struct *task, struct rt_mutex_waiter *waiter) | ||
| 155 | { | ||
| 156 | struct rb_node **link = &task->pi_waiters.rb_node; | ||
| 157 | struct rb_node *parent = NULL; | ||
| 158 | struct rt_mutex_waiter *entry; | ||
| 159 | int leftmost = 1; | ||
| 160 | |||
| 161 | while (*link) { | ||
| 162 | parent = *link; | ||
| 163 | entry = rb_entry(parent, struct rt_mutex_waiter, pi_tree_entry); | ||
| 164 | if (rt_mutex_waiter_less(waiter, entry)) { | ||
| 165 | link = &parent->rb_left; | ||
| 166 | } else { | ||
| 167 | link = &parent->rb_right; | ||
| 168 | leftmost = 0; | ||
| 169 | } | ||
| 170 | } | ||
| 171 | |||
| 172 | if (leftmost) | ||
| 173 | task->pi_waiters_leftmost = &waiter->pi_tree_entry; | ||
| 174 | |||
| 175 | rb_link_node(&waiter->pi_tree_entry, parent, link); | ||
| 176 | rb_insert_color(&waiter->pi_tree_entry, &task->pi_waiters); | ||
| 177 | } | ||
| 178 | |||
| 179 | static void | ||
| 180 | rt_mutex_dequeue_pi(struct task_struct *task, struct rt_mutex_waiter *waiter) | ||
| 181 | { | ||
| 182 | if (RB_EMPTY_NODE(&waiter->pi_tree_entry)) | ||
| 183 | return; | ||
| 184 | |||
| 185 | if (task->pi_waiters_leftmost == &waiter->pi_tree_entry) | ||
| 186 | task->pi_waiters_leftmost = rb_next(&waiter->pi_tree_entry); | ||
| 187 | |||
| 188 | rb_erase(&waiter->pi_tree_entry, &task->pi_waiters); | ||
| 189 | RB_CLEAR_NODE(&waiter->pi_tree_entry); | ||
| 190 | } | ||
| 191 | |||
| 94 | /* | 192 | /* |
| 95 | * Calculate task priority from the waiter list priority | 193 | * Calculate task priority from the waiter tree priority |
| 96 | * | 194 | * |
| 97 | * Return task->normal_prio when the waiter list is empty or when | 195 | * Return task->normal_prio when the waiter tree is empty or when |
| 98 | * the waiter is not allowed to do priority boosting | 196 | * the waiter is not allowed to do priority boosting |
| 99 | */ | 197 | */ |
| 100 | int rt_mutex_getprio(struct task_struct *task) | 198 | int rt_mutex_getprio(struct task_struct *task) |
| @@ -102,10 +200,18 @@ int rt_mutex_getprio(struct task_struct *task) | |||
| 102 | if (likely(!task_has_pi_waiters(task))) | 200 | if (likely(!task_has_pi_waiters(task))) |
| 103 | return task->normal_prio; | 201 | return task->normal_prio; |
| 104 | 202 | ||
| 105 | return min(task_top_pi_waiter(task)->pi_list_entry.prio, | 203 | return min(task_top_pi_waiter(task)->prio, |
| 106 | task->normal_prio); | 204 | task->normal_prio); |
| 107 | } | 205 | } |
| 108 | 206 | ||
| 207 | struct task_struct *rt_mutex_get_top_task(struct task_struct *t | ||
