git-svn-id: svn://svn.code.sf.net/p/chibios/svn/trunk@501 35acf78f-673a-0410-8e92-d51de3d6d3f4

demos/ARM7-AT91SAM7X-GCC/chconf.h

@@ -59,14 +59,6 @@
  *  the kernel.*/
 #define CH_USE_EVENTS
 
-/** Configuration option: if specified then the
- *  \p chThdGetExitEventSource() function is included in the kernel.
- * @note requires \p CH_USE_EVENTS.
- * @deprecated \p THREAD_EXT_EXIT should be used, this functionality will be
- *             removed in version 1.0.0.
- */
-#define CH_USE_EVENTS_TIMEOUT
-
 /** Configuration option: if specified then the Synchronous Messages APIs are
  *  included in the kernel.*/
 #define CH_USE_MESSAGES
@@ -83,8 +75,9 @@
 
 /** Configuration option: if specified then the
  *  \p chThdGetExitEventSource() function is included in the kernel.
- * @note requires \p CH_USE_MESSAGES.
+ * @note requires \p CH_USE_EVENTS.
- * @note requires \p CH_USE_EVENTS.*/
+ * @deprecated \p THREAD_EXT_EXIT should be used, this functionality will be
+ *             removed in version 1.0.0.*/
 #define CH_USE_EXIT_EVENT
 
 /** Configuration option: if specified then the I/O queues APIs are included

demos/ARM7-AT91SAM7X-WEB-GCC/chconf.h

@@ -59,11 +59,6 @@
  *  the kernel.*/
 #define CH_USE_EVENTS
 
-/** Configuration option: if specified then the \p chEvtWaitTimeout()
- *  function is included in the kernel.
- * @note requires \p CH_USE_EVENTS.*/
-#define CH_USE_EVENTS_TIMEOUT
-
 /** Configuration option: if specified then the Synchronous Messages APIs are
  *  included in the kernel.*/
 #define CH_USE_MESSAGES

demos/ARM7-LPC214x-G++/chconf.h

@@ -59,11 +59,6 @@
  *  the kernel.*/
 #define CH_USE_EVENTS
 
-/** Configuration option: if specified then the \p chEvtWaitTimeout()
- *  function is included in the kernel.
- * @note requires \p CH_USE_EVENTS.*/
-#define CH_USE_EVENTS_TIMEOUT
-
 /** Configuration option: if specified then the Synchronous Messages APIs are
  *  included in the kernel.*/
 #define CH_USE_MESSAGES

demos/ARM7-LPC214x-GCC-minimal/chconf.h

@@ -59,11 +59,6 @@
  *  the kernel.*/
 //#define CH_USE_EVENTS
 
-/** Configuration option: if specified then the \p chEvtWaitTimeout()
- *  function is included in the kernel.
- * @note requires \p CH_USE_EVENTS.*/
-//#define CH_USE_EVENTS_TIMEOUT
-
 /** Configuration option: if specified then the Synchronous Messages APIs are
  *  included in the kernel.*/
 //#define CH_USE_MESSAGES

demos/ARM7-LPC214x-GCC/chconf.h

@@ -59,11 +59,6 @@
  *  the kernel.*/
 #define CH_USE_EVENTS
 
-/** Configuration option: if specified then the \p chEvtWaitTimeout()
- *  function is included in the kernel.
- * @note requires \p CH_USE_EVENTS.*/
-#define CH_USE_EVENTS_TIMEOUT
-
 /** Configuration option: if specified then the Synchronous Messages APIs are
  *  included in the kernel.*/
 #define CH_USE_MESSAGES

demos/ARMCM3-STM32F103-GCC/chconf.h

@@ -59,11 +59,6 @@
  *  the kernel.*/
 #define CH_USE_EVENTS
 
-/** Configuration option: if specified then the \p chEvtWaitTimeout()
- *  function is included in the kernel.
- * @note requires \p CH_USE_EVENTS.*/
-#define CH_USE_EVENTS_TIMEOUT
-
 /** Configuration option: if specified then the Synchronous Messages APIs are
  *  included in the kernel.*/
 #define CH_USE_MESSAGES

demos/AVR-AT90CANx-GCC/chconf.h

@@ -59,11 +59,6 @@
  *  the kernel.*/
 #define CH_USE_EVENTS
 
