kernel: preemptive and cooperative scheduler refactoring.
authorarighi <arighi@38d2e660-2303-0410-9eaa-f027e97ec537>
Mon, 19 Apr 2010 16:03:37 +0000 (16:03 +0000)
committerarighi <arighi@38d2e660-2303-0410-9eaa-f027e97ec537>
Mon, 19 Apr 2010 16:03:37 +0000 (16:03 +0000)
Cooperative and preemptive scheduler share almost the same code.
Everything can be merged into bertos/kern/proc.c.

git-svn-id: https://src.develer.com/svnoss/bertos/trunk@3466 38d2e660-2303-0410-9eaa-f027e97ec537

17 files changed:
bertos/drv/timer.c
bertos/kern/coop.c
bertos/kern/preempt.c
bertos/kern/preempt.h [deleted file]
bertos/kern/proc.c
bertos/kern/proc.h
bertos/kern/proc_p.h
doc/STATUS
examples/at91sam7/at91sam7s.mk
examples/at91sam7/at91sam7x.mk
examples/avr-kern/avr-kern_wiz.mk
examples/benchmark/kernel-core_avr/kernel-core_avr_wiz.mk
examples/benchmark/kernel-only_arm/kernel-only_arm_wiz.mk
examples/demo/demo.mk
examples/lm3s1968/lm3s1968.mk
examples/lpc2378/lpc2378.mk
test/run_tests.sh

index dfc27aefb53ccee74c8edaa141052e0b98010ee5..d380e5f1d458de07e0342281cbc84a934c80fdb2 100644 (file)
@@ -52,7 +52,7 @@
 #include <cpu/irq.h>
 #include <cpu/power.h> // cpu_relax()
 
-#include <kern/preempt.h> // proc_decQuantun()
+#include <kern/proc_p.h> // proc_decQuantun()
 
 /*
  * Include platform-specific binding code if we're hosted.
index c5cab0ed2e4475ab1d192f897921edd139d4e1b0..078724b42a8e38095fb93e3c6e226d2e2b5e2d70 100644 (file)
  * invalidate any other reasons why the executable file might be covered by
  * the GNU General Public License.
  *
- * Copyright 2001, 2004, 2008 Develer S.r.l. (http://www.develer.com/)
- * Copyright 1999, 2000, 2001, 2008 Bernie Innocenti <bernie@codewiz.org>
- * -->
- *
- * \brief Simple cooperative multitasking scheduler.
- *
- * \version $Id$
- * \author Bernie Innocenti <bernie@codewiz.org>
- * \author Stefano Fedrigo <aleph@develer.com>
- */
-
-#include "proc_p.h"
-#include "proc.h"
-
-// Log settings for cfg/log.h.
-#define LOG_LEVEL   KERN_LOG_LEVEL
-#define LOG_FORMAT  KERN_LOG_FORMAT
-#include <cfg/log.h>
-
-#include <cpu/irq.h>
-#include <cpu/types.h>
-#include <cpu/attr.h>
-#include <cpu/frame.h>
-
-/**
- * Define function prototypes exported outside.
- *
- * Required to silent gcc "no previous prototype" warnings.
- */
-void coop_yield(void);
-void coop_switch(void);
-void coop_wakeup(Process *proc);
-
-static void coop_switchTo(Process *proc)
-{
-       Process *old_process = current_process;
-
-       SCHED_ENQUEUE(current_process);
-       current_process = proc;
-       proc_switchTo(current_process, old_process);
-}
-
-/**
- * Give the control of the CPU to another process.
- *
- * \note Assume the current process has been already added to a wait queue.
+ * \note This file is deprecated and kept only for backward compatibility.
  *
- * \warning This should be considered an internal kernel function, even if it
- * is allowed, usage from application code is strongly discouraged.
- */
-void coop_switch(void)
-{
-       ATOMIC(proc_schedule());
-}
-
-/**
- * Immediately wakeup a process, dispatching it to the CPU.
- */
-void coop_wakeup(Process *proc)
-{
-       ASSERT(proc_preemptAllowed());
-       ASSERT(current_process);
-       IRQ_ASSERT_DISABLED();
-
-       if (prio_proc(proc) >= prio_curr())
-               coop_switchTo(proc);
-       else
-               SCHED_ENQUEUE_HEAD(proc);
-}
-
-/**
- * Co-operative context switch
+ * -->
  */
