diff options
| author | Richard Braun <rbraun@sceen.net> | 2013-03-06 21:15:11 +0100 |
|---|---|---|
| committer | Richard Braun <rbraun@sceen.net> | 2013-03-06 21:15:11 +0100 |
| commit | 717ccb26eee4aa67dba12629163d96ead5027e9b (patch) | |
| tree | b2d4cef9c1542543ff36c04e3f560ced2846addb /kern/thread.c | |
| parent | 26736102ae2066e04d66d1f92deee4c5cadc60bc (diff) | |
kern/thread: fix rescheduling on time-sharing run queue changes
Dynamic events on time-sharing run queues shouldn't trigger a useless
scheduling attempt when the current thread is a real-time one.
Diffstat (limited to 'kern/thread.c')
| -rw-r--r-- | kern/thread.c | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/kern/thread.c b/kern/thread.c index 2379494c..a632bdce 100644 --- a/kern/thread.c +++ b/kern/thread.c @@ -432,14 +432,18 @@ thread_sched_ts_enqueue(struct thread_ts_runq *ts_runq, struct thread *thread) } static void -thread_sched_ts_restart(struct thread_ts_runq *ts_runq) +thread_sched_ts_restart(struct thread_runq *runq) { + struct thread_ts_runq *ts_runq; struct list *node; + ts_runq = runq->ts_runq_active; node = list_first(&ts_runq->groups); assert(node != NULL); ts_runq->current = list_entry(node, struct thread_ts_group, node); - thread_self()->flags |= THREAD_RESCHEDULE; + + if (runq->current->sched_class == THREAD_SCHED_CLASS_TS) + runq->current->flags |= THREAD_RESCHEDULE; } static void @@ -449,7 +453,7 @@ thread_sched_ts_add(struct thread_runq *runq, struct thread *thread) ts_runq = runq->ts_runq_active; thread_sched_ts_enqueue(ts_runq, thread); - thread_sched_ts_restart(ts_runq); + thread_sched_ts_restart(runq); } static unsigned int @@ -523,7 +527,7 @@ thread_sched_ts_start_next_round(struct thread_runq *runq) runq->ts_runq_active = ts_runq; if (ts_runq->weight != 0) - thread_sched_ts_restart(ts_runq); + thread_sched_ts_restart(runq); } static void @@ -538,7 +542,7 @@ thread_sched_ts_remove(struct thread_runq *runq, struct thread *thread) if (ts_runq->weight == 0) thread_sched_ts_start_next_round(runq); else - thread_sched_ts_restart(ts_runq); + thread_sched_ts_restart(runq); } } |