-/** Configuration option: if specified then the \p chEvtWaitTimeout()
- *  function is included in the kernel.
- * @note requires \p CH_USE_EVENTS.*/
-#define CH_USE_EVENTS_TIMEOUT
-
 /** Configuration option: if specified then the Synchronous Messages APIs are
  *  included in the kernel.*/
 #define CH_USE_MESSAGES

demos/AVR-ATmega128-GCC/chconf.h

@@ -59,11 +59,6 @@
  *  the kernel.*/
 #define CH_USE_EVENTS
 
-/** Configuration option: if specified then the \p chEvtWaitTimeout()
- *  function is included in the kernel.
- * @note requires \p CH_USE_EVENTS.*/
-#define CH_USE_EVENTS_TIMEOUT
-
 /** Configuration option: if specified then the Synchronous Messages APIs are
  *  included in the kernel.*/
 #define CH_USE_MESSAGES

demos/MSP430-MSP430x1611-GCC/chconf.h

@@ -64,11 +64,6 @@
  *  the kernel.*/
 #define CH_USE_EVENTS
 
-/** Configuration option: if specified then the \p chEvtWaitTimeout()
- *  function is included in the kernel.
- * @note requires \p CH_USE_EVENTS.*/
-#define CH_USE_EVENTS_TIMEOUT
-
 /** Configuration option: if specified then the Synchronous Messages APIs are
  *  included in the kernel.*/
 #define CH_USE_MESSAGES

demos/Win32-MinGW/chconf.h

@@ -59,11 +59,6 @@
  *  the kernel.*/
 #define CH_USE_EVENTS
 
-/** Configuration option: if specified then the \p chEvtWaitTimeout()
- *  function is included in the kernel.
- * @note requires \p CH_USE_EVENTS.*/
-#define CH_USE_EVENTS_TIMEOUT
-
 /** Configuration option: if specified then the Synchronous Messages APIs are
  *  included in the kernel.*/
 #define CH_USE_MESSAGES

docs/Doxyfile

@@ -5,7 +5,7 @@
 #---------------------------------------------------------------------------
 DOXYFILE_ENCODING      = UTF-8
 PROJECT_NAME           = ChibiOS/RT
-PROJECT_NUMBER         = "0.7.4 beta"
+PROJECT_NUMBER         = "0.8.0 beta"
 OUTPUT_DIRECTORY       = .
 CREATE_SUBDIRS         = NO
 OUTPUT_LANGUAGE        = English

docs/index.html

@@ -12,7 +12,7 @@
     </tr>
     <tr>
       <td style="text-align: center; vertical-align: top; width: 150px;">Current
-Version 0.7.4<br>
+Version 0.8.0<br>
 -<br>
       <a href="http://sourceforge.net/projects/chibios/" rel="me" target="_top">Project on SourceForge</a><br>
       <a href="html/index.html" target="_top" rel="me">Documentation</a><br>

readme.txt

@@ -73,10 +73,23 @@ Win32-MinGW            - ChibiOS/RT simulator and demo into a WIN32 process,
 *** Releases                                                              ***
 *****************************************************************************
 
-*** 0.7.4 ***
+*** 0.8.0 ***
+- NEW: Improved events subsystems, now it is also possible to use it just as
+  "event flags" without have to use event handler callbacks.
+  Some new APIs were introduced:
+  * chEvtWaitOne()  - Wait for a single event.
+  * chEvtWaitAny()  - Wait with OR condition.
+  * chEvtWaitAll()  - Wait with AND condition.
+  * chEvtDispatch() - Invokes the event handlers associated to a mask.
+  * chEvtPend()     - Quickly self-pends some events.
+  All the "wait"-type APIs have a timeout-capable variant.
+- CHANGE: The old chEvtWait() and chEvtWaitTimeout() APIs are now deprecated
+  and will be removed in version 1.0.0.
+- CHANGE: Removed the CH_USE_EVENT_TIMEOUT configuration option in order to
+  make the chconf.h file simpler.
 - CHANGE: Modified chDbgAssert() to syntax check the condition even when the
   CH_USE_DEBUG is disabled, it produces no code but allows to check the
-  option without have to compile twice.
+  optional code without have to compile twice.
 - Added a new benchmark to the test suite (timers set/reset performance).
 - Renamed the macro fifo_init() to queue_init() because it is used to init
   both FIFO queues and priority queues.

src/chevents.c