-void coop_yield(void)
-{
-       Process *proc;
-
-       IRQ_DISABLE;
-       proc = (struct Process *)list_remHead(&proc_ready_list);
-       if (proc)
-               coop_switchTo(proc);
-       IRQ_ENABLE;
-}
index bdb6d3c9e716b543529b464167b8ecc04a6a0751..078724b42a8e38095fb93e3c6e226d2e2b5e2d70 100644 (file)
  * invalidate any other reasons why the executable file might be covered by
  * the GNU General Public License.
  *
- * Copyright 2008 Bernie Innocenti <bernie@codewiz.org>
- * Copyright 2009 Andrea Righi <arighi@develer.com>
- * -->
- *
- * \brief Simple preemptive multitasking scheduler.
- *
- * Preemption is explicitly regulated at the exit of each interrupt service
- * routine (ISR). Each task obtains a time quantum as soon as it is scheduled
- * on the CPU and its quantum is decremented at each clock tick. The frequency
- * of the timer determines the system tick granularity and CONFIG_KERN_QUANTUM
- * the time sharing interval.
- *
- * When the quantum expires the handler proc_needPreempt() checks if the
- * preemption is enabled and in this case preempt_schedule() is called, that
- * possibly replaces the current running thread with a different one.
- *
- * The preemption can be disabled or enabled via proc_forbid() and
- * proc_permit() primitives. This is implemented using a global atomic counter.
- * When the counter is greater than 0 the task cannot be preempted; only when
- * the counter reaches 0 the task can be preempted again.
- *
- * Preemption-disabled sections may be nested. The preemption will be
- * re-enabled when the outermost preemption-disabled section completes.
- *
- * The voluntary preemption still happens via proc_switch() or proc_yield().
- * The first one assumes the current process has been already added to a
- * private wait queue (e.g., on a semaphore or a signal), while the second one
- * takes care of adding the process into the ready queue.
- *
- * Context switch is done by CPU-dependent support routines. In case of a
- * voluntary preemption the context switch routine must take care of
- * saving/restoring only the callee-save registers (the voluntary-preemption is
- * actually a function call). The kernel-preemption always happens inside a
- * signal/interrupt context and it must take care of saving all registers. For
- * this, in the entry point of each ISR the caller-save registers must be
- * saved. In the ISR exit point, if the context switch must happen, we switch
- * to user-context and call the same voluntary context switch routine that take
- * care of saving/restoring also the callee-save registers. On resume from the
- * switch, the interrupt exit point moves back to interrupt-context, resumes
- * the caller-save registers (saved in the ISR entry point) and return from the
- * interrupt-context.
- *
- * \note Thread priority (if enabled by CONFIG_KERN_PRI) defines the order in
- * the \p proc_ready_list and the capability to deschedule a running process. A
- * low-priority thread can't preempt a high-priority thread.
- *
- * A high-priority process can preempt a low-priority process immediately (it
- * will be descheduled and replaced in the interrupt exit point). Processes
- * running at the same priority can be descheduled when they expire the time
- * quantum.
- *
- * \note Sleeping while preemption is disabled fallbacks to a busy-wait sleep.
- * Voluntary preemption when preemption is disabled raises a kernel bug.
- *
- * \author Bernie Innocenti <bernie@codewiz.org>
- * \author Andrea Righi <arighi@develer.com>
- */
-
-#include "cfg/cfg_proc.h"
-
-#include "proc_p.h"
-#include "proc.h"
-
-#include <kern/irq.h>
-#include <kern/monitor.h>
-#include <cpu/frame.h> // CPU_IDLE
-#include <cpu/irq.h>   // IRQ_DISABLE()...
-#include <cfg/log.h>
-#include <cfg/module.h>
-#include <cfg/depend.h>    // CONFIG_DEPEND()
-
-// Check config dependencies
-CONFIG_DEPEND(CONFIG_KERN_PREEMPT, CONFIG_KERN);
-
-MOD_DEFINE(preempt)
-
-/* Global preemption nesting counter */
-cpu_atomic_t preempt_count;
-
-/*
- * The time sharing interval: when a process is scheduled on a CPU it gets an
- * amount of CONFIG_KERN_QUANTUM clock ticks. When these ticks expires and
- * preemption is enabled a new process is selected to run.
- */
-int _proc_quantum;
-
-/**
- * Define function prototypes exported outside.
+ * \note This file is deprecated and kept only for backward compatibility.
  *
- * Required to silent gcc "no previous prototype" warnings.
- */
-void preempt_yield(void);
-int preempt_needPreempt(void);
-void preempt_preempt(void);
-void preempt_switch(void);
-void preempt_wakeup(Process *proc);
-void preempt_init(void);
-
-static void preempt_switchTo(Process *proc)
-{
-       Process *old_process = current_process;
-
-       SCHED_ENQUEUE(current_process);
-       _proc_quantum = CONFIG_KERN_QUANTUM;
-       current_process = proc;
-       proc_switchTo(current_process, old_process);
-}
-
-/**
- * Call the scheduler and eventually replace the current running process.
- */
-static void preempt_schedule(void)
-{
-       _proc_quantum = CONFIG_KERN_QUANTUM;
-       proc_schedule();
-}
-
-/**
- * Check if we need to schedule another task
- */
-int preempt_needPreempt(void)
-{
-       if (UNLIKELY(current_process == NULL))
-               return 0;
-       if (!proc_preemptAllowed())
-               return 0;
-       if (LIST_EMPTY(&proc_ready_list))
-               return 0;
-       return _proc_quantum ? prio_next() > prio_curr() :
-                       prio_next() >= prio_curr();
-}
-
-/**
- * Preempt the current task.
- */
-void preempt_preempt(void)
-{
-       IRQ_ASSERT_DISABLED();
-       ASSERT(current_process);
-
-       /* Perform the kernel preemption */
-       LOG_INFO("preempting %p:%s\n", current_process, proc_currentName());
-       /* We are inside a IRQ context, so ATOMIC is not needed here */
-       SCHED_ENQUEUE(current_process);
-       preempt_schedule();
-}
-
-/**
- * Give the control of the CPU to another process.
- *
- * \note Assume the current process has been already added to a wait queue.
- *
- * \warning This should be considered an internal kernel function, even if it
- * is allowed, usage from application code is strongly discouraged.
- */
-void preempt_switch(void)
-{
-       ASSERT(proc_preemptAllowed());
-
-       ATOMIC(preempt_schedule());
-}
-
-/**
- * Immediately wakeup a process, dispatching it to the CPU.
- */
-void preempt_wakeup(Process *proc)
-{
-       ASSERT(proc_preemptAllowed());
-       ASSERT(current_process);
-       IRQ_ASSERT_DISABLED();
-
-       if (prio_proc(proc) >= prio_curr())
-               preempt_switchTo(proc);
-       else
-               SCHED_ENQUEUE_HEAD(proc);
-}
-
-/**
- * Voluntarily release the CPU.
+ * -->
  */
