diff options
author | Joel Sherrill <joel.sherrill@oarcorp.com> | 2014-07-07 14:26:13 -0500 |
---|---|---|
committer | Joel Sherrill <joel.sherrill@oarcorp.com> | 2014-07-15 12:43:44 -0500 |
commit | ed7a02895e3bedda5edb33c91f0ffc956e9cab06 (patch) | |
tree | 0266870aab25e0eca278237aca3e11a621a12c9e /cpukit/score/src/threadqextractpriority.c | |
parent | rbtree: Reduce RBTree_Control size (diff) | |
download | rtems-ed7a02895e3bedda5edb33c91f0ffc956e9cab06.tar.bz2 |
Thread Queue Priority Discipline Reimplemented with RBTree
Diffstat (limited to 'cpukit/score/src/threadqextractpriority.c')
-rw-r--r-- | cpukit/score/src/threadqextractpriority.c | 48 |
1 files changed, 6 insertions, 42 deletions
diff --git a/cpukit/score/src/threadqextractpriority.c b/cpukit/score/src/threadqextractpriority.c index 2f2555be33..dc793b3cb5 100644 --- a/cpukit/score/src/threadqextractpriority.c +++ b/cpukit/score/src/threadqextractpriority.c @@ -6,7 +6,7 @@ */ /* - * COPYRIGHT (c) 1989-2008. + * COPYRIGHT (c) 1989-2014. * On-Line Applications Research Corporation (OAR). * * The license and distribution terms for this file may be @@ -19,7 +19,7 @@ #endif #include <rtems/score/threadqimpl.h> -#include <rtems/score/chainimpl.h> +#include <rtems/score/rbtreeimpl.h> #include <rtems/score/isrlevel.h> #include <rtems/score/threadimpl.h> #include <rtems/score/watchdogimpl.h> @@ -31,17 +31,7 @@ void _Thread_queue_Extract_priority_helper( ) { ISR_Level level; - Chain_Node *head; - Chain_Node *tail; - Chain_Node *the_node; - Chain_Node *next_node; - Chain_Node *previous_node; - Thread_Control *new_first_thread; - Chain_Node *new_first_node; - Chain_Node *new_second_node; - Chain_Node *last_node; - the_node = (Chain_Node *) the_thread; _ISR_Disable( level ); if ( !_States_Is_waiting_on_thread_queue( the_thread->current_state ) ) { _ISR_Enable( level ); @@ -51,40 +41,14 @@ void _Thread_queue_Extract_priority_helper( /* * The thread was actually waiting on a thread queue so let's remove it. */ - - next_node = the_node->next; - previous_node = the_node->previous; - - if ( !_Chain_Is_empty( &the_thread->Wait.Block2n ) ) { - new_first_node = _Chain_First( &the_thread->Wait.Block2n ); - new_first_thread = (Thread_Control *) new_first_node; - last_node = _Chain_Last( &the_thread->Wait.Block2n ); - new_second_node = new_first_node->next; - - previous_node->next = new_first_node; - next_node->previous = new_first_node; - new_first_node->next = next_node; - new_first_node->previous = previous_node; - - if ( !_Chain_Has_only_one_node( &the_thread->Wait.Block2n ) ) { - /* > two threads on 2-n */ - head = _Chain_Head( &new_first_thread->Wait.Block2n ); - tail = _Chain_Tail( &new_first_thread->Wait.Block2n ); - - new_second_node->previous = head; - head->next = new_second_node; - tail->previous = last_node; - last_node->next = tail; - } - } else { - previous_node->next = next_node; - next_node->previous = previous_node; - } + _RBTree_Extract( + &the_thread->Wait.queue->Queues.Priority, + &the_thread->RBNode + ); /* * If we are not supposed to touch timers or the thread's state, return. */ - if ( requeuing ) { _ISR_Enable( level ); return; |