@@ -76,14 +76,34 @@ void chEvtUnregister(EventSource *esp, EventListener *elp) {
 /**
  * Clears the pending events specified in the mask.
  * @param mask the events to be cleared
+ * @return The pending events that were cleared.
  */
-void chEvtClear(eventmask_t mask) {
+eventmask_t chEvtClear(eventmask_t mask) {
+  eventmask_t m;
 
   chSysLock();
 
+  m = currp->p_epending & mask;
   currp->p_epending &= ~mask;
 
   chSysUnlock();
+  return m;
+}
+
+/**
+ * Makes an events mask pending in the current thread, this is \b much faster than
+ * using \p chEvtBreadcast().
+ * @param mask the events to be pended
+ * @return The current pending events mask.
+ */
+eventmask_t chEvtPend(eventmask_t mask) {
+
+  chSysLock();
+
+  mask = (currp->p_epending |= mask);
+
+  chSysUnlock();
+  return mask;
 }
 
 /**
@@ -113,13 +133,125 @@ void chEvtBroadcastI(EventSource *esp) {
     Thread *tp = elp->el_listener;
 
     tp->p_epending |= EventMask(elp->el_id);
-    if ((tp->p_state == PRWTEVENT) && (tp->p_epending & tp->p_ewmask))
+
+    /* Test on the AND/OR conditions wait states.*/
+    if ((tp->p_state == PRWTOREVT) &&
+        ((tp->p_epending & tp->p_ewmask) != 0))
       chSchReadyI(tp)->p_rdymsg = RDY_OK;
+    else if ((tp->p_state == PRWTANDEVT) &&
+             ((tp->p_epending & tp->p_ewmask) == tp->p_ewmask))
+      chSchReadyI(tp)->p_rdymsg = RDY_OK;
+
     elp = elp->el_next;
   }
 }
 