-void preempt_yield(void)
-{
-       Process *proc;
-
-       /*
-        * Voluntary preemption while preemption is disabled is considered
-        * illegal, as not very useful in practice.
-        *
-        * ASSERT if it happens.
-        */
-       ASSERT(proc_preemptAllowed());
-       IRQ_ASSERT_ENABLED();
-
-       IRQ_DISABLE;
-       proc = (struct Process *)list_remHead(&proc_ready_list);
-       if (proc)
-               preempt_switchTo(proc);
-       IRQ_ENABLE;
-}
-
-void preempt_init(void)
-{
-       MOD_INIT(preempt);
-}
diff --git a/bertos/kern/preempt.h b/bertos/kern/preempt.h
deleted file mode 100644 (file)
index 9688e6c..0000000
+++ /dev/null
@@ -1,54 +0,0 @@
-/**
- * \file
- * <!--
- * This file is part of BeRTOS.
- *
- * Bertos is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program; if not, write to the Free Software
- * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
- *
- * As a special exception, you may use this file as part of a free software
- * library without restriction.  Specifically, if other files instantiate
- * templates or use macros or inline functions from this file, or you compile
- * this file and link it with other files to produce an executable, this
- * file does not by itself cause the resulting executable to be covered by
- * the GNU General Public License.  This exception does not however
- * invalidate any other reasons why the executable file might be covered by
- * the GNU General Public License.
- *
- * Copyright 2010 Develer S.r.l. (http://www.develer.com/)
- *
- * -->
- *
- * \brief Preeptive kernel funtion interfaces.
- *
- * \author Francesco Sacchi <batt@develer.com>
- */
-
-#ifndef KERN_PREEMPT_H
-#define KERN_PREEMPT_H
-
-#include <cfg/compiler.h>
-
-#if CONFIG_KERN_PREEMPT
-       INLINE void proc_decQuantum(void)
-       {
-               extern int _proc_quantum;
-               if (_proc_quantum > 0)
-                       _proc_quantum--;
-       }
-#else /* !CONFIG_KERN_PREEMPT */
-       #define proc_decQuantum() /* NOP */
-#endif /* CONFIG_KERN_PREEMPT */
-
-#endif /* KERN_PREEMPT_H */
index a18fc40498d52e85e198ee54e5e13a1e90e2c49e..781bd5532ab3846c0b5de51f2a5c2f48283fa09f 100644 (file)
  * invalidate any other reasons why the executable file might be covered by
  * the GNU General Public License.
  *
