[PATCH 14/16] score: Add _Thread_Continue()

Sebastian Huber sebastian.huber at embedded-brains.de
Mon Oct 23 13:53:45 UTC 2017


Update #3117.
Update #3182.
---
 cpukit/score/include/rtems/score/threadimpl.h | 18 ++++++++++++++++--
 cpukit/score/src/threadtimeout.c              | 25 +++++++++++++++++--------
 2 files changed, 33 insertions(+), 10 deletions(-)

diff --git a/cpukit/score/include/rtems/score/threadimpl.h b/cpukit/score/include/rtems/score/threadimpl.h
index 8c87f98cb8..5f6a5eb2d0 100644
--- a/cpukit/score/include/rtems/score/threadimpl.h
+++ b/cpukit/score/include/rtems/score/threadimpl.h
@@ -1841,11 +1841,25 @@ RTEMS_INLINE_ROUTINE Status_Control _Thread_Wait_get_status(
 }
 
 /**
+ * @brief Cancels a blocking operation so that the thread can continue its
+ * execution.
+ *
+ * In case this function actually cancelled the blocking operation, then the
+ * thread wait return code is set to the specified status.
+ *
+ * A specialization of this function is _Thread_Timeout().
+ *
+ * @param[in] the_thread The thread.
+ * @param[in] status The thread wait status.
+ */
+void _Thread_Continue( Thread_Control *the_thread, Status_Control status );
+
+/**
  * @brief General purpose thread wait timeout.
  *
- * @param[in] watchdog The thread timer watchdog.
+ * @param[in] the_watchdog The thread timer watchdog.
  */
-void _Thread_Timeout( Watchdog_Control *watchdog );
+void _Thread_Timeout( Watchdog_Control *the_watchdog );
 
 RTEMS_INLINE_ROUTINE void _Thread_Timer_initialize(
   Thread_Timer_information *timer,
diff --git a/cpukit/score/src/threadtimeout.c b/cpukit/score/src/threadtimeout.c
index 8bcdc3806d..8ea5a651f0 100644
--- a/cpukit/score/src/threadtimeout.c
+++ b/cpukit/score/src/threadtimeout.c
@@ -22,14 +22,11 @@
 #include <rtems/score/threadimpl.h>
 #include <rtems/score/status.h>
 
-void _Thread_Timeout( Watchdog_Control *watchdog )
+void _Thread_Continue( Thread_Control *the_thread, Status_Control status )
 {
-  Thread_Control       *the_thread;
-  Thread_queue_Context  queue_context;
-  Thread_Wait_flags     wait_flags;
-  bool                  unblock;
-
-  the_thread = RTEMS_CONTAINER_OF( watchdog, Thread_Control, Timer.Watchdog );
+  Thread_queue_Context queue_context;
+  Thread_Wait_flags    wait_flags;
+  bool                 unblock;
 
   _Thread_queue_Context_initialize( &queue_context );
   _Thread_queue_Context_clear_priority_updates( &queue_context );
@@ -44,7 +41,7 @@ void _Thread_Timeout( Watchdog_Control *watchdog )
 
     _Thread_Wait_cancel( the_thread, &queue_context );
 
-    the_thread->Wait.return_code = STATUS_TIMEOUT;
+    the_thread->Wait.return_code = status;
 
     wait_class = wait_flags & THREAD_WAIT_CLASS_MASK;
     ready_again = wait_class | THREAD_WAIT_STATE_READY_AGAIN;
@@ -82,3 +79,15 @@ void _Thread_Timeout( Watchdog_Control *watchdog )
 #endif
   }
 }
+
+void _Thread_Timeout( Watchdog_Control *the_watchdog )
+{
+  Thread_Control *the_thread;
+
+  the_thread = RTEMS_CONTAINER_OF(
+    the_watchdog,
+    Thread_Control,
+    Timer.Watchdog
+  );
+  _Thread_Continue( the_thread, STATUS_TIMEOUT );
+}
-- 
2.12.3




More information about the devel mailing list