-#ifdef CH_USE_EVENTS_TIMEOUT
+/**
+ * Waits for a single event.
+ * A pending event among those specified in \p ewmask is selected, cleared and
+ * its mask returned.
+ * @param ewmask mask of the events that the function should wait for,
+ *               \p ALL_EVENTS enables all the events
+ * @param time the number of ticks before the operation timouts
+ * @return The mask of the lowest id served and cleared event.
+ * @retval 0 if the specified timeout expired
+ * @note Only a single event is served in the function, the one with the
+ *       lowest event id. The function is meant to be invoked into a loop in
+ *       order to serve all the pending events.<br>
+ *       This means that Event Listeners with a lower event identifier have
+ *       an higher priority.
+ */
+eventmask_t chEvtWaitOneTimeout(eventmask_t ewmask, systime_t time) {
+  eventmask_t m;
+
+  chSysLock();
+
+  if ((m = (currp->p_epending & ewmask)) == 0) {
+    currp->p_ewmask = ewmask;
+    if (chSchGoSleepTimeoutS(PRWTOREVT, time) < RDY_OK)
+      return (eventmask_t)0;
+    m = currp->p_epending & ewmask;
+  }
+//  m ^= m & (m - 1);
+  m &= -m;
+  currp->p_epending &= ~m;
+
+  chSysUnlock();
+  return m;
+}
+
+/**
+ * Waits for any of the specified events.
+ * The function waits for any event among those specified in \p ewmask to
+ * become pending then the events are cleared and returned.
+ * @param ewmask mask of the events that the function should wait for,
+ *               \p ALL_EVENTS enables all the events
+ * @param time the number of ticks before the operation timouts
+ * @return The mask of the served and cleared events.
+ * @retval 0 if the specified timeout expired
+ */
+eventmask_t chEvtWaitAnyTimeout(eventmask_t ewmask, systime_t time) {
+  eventmask_t m;
+
+  chSysLock();
+
+  if ((m = (currp->p_epending & ewmask)) == 0) {
+    currp->p_ewmask = ewmask;
+    if (chSchGoSleepTimeoutS(PRWTOREVT, time) < RDY_OK)
+      return (eventmask_t)0;
+    m = currp->p_epending & ewmask;
+  }
+  currp->p_epending &= ~m;
+
+  chSysUnlock();
+  return m;
+}
+
+/**
+ * Waits for all the specified event flags then clears them.
+ * The function waits for all the events specified in \p ewmask to become
+ * pending then the events are cleared and returned.
+ * @param ewmask mask of the event ids that the function should wait for
+ * @param time the number of ticks before the operation timouts
+ * @return The mask of the served and cleared events.
+ * @retval 0 if the specified timeout expired
+ */
+eventmask_t chEvtWaitAllTimeout(eventmask_t ewmask, systime_t time) {
+
+  chSysLock();
+
+  if ((currp->p_epending & ewmask) != ewmask) {
+    currp->p_ewmask = ewmask;
+    if (chSchGoSleepTimeoutS(PRWTANDEVT, time) < RDY_OK)
+      return (eventmask_t)0;
+  }
+  currp->p_epending &= ~ewmask;
+
+  chSysUnlock();
+  return ewmask;
+}
+
+/**
+ * Invokes the event handlers associated with a mask.
+ * @param mask mask of the events that should be invoked by the function,
+ *               \p ALL_EVENTS enables all the sources
+ * @param handlers an array of \p evhandler_t. The array must be
+ *                 have indexes from zero up the higher registered event
+ *                 identifier. The array can be \p NULL or contain \p NULL
+ *                 elements (no callbacks specified).
+ */
+void chEvtDispatch(const evhandler_t handlers[], eventmask_t mask) {
+  eventid_t i;
+  eventmask_t m;
+
+  i = 0, m = 1;
+  while ((mask & m) == 0) {
+    i += 1, m <<= 1;
+    mask &= ~m;
+    handlers[i](i);
+  }
+}
+
 /**
  * The function waits for an event and returns the event identifier, if an
  * event handler is specified then the handler is executed before returning.
@@ -135,6 +267,8 @@ void chEvtBroadcastI(EventSource *esp) {
  *       that all events are received and served.<br>
  *       This means that Event Listeners with a lower event identifier have
  *       an higher priority.
+ * @deprecated Please use \p chEvtWaitOne() and \p chEvtDispatch() instead,
+ *             this function will be removed in version 1.0.0.
  */
 eventid_t chEvtWait(eventmask_t ewmask,
                     const evhandler_t handlers[]) {
@@ -160,8 +294,8 @@ eventid_t chEvtWait(eventmask_t ewmask,
  *       that all events are received and served.<br>
  *       This means that Event Listeners with a lower event identifier have
  *       an higher priority.
- * @note The function is available only if the \p CH_USE_EVENTS_TIMEOUT
+ * @deprecated Please use \p chEvtWaitOneTimeout() and \p chEvtDispatch()
- *       option is enabled in \p chconf.h.
+ *             instead, this function will be removed in version 1.0.0.
  */
 eventid_t chEvtWaitTimeout(eventmask_t ewmask,
                            const evhandler_t handlers[],
@@ -173,7 +307,7 @@ eventid_t chEvtWaitTimeout(eventmask_t ewmask,
 
   if ((currp->p_epending & ewmask) == 0) {
     currp->p_ewmask = ewmask;
-    if (chSchGoSleepTimeoutS(PRWTEVENT, time) < RDY_OK)
+    if (chSchGoSleepTimeoutS(PRWTOREVT, time) < RDY_OK)
       return RDY_TIMEOUT;
   }
   i = 0, m = 1;
@@ -189,33 +323,6 @@ eventid_t chEvtWaitTimeout(eventmask_t ewmask,
   return i;
 }
 
-#else /* !CH_USE_EVENTS_TIMEOUT */
-eventid_t chEvtWait(eventmask_t ewmask,
-                    const evhandler_t handlers[]) {
-  eventid_t i;
-  eventmask_t m;
-
-  chSysLock();
-
-  if ((currp->p_epending & ewmask) == 0) {
-    currp->p_ewmask = ewmask;
-    chSchGoSleepS(PRWTEVENT);
-  }
-  i = 0, m = 1;
-  while ((currp->p_epending & ewmask & m) == 0)
-    i += 1, m <<= 1;
-  currp->p_epending &= ~m;
-
-  chSysUnlock();
-
-  if (handlers && handlers[i])
-    handlers[i](i);
-
-  return i;
-}
-
-#endif /* CH_USE_EVENTS_TIMEOUT */
-
 #endif /* CH_USE_EVENTS */
 
 /** @} */

src/include/events.h

@@ -81,20 +81,55 @@ extern "C" {
 #endif
   void chEvtRegister(EventSource *esp, EventListener *elp, eventid_t eid);
   void chEvtUnregister(EventSource *esp, EventListener *elp);
-  void chEvtClear(eventmask_t mask);
+  eventmask_t chEvtClear(eventmask_t mask);
+  eventmask_t chEvtPend(eventmask_t mask);
+  eventmask_t chEvtWaitOneTimeout(eventmask_t ewmask, systime_t time);
+  eventmask_t chEvtWaitAnyTimeout(eventmask_t ewmask, systime_t time);
+  eventmask_t chEvtWaitAllTimeout(eventmask_t ewmask, systime_t time);
   void chEvtBroadcast(EventSource *esp);
   void chEvtBroadcastI(EventSource *esp);
   eventid_t chEvtWait(eventmask_t ewmask,
                       const evhandler_t handlers[]);
-#ifdef CH_USE_EVENTS_TIMEOUT
   eventid_t chEvtWaitTimeout(eventmask_t ewmask,
                              const evhandler_t handlers[],
                              systime_t time);
-#endif
 #ifdef __cplusplus
 }
 #endif
 
+/**
+ * A pending event among those specified in \p ewmask is selected, cleared and
+ * its mask returned.
+ * @param ewmask mask of the events that the function should wait for,
+ *               \p ALL_EVENTS enables all the events
+ * @return The mask of the lowest id served and cleared event.
+ * @note Only a single event is served in the function, the one with the
+ *       lowest event id. The function is meant to be invoked into a loop in
+ *       order to serve all the pending events.<br>
+ *       This means that Event Listeners with a lower event identifier have
+ *       an higher priority.
+ */
+#define chEvtWaitOne(ewmask) chEvtWaitOneTimeout(ewmask, TIME_INFINITE)
+
+/**
+ * Waits for any of the specified events.
+ * The function waits for any event among those specified in \p ewmask to
+ * become pending then the events are cleared and returned.
+ * @param ewmask mask of the events that the function should wait for,
+ *               \p ALL_EVENTS enables all the events
+ * @return The mask of the served and cleared events.
+ */
+#define chEvtWaitAny(ewmask) chEvtWaitAnyTimeout(ewmask, TIME_INFINITE)
+
+/**
+ * Waits for all the specified event flags then clears them.
+ * The function waits for all the events specified in \p ewmask to become
+ * pending then the events are cleared and returned.
+ * @param ewmask mask of the event ids that the function should wait for
+ * @return The mask of the served and cleared events.
+ */
+#define chEvtWaitAll(ewmask) chEvtWaitAllTimeout(ewmask, TIME_INFINITE)
+
 /*
  * Old function names, deprecated, will be removed in some next release.
  */

src/include/threads.h

@@ -127,17 +127,22 @@ struct Thread {
 /** Thread state: Waiting on a mutex. */
 #define PRWTMTX     4
 /** Thread state: Waiting in \p chThdSleep() or \p chThdSleepUntil(). */
-#define PRSLEEP     5
+#define PRWTCOND    5
+/** Thread state: Waiting in \p chCondWait(). */
+#define PRSLEEP     6
 /** Thread state: Waiting in \p chThdWait(). */
-#define PRWAIT      6
+#define PRWAIT      7
-/** Thread state: Waiting in \p chEvtWait(). */
+/** Thread state: Waiting in \p chEvtWaitOneTimeout() or
-#define PRWTEVENT   7
+    \p chEvtWaitAnyTimeout(). */
+#define PRWTOREVT   8
+/** Thread state: Waiting in \p chEvtWaitAllTimeout(). */
+#define PRWTANDEVT  9
 /** Thread state: Waiting in \p chMsgSend(). */
-#define PRSNDMSG    8
+#define PRSNDMSG    10
 /** Thread state: Waiting in \p chMsgWait(). */
-#define PRWTMSG     9
+#define PRWTMSG     11
 /** Thread state: After termination.*/
-#define PREXIT      10
+#define PREXIT      12
 
 /*
  * Various flags into the thread p_flags field.

src/templates/chconf.h

@@ -64,11 +64,6 @@
  *  the kernel.*/
 #define CH_USE_EVENTS
 
-/** Configuration option: if specified then the \p chEvtWaitTimeout()
- *  function is included in the kernel.
- * @note requires \p CH_USE_EVENTS.*/
-#define CH_USE_EVENTS_TIMEOUT
-
 /** Configuration option: if specified then the Synchronous Messages APIs are
  *  included in the kernel.*/
 #define CH_USE_MESSAGES