- * Copyright 2001, 2004 Develer S.r.l. (http://www.develer.com/)
- * Copyright 1999, 2000, 2001, 2008 Bernie Innocenti <bernie@codewiz.org>
+ * \brief Simple preemptive multitasking scheduler.
+ *
+ * Preemption is explicitly regulated at the exit of each interrupt service
+ * routine (ISR). Each task obtains a time quantum as soon as it is scheduled
+ * on the CPU and its quantum is decremented at each clock tick. The frequency
+ * of the timer determines the system tick granularity and CONFIG_KERN_QUANTUM
+ * the time sharing interval.
+ *
+ * When the quantum expires the handler proc_needPreempt() checks if the
+ * preemption is enabled and in this case proc_schedule() is called, that
+ * possibly replaces the current running thread with a different one.
+ *
+ * The preemption can be disabled or enabled via proc_forbid() and
+ * proc_permit() primitives. This is implemented using a global atomic counter.
+ * When the counter is greater than 0 the task cannot be preempted; only when
+ * the counter reaches 0 the task can be preempted again.
+ *
+ * Preemption-disabled sections may be nested. The preemption will be
+ * re-enabled when the outermost preemption-disabled section completes.
+ *
+ * The voluntary preemption still happens via proc_switch() or proc_yield().
+ * The first one assumes the current process has been already added to a
+ * private wait queue (e.g., on a semaphore or a signal), while the second one
+ * takes care of adding the process into the ready queue.
+ *
+ * Context switch is done by CPU-dependent support routines. In case of a
+ * voluntary preemption the context switch routine must take care of
+ * saving/restoring only the callee-save registers (the voluntary-preemption is
+ * actually a function call). The kernel-preemption always happens inside a
+ * signal/interrupt context and it must take care of saving all registers. For
+ * this, in the entry point of each ISR the caller-save registers must be
+ * saved. In the ISR exit point, if the context switch must happen, we switch
+ * to user-context and call the same voluntary context switch routine that take
+ * care of saving/restoring also the callee-save registers. On resume from the
+ * switch, the interrupt exit point moves back to interrupt-context, resumes
+ * the caller-save registers (saved in the ISR entry point) and return from the
+ * interrupt-context.
+ *
+ * \note Thread priority (if enabled by CONFIG_KERN_PRI) defines the order in
+ * the \p proc_ready_list and the capability to deschedule a running process. A
+ * low-priority thread can't preempt a high-priority thread.
+ *
+ * A high-priority process can preempt a low-priority process immediately (it
+ * will be descheduled and replaced in the interrupt exit point). Processes
+ * running at the same priority can be descheduled when they expire the time
+ * quantum.
+ *
+ * \note Sleeping while preemption is disabled fallbacks to a busy-wait sleep.
+ * Voluntary preemption when preemption is disabled raises a kernel bug.
+ *
  * -->
  *
- * \brief Simple cooperative multitasking scheduler.
+ * \brief Simple cooperative and preemptive multitasking scheduler.
  *
  * \author Bernie Innocenti <bernie@codewiz.org>
  * \author Stefano Fedrigo <aleph@develer.com>
+ * \author Andrea Righi <arighi@develer.com>
  */
 
 #include "proc_p.h"
@@ -98,6 +147,36 @@ static List zombie_list;
 
 #endif /* CONFIG_KERN_HEAP */
 
+/*
+ * Check if the process context switch can be performed directly by the
+ * architecture-dependent asm_switch_context() or if it must be delayed
+ * because we're in the middle of an ISR.
+ *
+ * Return true if asm_switch_context() can be executed, false
+ * otherwise.
+ *
+ * NOTE: if an architecture does not implement IRQ_RUNNING() this function
+ * always returns true.
+ */
+#define CONTEXT_SWITCH_FROM_ISR()      (!IRQ_RUNNING())
+
+/*
+ * Save context of old process and switch to new process.
+  */
+static void proc_context_switch(Process *next, Process *prev)
+{
+       cpu_stack_t *dummy;
+
+       if (UNLIKELY(next == prev))
+               return;
+       /*
+        * If there is no old process, we save the old stack pointer into a
+        * dummy variable that we ignore.  In fact, this happens only when the
+        * old process has just exited.
+        */
+       asm_switch_context(&next->stack, prev ? &prev->stack : &dummy);
+}
+
 static void proc_initStruct(Process *proc)
 {
        /* Avoid warning for unused argument. */
@@ -423,7 +502,7 @@ void proc_exit(void)
 /**
  * Call the scheduler and eventually replace the current running process.
  */
-void proc_schedule(void)
+static void proc_schedule(void)
 {
        Process *old_process = current_process;
 
@@ -454,7 +533,116 @@ void proc_schedule(void)
                IRQ_DISABLE;
        }
        if (CONTEXT_SWITCH_FROM_ISR())
-               proc_switchTo(current_process, old_process);
+               proc_context_switch(current_process, old_process);
        /* This RET resumes the execution on the new process */
        LOG_INFO("resuming %p:%s\n", current_process, proc_currentName());
 }
+
+#if CONFIG_KERN_PREEMPT
+/* Global preemption nesting counter */
+cpu_atomic_t preempt_count;
+
+/*
+ * The time sharing interval: when a process is scheduled on a CPU it gets an
+ * amount of CONFIG_KERN_QUANTUM clock ticks. When these ticks expires and
+ * preemption is enabled a new process is selected to run.
+ */
+int _proc_quantum;
+
+/**
+ * Check if we need to schedule another task
+ */
+bool proc_needPreempt(void)
+{
+       if (UNLIKELY(current_process == NULL))
+               return false;
+       if (!proc_preemptAllowed())
+               return false;
+       if (LIST_EMPTY(&proc_ready_list))
+               return false;
+       return preempt_quantum() ? prio_next() > prio_curr() :
+                       prio_next() >= prio_curr();
+}
+
+/**
+ * Preempt the current task.
+ */
+void proc_preempt(void)
+{
+       IRQ_ASSERT_DISABLED();
+       ASSERT(current_process);
+
+       /* Perform the kernel preemption */
+       LOG_INFO("preempting %p:%s\n", current_process, proc_currentName());
+       /* We are inside a IRQ context, so ATOMIC is not needed here */
+       SCHED_ENQUEUE(current_process);
+       preempt_reset_quantum();
+       proc_schedule();
+}
+#endif /* CONFIG_KERN_PREEMPT */
+
+/* Immediately switch to a particular process */
+static void proc_switchTo(Process *proc)
+{
+       Process *old_process = current_process;
+
+       SCHED_ENQUEUE(current_process);
+       preempt_reset_quantum();
+       current_process = proc;
+       proc_context_switch(current_process, old_process);
+}
+
+/**
+ * Give the control of the CPU to another process.
+ *
+ * \note Assume the current process has been already added to a wait queue.
+ *
+ * \warning This should be considered an internal kernel function, even if it
+ * is allowed, usage from application code is strongly discouraged.
+ */
+void proc_switch(void)
+{
+       ASSERT(proc_preemptAllowed());
+       ATOMIC(
+               preempt_reset_quantum();
+               proc_schedule();
+       );
+}
+
+/**
+ * Immediately wakeup a process, dispatching it to the CPU.
+ */
+void proc_wakeup(Process *proc)
+{
+       ASSERT(proc_preemptAllowed());
+       ASSERT(current_process);
+       IRQ_ASSERT_DISABLED();
+
+       if (prio_proc(proc) >= prio_curr())
+               proc_switchTo(proc);
+       else
+               SCHED_ENQUEUE_HEAD(proc);
+}
+
+/**
+ * Voluntarily release the CPU.
+ */
+void proc_yield(void)
+{
+       Process *proc;
+
+       /*
+        * Voluntary preemption while preemption is disabled is considered
+        * illegal, as not very useful in practice.
+        *
+        * ASSERT if it happens.
+        */
+       ASSERT(proc_preemptAllowed());
+       IRQ_ASSERT_ENABLED();
+
+       IRQ_DISABLE;
+       proc = (struct Process *)list_remHead(&proc_ready_list);
+       if (proc)
+               proc_switchTo(proc);
+       IRQ_ENABLE;
+}
index bacd052be848fdebf85b826ece98fb527a88ca63..9b4fe140efc8cb9312aec235012545330a1ae156 100644 (file)
@@ -37,7 +37,7 @@
  *
  * $WIZ$ module_name = "kernel"
  * $WIZ$ module_configuration = "bertos/cfg/cfg_proc.h"
- * $WIZ$ module_depends = "switch_ctx", "coop", "preempt"
+ * $WIZ$ module_depends = "switch_ctx"
  * $WIZ$ module_supports = "not atmega103"
  */
 
 #include <struct/list.h> // Node, PriNode
 
 #include <cfg/compiler.h>
-
-#if CONFIG_KERN_PREEMPT
-       #include <cfg/debug.h> // ASSERT()
-       #include <kern/preempt.h>
-#endif
+#include <cfg/debug.h> // ASSERT()
 
 #include <cpu/types.h> // cpu_stack_t
 #include <cpu/frame.h> // CPU_SAVED_REGS_CNT
@@ -146,41 +142,19 @@ void proc_exit(void);
  * Public scheduling class methods.
  */
 void proc_yield(void);
-void proc_preempt(void);
-int proc_needPreempt(void);
-void proc_wakeup(Process *proc);
 
-/**
- * Dummy function that defines unimplemented scheduler class methods.
- */
-INLINE void __proc_noop(void)
+#if CONFIG_KERN_PREEMPT
+bool proc_needPreempt(void);
+void proc_preempt(void);
+#else
+INLINE bool proc_needPreempt(void)
 {
+       return false;
 }
 
-#if CONFIG_KERN_PREEMPT
-       /**
-        * Preemptive scheduler public methods.
-        */
-       #define preempt_yield           proc_yield
-       #define preempt_needPreempt     proc_needPreempt
-       #define preempt_preempt         proc_preempt
-       /**
-        * Preemptive scheduler: private methods.
-        */
-       #define preempt_switch          proc_switch
-       #define preempt_wakeup          proc_wakeup
-#else
-       /**
-        * Co-operative scheduler: public methods.
-        */
-       #define coop_yield              proc_yield
-       #define proc_needPreempt        __proc_noop
-       #define proc_preempt            __proc_noop
-       /**
-        * Co-operative scheduler: private methods.
-        */
-       #define coop_switch             proc_switch
-       #define coop_wakeup             proc_wakeup
+INLINE void proc_preempt(void)
+{
+}
 #endif
 
 void proc_rename(struct Process *proc, const char *name);
index 56c810819b56964d2d16c83fe29075fbde8f3e5b..64fabb1290fef6052231bf3e682fb9c8a4830f49 100644 (file)
 
 #include <kern/proc.h>   // struct Process
 
-/*
- * Check if the process context switch can be performed directly by the
- * architecture-dependent asm_switch_context() or if it must be delayed
- * because we're in the middle of an ISR.
- *
- * Return true if asm_switch_context() can be executed, false
- * otherwise.
- *
- * NOTE: if an architecture does not implement IRQ_RUNNING() this function
- * always returns true.
- */
-#define CONTEXT_SWITCH_FROM_ISR()      (!IRQ_RUNNING())
-
 #ifndef asm_switch_context
 /**
  * CPU dependent context switching routines.
 EXTERN_C void asm_switch_context(cpu_stack_t **new_sp, cpu_stack_t **save_sp);
 #endif
 
-/*
- * Save context of old process and switch to new process.
-  */
-INLINE void proc_switchTo(Process *next, Process *prev)
-{
-       cpu_stack_t *dummy;
-
-       if (UNLIKELY(next == prev))
-               return;
-       /*
-        * If there is no old process, we save the old stack pointer into a
-        * dummy variable that we ignore.  In fact, this happens only when the
-        * old process has just exited.
-        */
-       asm_switch_context(&next->stack, prev ? &prev->stack : &dummy);
-}
-
 /**
  * \name Flags for Process.flags.
  * \{
@@ -191,11 +161,8 @@ void proc_entry(void);
 /* Schedule another process *without* adding the current one to the ready list. */
 void proc_switch(void);
 
-/* Low level scheduling routine. */
-void proc_schedule(void);
-
-/* Low level context switch routine. */
-void proc_switchTo(Process *next, Process *prev);
+/* Immediately schedule a particular process bypassing the scheduler. */
+void proc_wakeup(Process *proc);
 
 /* Initialize a scheduler class. */
 void proc_schedInit(void);
@@ -214,4 +181,38 @@ void proc_schedInit(void);
        void monitor_rename(Process *proc, const char *name);
 #endif /* CONFIG_KERN_MONITOR */
 
+#if CONFIG_KERN_PREEMPT
+INLINE int preempt_quantum(void)
+{
+       extern int _proc_quantum;
+       return _proc_quantum;
+}
+
+INLINE void proc_decQuantum(void)
+{
+       extern int _proc_quantum;
+       if (_proc_quantum > 0)
+               _proc_quantum--;
+}
+
+INLINE void preempt_reset_quantum(void)
+{
+       extern int _proc_quantum;
+       _proc_quantum = CONFIG_KERN_QUANTUM;
+}
+#else /* !CONFIG_KERN_PREEMPT */
+INLINE int preempt_quantum(void)
+{
+       return 0;
+}
+
+INLINE void proc_decQuantum(void)
+{
+}
+
+INLINE void preempt_reset_quantum(void)
+{
+}
+#endif /* CONFIG_KERN_PREEMPT */
+
 #endif /* KERN_PROC_P_H */
index d91fd337aebb4311a1b170f685c79f60bec927c9..c437d00dff81fbaa617afda8f0d1db266828b85a 100644 (file)
@@ -50,7 +50,7 @@ Since the system simply waits for external events to happen we decided to implem
 Currently the kernel code is very stable.
 
 <b> Kernel features </b>:
-  \li \link coop.c Cooperative \endlink round-robin scheduling.
+  \li \link preempt.c Cooperative and preemptive \endlink round-robin scheduling.
   \li \link monitor.h Stack process monitor \endlink, useful to prevent stack overflows.
   \li \link msg.h Inter-process messaging system \endlink (with very low overhead).
   \li \link sem.h Binary semaphores \endlink.
index 0586ba4544a825c601bc249b85ae84edd36b51ed..451e4e90aff3a93bbb0527b1e2acda75f934f126 100644 (file)
@@ -28,8 +28,6 @@ at91sam7s_CSRC = \
        bertos/mware/sprintf.c \
        bertos/kern/kfile.c \
        bertos/kern/proc.c \
-       bertos/kern/coop.c \
-       bertos/kern/preempt.c \
        bertos/kern/proc_test.c \
        bertos/kern/signal_test.c \
        bertos/kern/monitor.c \
@@ -43,7 +41,7 @@ at91sam7s_CPPASRC = \
 
 at91sam7s_PREFIX = arm-none-eabi-
 
-at91sam7s_CPPAFLAGS = -O0 -g -gdwarf-2 -g -gen-debug
+at91sam7s_CPPAFLAGS = -O0 -g -gdwarf-2 -g
 at91sam7s_CPPFLAGS = -O0 -D'ARCH=0' -D__ARM_AT91SAM7S256__ -D'CPU_FREQ=(48023000UL)' -D'WIZ_AUTOGEN' -g3 -gdwarf-2 -fverbose-asm -Iexamples/at91sam7 -Ibertos/cpu/arm
 at91sam7s_LDFLAGS = -nostartfiles -T bertos/cpu/arm/scripts/at91sam7_256_rom.ld -Wl,--no-warn-mismatch
 at91sam7s_CPU = arm7tdmi
index 11a6c5edfd3f523b2f8b444eae7c56ffa2f2d906..fe48a2eaa7822e94d3f5c315c309db2be8163322 100644 (file)
@@ -29,8 +29,6 @@ at91sam7x_CSRC = \
        bertos/struct/heap.c \
        bertos/kern/kfile.c \
        bertos/kern/proc.c \
-       bertos/kern/coop.c \
-       bertos/kern/preempt.c \
        bertos/kern/proc_test.c \
        bertos/kern/signal_test.c \
        bertos/kern/monitor.c \
index cf3aefbd84ca3099bd96ab0477de170249cf30ae..3f2e83ef66fa34677d660dc03b3f8c416c15d30f 100644 (file)
@@ -26,8 +26,6 @@ avr-kern_WIZARD_CSRC = \
        bertos/struct/heap.c \
        bertos/kern/monitor.c \
        bertos/drv/timer.c \
-       bertos/kern/coop.c \
-       bertos/kern/preempt.c \
        bertos/cpu/avr/drv/timer_avr.c \
        bertos/kern/proc.c \
        bertos/mware/formatwr.c \
index dfbbe4b13ab290cad0bf81d92469783315f63bd4..164feb2466b31e25ed769cff3af54aac8b9bf929 100644 (file)
@@ -22,7 +22,6 @@ kernel-core_avr_SUFFIX = ""
 kernel-core_avr_WIZARD_CSRC = \
        bertos/cpu/avr/drv/ser_avr.c \
        bertos/drv/ser.c \
-       bertos/kern/coop.c \
        bertos/kern/proc.c \
        bertos/mware/formatwr.c \
        bertos/mware/hex.c \
index 7394432bffa184cba6ff555904fdf50f1f30772a..4a67ba2f497f817f7b2e6b7a3f2ffc6442241b9a 100644 (file)
@@ -20,7 +20,6 @@ kernel-only_arm_SUFFIX = ""
 
 # Files automatically generated by the wizard. DO NOT EDIT, USE kernel-only_arm_USER_CSRC INSTEAD!
 kernel-only_arm_WIZARD_CSRC = \
-       bertos/kern/coop.c \
        bertos/kern/proc.c \
        bertos/kern/sem.c \
        bertos/kern/signal.c \
@@ -71,7 +70,7 @@ kernel-only_arm_ASRC = $(kernel-only_arm_CPU_ASRC) $(kernel-only_arm_WIZARD_ASRC
 
 # CPU specific flags and options, defined in the CPU definition files.
 # Automatically generated by the wizard. PLEASE DO NOT EDIT!
-kernel-only_arm_CPU_CPPAFLAGS = -O0 -g -gdwarf-2 -g -gen-debug
+kernel-only_arm_CPU_CPPAFLAGS = -O0 -g -gdwarf-2 -g
 kernel-only_arm_CPU_CPPFLAGS = -O0 -g3 -gdwarf-2 -fverbose-asm -Ibertos/cpu/arm/ -D__ARM_AT91SAM7X256__
 kernel-only_arm_PROGRAMMER_CPU = at91sam7
 kernel-only_arm_STOPFLASH_SCRIPT = bertos/prg_scripts/arm/stopopenocd.sh
index 838b8a948dc53e5018d6b2cbb946d18351982699..1e687b5bb10a3c4cf5892d66dfc5adb6979f779c 100644 (file)
@@ -56,8 +56,6 @@ demo_CSRC = \
        bertos/mware/resource.c \
        bertos/mware/sprintf.c \
        bertos/struct/heap.c \
-       bertos/kern/coop.c \
-       bertos/kern/preempt.c \
        bertos/kern/irq.c \
        bertos/kern/proc.c \
        bertos/kern/proc_test.c \
index 4d71d0dac0cc8326a80e916d0780689db640414b..63be128ce6d7e8442670985b2061b746eb4d015e 100644 (file)
@@ -39,8 +39,6 @@ lm3s1968_CSRC = \
        bertos/kern/monitor.c \
        bertos/kern/proc_test.c \
        bertos/kern/proc.c \
-       bertos/kern/coop.c \
-       bertos/kern/preempt.c \
        bertos/kern/signal.c \
        bertos/cpu/cortex-m3/drv/gpio_lm3s.c \
        bertos/cpu/cortex-m3/drv/clock_lm3s.c \
index e5a3bc74a34086a35a5bb1e729b02fa8c0b246c7..59ec1cb647b7c490a49fe6c3c7a1b98a68ae1d01 100644 (file)
@@ -21,8 +21,6 @@ lpc2378_USER_CSRC = \
        bertos/cpu/arm/drv/timer_lpc2.c \
        bertos/mware/event.c \
        bertos/kern/proc.c \
-       bertos/kern/coop.c \
-       bertos/kern/preempt.c \
        bertos/kern/proc_test.c \
        bertos/kern/monitor.c \
        bertos/mware/sprintf.c \
index 71a25d31bd34123e740dbc27accfa47248cc0023..d79f46feb4ddcc23ffd0bc0958e9a20765b189eb 100755 (executable)
@@ -39,7 +39,6 @@ SRC_LIST="
        bertos/kern/proc.c
        bertos/kern/signal.c
        bertos/kern/sem.c
-       bertos/kern/coop.c
        bertos/kern/preempt.c
        bertos/mware/event.c
        bertos/mware/formatwr.c