score: Generalize _Event_Timeout()

Add a thread wait timeout code.  Replace _Event_Timeout() with a general
purpose _Thread_Timeout() watchdog handler.

Update #2273.

cpukit/rtems/Makefile.am

@@ -210,7 +210,6 @@ librtems_a_SOURCES += src/eventreceive.c
 librtems_a_SOURCES += src/eventseize.c
 librtems_a_SOURCES += src/eventsend.c
 librtems_a_SOURCES += src/eventsurrender.c
-librtems_a_SOURCES += src/eventtimeout.c
 librtems_a_SOURCES += src/systemeventsend.c
 librtems_a_SOURCES += src/systemeventreceive.c
 

cpukit/rtems/src/eventseize.c

@@ -89,7 +89,13 @@ void _Event_Seize(
   _Giant_Acquire( cpu_self );
 
   if ( ticks ) {
-    _Watchdog_Initialize( &executing->Timer, _Event_Timeout, 0, executing );
+    _Thread_Wait_set_timeout_code( executing, RTEMS_TIMEOUT );
+    _Watchdog_Initialize(
+      &executing->Timer,
+      _Thread_Timeout,
+      0,
+      executing
+    );
     _Watchdog_Insert_ticks( &executing->Timer, ticks );
   }
 

cpukit/score/Makefile.am

@@ -290,6 +290,7 @@ libscore_a_SOURCES += src/thread.c src/threadchangepriority.c \
     src/threadstackallocate.c src/threadstackfree.c src/threadstart.c \
     src/threadstartmultitasking.c src/iterateoverthreads.c
 libscore_a_SOURCES += src/threadglobalconstruction.c
+libscore_a_SOURCES += src/threadtimeout.c
 libscore_a_SOURCES += src/threadyield.c
 
 if HAS_SMP

cpukit/score/include/rtems/score/thread.h

@@ -354,6 +354,11 @@ typedef struct {
    */
   uint32_t              return_code;
 
+  /**
+   * @brief Code to set the timeout return code in _Thread_Timeout().
+   */
+  uint32_t timeout_code;
+
   /** This field points to the thread queue on which this thread is blocked. */
   Thread_queue_Control *queue;
 

cpukit/score/include/rtems/score/threadimpl.h

@@ -1257,6 +1257,28 @@ RTEMS_INLINE_ROUTINE bool _Thread_Wait_flags_try_change(
   return success;
 }
 
+/**
+ * @brief Sets the thread wait timeout code.
+ *
+ * @param[in] the_thread The thread.
+ * @param[in] timeout_code The new thread wait timeout code.
+ */
+RTEMS_INLINE_ROUTINE void _Thread_Wait_set_timeout_code(
+  Thread_Control *the_thread,
+  uint32_t        timeout_code
+)
+{
+  the_thread->Wait.timeout_code = timeout_code;
+}
+
+/**
+ * @brief General purpose thread wait timeout.
+ *
+ * @param[in] id Unused.
+ * @param[in] arg The thread.
+ */
+void _Thread_Timeout( Objects_Id id, void *arg );
+
 RTEMS_INLINE_ROUTINE void _Thread_Debug_set_real_processor(
   Thread_Control  *the_thread,
   Per_CPU_Control *cpu

cpukit/score/src/threadtimeout.c

@@ -1,8 +1,9 @@
 /**
  * @file
  *
- *  @brief Timeout Event
- *  @ingroup ClassicEvent
+ * @brief Thread Wait Timeout
+ *
+ * @ingroup ScoreThread
  */
 
 /*
@@ -18,15 +19,18 @@
   #include "config.h"
 #endif
 
-#include <rtems/rtems/eventimpl.h>
 #include <rtems/score/threadimpl.h>
 
-void _Event_Timeout(
-  Objects_Id  id,
-  void       *arg
-)
+static void _Thread_Do_timeout( Thread_Control *the_thread )
+{
+  the_thread->Wait.return_code = the_thread->Wait.timeout_code;
+  _Thread_Lock_restore_default( the_thread );
+}
+
+void _Thread_Timeout( Objects_Id id, void *arg )
 {
   Thread_Control    *the_thread;
+  ISR_lock_Control  *thread_lock;
   ISR_lock_Context   lock_context;
   Thread_Wait_flags  wait_flags;
   Thread_Wait_flags  wait_class;
@@ -36,7 +40,7 @@ void _Event_Timeout(
   bool               unblock;
 
   the_thread = arg;
-  _Thread_Lock_acquire_default( the_thread, &lock_context );
+  thread_lock = _Thread_Lock_acquire( the_thread, &lock_context );
 
   wait_flags = _Thread_Wait_flags_get( the_thread );
   wait_class = wait_flags & THREAD_WAIT_CLASS_MASK;
@@ -49,20 +53,20 @@ void _Event_Timeout(
   );
 
   if ( success ) {
-    the_thread->Wait.return_code = RTEMS_TIMEOUT;
+    _Thread_Do_timeout( the_thread );
     unblock = false;
   } else if ( _Thread_Wait_flags_get( the_thread ) == blocked ) {
-    the_thread->Wait.return_code = RTEMS_TIMEOUT;
     _Thread_Wait_flags_set(
       the_thread,
       wait_class | THREAD_WAIT_STATE_READY_AGAIN
     );
+    _Thread_Do_timeout( the_thread );
     unblock = true;
   } else {
     unblock = false;
   }
 
-  _Thread_Lock_release_default( the_thread, &lock_context );
+  _Thread_Lock_release( thread_lock, &lock_context );
 
   if ( unblock ) {
     _Thread_Unblock( the_thread );

testsuites/sptests/spintrcritical10/init.c

@@ -78,7 +78,7 @@ static void any_satisfy_before_timeout(rtems_id timer, void *arg)
     );
     rtems_test_assert(thread->Wait.return_code == RTEMS_SUCCESSFUL);
 
-    _Event_Timeout(0, thread);
+    _Thread_Timeout(0, thread);
 
     rtems_test_assert(
       *(rtems_event_set *) thread->Wait.return_argument == GREEN
@@ -175,7 +175,7 @@ static void all_satisfy_before_timeout(rtems_id timer, void *arg)
     );
     rtems_test_assert(thread->Wait.return_code == RTEMS_SUCCESSFUL);
 
-    _Event_Timeout(0, thread);
+    _Thread_Timeout(0, thread);
 
     rtems_test_assert(
       *(rtems_event_set *) thread->Wait.return_argument == EVENTS
@@ -251,7 +251,7 @@ static void timeout_before_satisfied(rtems_id timer, void *arg)
     );
     rtems_test_assert(thread->Wait.return_code == RTEMS_SUCCESSFUL);
 
-    _Event_Timeout(0, thread);
+    _Thread_Timeout(0, thread);
 
     rtems_test_assert(
       *(rtems_event_set *) thread->Wait.return_argument == DEADBEEF