X-Git-Url: https://codewiz.org/gitweb?a=blobdiff_plain;f=bertos%2Fkern%2Fsignal.c;h=19941f9477ae8775fe025a919a396bcc050bf76c;hb=32d1445272120a254d77ce8d1af1f527da7a2c17;hp=d7633a147809b582c64b2e300489ac2917658b12;hpb=03eac0b24146fe73d585c998eca4c1c2873f1acb;p=bertos.git

diff --git a/bertos/kern/signal.c b/bertos/kern/signal.c
index d7633a14..19941f94 100644
--- a/bertos/kern/signal.c
+++ b/bertos/kern/signal.c
@@ -28,7 +28,6 @@
  *
  * Copyright 2004, 2008 Develer S.r.l. (http://www.develer.com/)
  * Copyright 1999, 2000, 2001 Bernie Innocenti <bernie@codewiz.org>
- *
  * -->
  *
  * \brief IPC signals implementation.
@@ -93,35 +92,41 @@
  *  - Do not sleep between starting the asynchronous task that will fire
  *    SIG_SINGLE, and the call to  sig_wait().
  *  - Do not call system functions that may implicitly sleep, such as
- *    timer_delayTickes().
+ *    timer_delayTicks().
  *
  * \version $Id$
- *
  * \author Bernie Innocenti <bernie@codewiz.org>
  */
 
 #include "signal.h"
 
+#include "cfg/cfg_timer.h"
 #include <cfg/debug.h>
-#include <drv/timer.h>
+#include <cfg/depend.h>
+
+#include <cpu/irq.h>
 #include <kern/proc.h>
 #include <kern/proc_p.h>
- 
+
 
 #if CONFIG_KERN_SIGNALS
 
+// Check config dependencies
+CONFIG_DEPEND(CONFIG_KERN_SIGNALS, CONFIG_KERN);
+
 /**
  * Check if any of the signals in \a sigs has occurred and clear them.
+ *
  * \return the signals that have occurred.
  */
 sigmask_t sig_check(sigmask_t sigs)
 {
 	sigmask_t result;
-	cpuflags_t flags;
+	cpu_flags_t flags;
 
 	IRQ_SAVE_DISABLE(flags);
-	result = CurrentProcess->sig_recv & sigs;
-	CurrentProcess->sig_recv &= ~sigs;
+	result = current_process->sig_recv & sigs;
+	current_process->sig_recv &= ~sigs;
 	IRQ_RESTORE(flags);
 
 	return result;
@@ -135,38 +140,40 @@ sigmask_t sig_check(sigmask_t sigs)
 sigmask_t sig_wait(sigmask_t sigs)
 {
 	sigmask_t result;
-	cpuflags_t flags;
+
+	/* Sleeping with IRQs disabled or preemption forbidden is illegal */
+	IRQ_ASSERT_ENABLED();
+	ASSERT(proc_preemptAllowed());
 
 	/*
 	 * This is subtle: there's a race condition where a concurrent
-	 * process or an interrupt calls sig_signal() to set a bit in
-	 * out sig_recv just after we have checked for it, but before
-	 * we've set sig_wait to tell them we want to be awaken.
+	 * process or an interrupt may call sig_signal() to set a bit in
+	 * Process.sig_recv just after we have checked for it, but before
+	 * we've set Process.sig_wait to let them know we want to be awaken.
 	 *
-	 * In this case, we'd deadlock with the signal bit already
-	 * set and the process never being reinserted into the ready
-	 * list.
+	 * In this case, we'd deadlock with the signal bit already set
+	 * and the process never being reinserted into the ready list.
 	 */
-	IRQ_SAVE_DISABLE(flags);
+	IRQ_DISABLE;
 
 	/* Loop until we get at least one of the signals */
-	while (!(result = CurrentProcess->sig_recv & sigs))
+	while (!(result = current_process->sig_recv & sigs))
 	{
 		/*
 		 * Tell "them" that we want to be awaken when any of these
 		 * signals arrives.
 		 */
-		CurrentProcess->sig_wait = sigs;
+		current_process->sig_wait = sigs;
 
 		/*
-		 * Go to sleep and proc_schedule() another process.
+		 * Go to sleep and proc_switch() to another process.
 		 *
-		 * We re-enable IRQs because proc_schedule() does not
+		 * We re-enable IRQs because proc_switch() does not
 		 * guarantee to save and restore the interrupt mask.
 		 */
-		IRQ_RESTORE(flags);
-		proc_schedule();
-		IRQ_SAVE_DISABLE(flags);
+		IRQ_ENABLE;
+		proc_switch();
+		IRQ_DISABLE;
 
 		/*
 		 * When we come back here, the wait mask must have been
@@ -174,17 +181,20 @@ sigmask_t sig_wait(sigmask_t sigs)
 		 * one of the signals we were expecting must have been
 		 * delivered to us.
 		 */
-		ASSERT(!CurrentProcess->sig_wait);
-		ASSERT(CurrentProcess->sig_recv & sigs);
+		ASSERT(!current_process->sig_wait);
+		ASSERT(current_process->sig_recv & sigs);
 	}
 
 	/* Signals found: clear them and return */
-	CurrentProcess->sig_recv &= ~sigs;
+	current_process->sig_recv &= ~sigs;
 
-	IRQ_RESTORE(flags);
+	IRQ_ENABLE;
 	return result;
 }
 
+#if CONFIG_TIMER_EVENTS
+
+#include <drv/timer.h>
 /**
  * Sleep until any of the signals in \a sigs or \a timeout ticks elapse.
  * If the timeout elapse a SIG_TIMEOUT is added to the received signal(s).
@@ -195,7 +205,7 @@ sigmask_t sig_waitTimeout(sigmask_t sigs, ticks_t timeout)
 {
 	Timer t;
 	sigmask_t res;
-	cpuflags_t flags;
+	cpu_flags_t flags;
 
 	ASSERT(!sig_check(SIG_TIMEOUT));
 	ASSERT(!(sigs & SIG_TIMEOUT));
@@ -215,6 +225,8 @@ sigmask_t sig_waitTimeout(sigmask_t sigs, ticks_t timeout)
 	return res;
 }
 
+#endif // CONFIG_TIMER_EVENTS
+
 
 /**
  * Send the signals \a sigs to the process \a proc.
@@ -224,7 +236,7 @@ sigmask_t sig_waitTimeout(sigmask_t sigs, ticks_t timeout)
  */
 void sig_signal(Process *proc, sigmask_t sigs)
 {
-	cpuflags_t flags;
+	cpu_flags_t flags;
 
 	/* See comment in sig_wait() for why this protection is necessary */
 	IRQ_SAVE_DISABLE(flags);
@@ -235,9 +247,14 @@ void sig_signal(Process *proc, sigmask_t sigs)
 	/* Check if process needs to be awoken */
 	if (proc->sig_recv & proc->sig_wait)
 	{
-		/* Wake up process and enqueue in ready list */
+		/*
+		 * Wake up process and enqueue in ready list.
+		 *
+		 * Move this process to the head of the ready list, so that it
+		 * will be chosen at the next scheduling point.
+		 */
 		proc->sig_wait = 0;
-		SCHED_ENQUEUE(proc);
+		SCHED_ENQUEUE_HEAD(proc);
 	}
 
 	IRQ_RESTORE(flags);