riot-ci/RIOT
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

core: remove unnecessary tests in sched.c

Browse Source 
The scheduling gets activated by `kernel_init()` calling
`cpu_switch_context_exit()`. Before this `sched_run()` won't be called.
When it gets called, at least the main thread and the idle thread are
spawned. The idle thread won't die / get killed. So there always is at
least one thread in `runqueue_bitcache`.

Closes #19.
This commit is contained in:
René Kijewski 2014-06-10 16:55:04 +02:00
parent ce428a8937
commit a21c3f45bc
1 changed files with 22 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
core/sched.c
View File

@ -69,11 +69,9 @@ void sched_run(void)
} }
#ifdef SCHED_TEST_STACK #ifdef SCHED_TEST_STACK
if (*((unsigned int *)my_active_thread->stack_start) != (unsigned int) my_active_thread->stack_start) { if (*((unsigned int *)my_active_thread->stack_start) != (unsigned int) my_active_thread->stack_start) {
printf("scheduler(): stack overflow detected, task=%s pid=%u\n", my_active_thread->name, my_active_thread->pid); printf("scheduler(): stack overflow detected, task=%s pid=%u\n", my_active_thread->name, my_active_thread->pid);
} }
#endif #endif
} }
@ -84,47 +82,34 @@ void sched_run(void)
if (my_active_thread && (sched_pidlist[my_active_thread->pid].laststart)) { if (my_active_thread && (sched_pidlist[my_active_thread->pid].laststart)) {
sched_pidlist[my_active_thread->pid].runtime_ticks += time - sched_pidlist[my_active_thread->pid].laststart; sched_pidlist[my_active_thread->pid].runtime_ticks += time - sched_pidlist[my_active_thread->pid].laststart;
} }
#endif #endif
DEBUG("\nscheduler: previous task: %s\n", (my_active_thread == NULL) ? "none" : my_active_thread->name); DEBUG("\nscheduler: previous task: %s\n", (my_active_thread == NULL) ? "none" : my_active_thread->name);
if (sched_num_threads == 0) { /* The bitmask in runqueue_bitcache is never empty,
DEBUG("scheduler: no tasks left.\n"); * since the threading should not be started before at least the idle thread was started.
*/
while (!sched_num_threads) {
/* loop until a new task arrives */
;
}
DEBUG("scheduler: new task created.\n");
}
my_active_thread = NULL;
while (!my_active_thread) {
int nextrq = bitarithm_lsb(runqueue_bitcache); int nextrq = bitarithm_lsb(runqueue_bitcache);
clist_node_t next = *(sched_runqueues[nextrq]); clist_node_t next = *(sched_runqueues[nextrq]);
DEBUG("scheduler: first in queue: %s\n", ((tcb_t *)next.data)->name); DEBUG("scheduler: first in queue: %s\n", ((tcb_t *)next.data)->name);
clist_advance(&(sched_runqueues[nextrq])); clist_advance(&(sched_runqueues[nextrq]));
my_active_thread = (tcb_t *)next.data; my_active_thread = (tcb_t *)next.data;
sched_active_pid = (volatile int) my_active_thread->pid; sched_active_pid = (volatile int) my_active_thread->pid;
#if SCHEDSTATISTICS #if SCHEDSTATISTICS
sched_pidlist[my_active_thread->pid].laststart = time; sched_pidlist[my_active_thread->pid].laststart = time;
sched_pidlist[my_active_thread->pid].schedules++; sched_pidlist[my_active_thread->pid].schedules++;
if ((sched_cb) && (my_active_thread->pid != thread_last_pid)) { if ((sched_cb) && (sched_active_thread != thread_last_pid)) {
sched_cb(hwtimer_now(), my_active_thread->pid); sched_cb(hwtimer_now(), my_active_thread->pid);
thread_last_pid = my_active_thread->pid; thread_last_pid = my_active_thread->pid;
} }
#endif #endif
#ifdef MODULE_NSS #ifdef MODULE_NSS
if (sched_active_thread && sched_active_thread != thread_last_pid) {
if (sched_active_thread && sched_active_thread->pid != thread_last_pid) { thread_last_pid = sched_active_thread;
thread_last_pid = sched_active_thread->pid;
} }
#endif #endif
}
DEBUG("scheduler: next task: %s\n", my_active_thread->name); DEBUG("scheduler: next task: %s\n", my_active_thread->name);