diff options
| -rw-r--r-- | cpukit/score/include/rtems/score/thread.h | 5 | ||||
| -rw-r--r-- | cpukit/score/include/rtems/score/threadimpl.h | 16 | ||||
| -rw-r--r-- | cpukit/score/src/threadinitialize.c | 1 | ||||
| -rw-r--r-- | cpukit/score/src/threadrestart.c | 1 |
4 files changed, 23 insertions, 0 deletions
diff --git a/cpukit/score/include/rtems/score/thread.h b/cpukit/score/include/rtems/score/thread.h index d839b1f9ec..eb272e6c01 100644 --- a/cpukit/score/include/rtems/score/thread.h +++ b/cpukit/score/include/rtems/score/thread.h @@ -246,6 +246,11 @@ typedef enum { typedef struct { #if defined(RTEMS_SMP) /** + * @brief Lock to protect the scheduler node change requests. + */ + ISR_lock_Control Lock; + + /** * @brief The current scheduler state of this thread. */ Thread_Scheduler_state state; diff --git a/cpukit/score/include/rtems/score/threadimpl.h b/cpukit/score/include/rtems/score/threadimpl.h index f259e74d49..8254b97183 100644 --- a/cpukit/score/include/rtems/score/threadimpl.h +++ b/cpukit/score/include/rtems/score/threadimpl.h @@ -1035,6 +1035,22 @@ RTEMS_INLINE_ROUTINE Scheduler_Node *_Thread_Scheduler_get_node_by_index( } #if defined(RTEMS_SMP) +RTEMS_INLINE_ROUTINE void _Thread_Scheduler_acquire_critical( + Thread_Control *the_thread, + ISR_lock_Context *lock_context +) +{ + _ISR_lock_Acquire( &the_thread->Scheduler.Lock, lock_context ); +} + +RTEMS_INLINE_ROUTINE void _Thread_Scheduler_release_critical( + Thread_Control *the_thread, + ISR_lock_Context *lock_context +) +{ + _ISR_lock_Release( &the_thread->Scheduler.Lock, lock_context ); +} + RTEMS_INLINE_ROUTINE void _Thread_Scheduler_add_wait_node( Thread_Control *the_thread, Scheduler_Node *scheduler_node diff --git a/cpukit/score/src/threadinitialize.c b/cpukit/score/src/threadinitialize.c index c6db62f3bf..62c3066aab 100644 --- a/cpukit/score/src/threadinitialize.c +++ b/cpukit/score/src/threadinitialize.c @@ -234,6 +234,7 @@ bool _Thread_Initialize( the_thread->Scheduler.own_node = scheduler_node; the_thread->Scheduler.node = scheduler_node; _Resource_Node_initialize( &the_thread->Resource_node ); + _ISR_lock_Initialize( &the_thread->Scheduler.Lock, "Thread Scheduler" ); _ISR_lock_Initialize( &the_thread->Wait.Lock.Default, "Thread Wait Default" ); _Thread_queue_Gate_open( &the_thread->Wait.Lock.Tranquilizer ); _RBTree_Initialize_node( &the_thread->Wait.Link.Registry_node ); diff --git a/cpukit/score/src/threadrestart.c b/cpukit/score/src/threadrestart.c index 69534001aa..5cd9d43c57 100644 --- a/cpukit/score/src/threadrestart.c +++ b/cpukit/score/src/threadrestart.c @@ -200,6 +200,7 @@ static void _Thread_Free( Thread_Control *the_thread ) _Workspace_Free( the_thread->Start.tls_area ); #if defined(RTEMS_SMP) + _ISR_lock_Destroy( &the_thread->Scheduler.Lock ); _ISR_lock_Destroy( &the_thread->Wait.Lock.Default ); _SMP_lock_Stats_destroy( &the_thread->Potpourri_stats ); #endif |