summaryrefslogtreecommitdiffstats
path: root/c/src/exec/score/src/coremsg.c
diff options
context:
space:
mode:
authorJoel Sherrill <joel.sherrill@OARcorp.com>1999-11-02 15:57:58 +0000
committerJoel Sherrill <joel.sherrill@OARcorp.com>1999-11-02 15:57:58 +0000
commit9693fdac7518e4d6d37b41dc1675b4041d54d900 (patch)
tree4d0715e54ebba2681e6e40e1b32881b67cf45de5 /c/src/exec/score/src/coremsg.c
parentCorrected spacing. (diff)
downloadrtems-9693fdac7518e4d6d37b41dc1675b4041d54d900.tar.bz2
Added support for message priority as required by POSIX.
Diffstat (limited to 'c/src/exec/score/src/coremsg.c')
-rw-r--r--c/src/exec/score/src/coremsg.c34
1 files changed, 33 insertions, 1 deletions
diff --git a/c/src/exec/score/src/coremsg.c b/c/src/exec/score/src/coremsg.c
index 2d1eca624b..da06c7acf9 100644
--- a/c/src/exec/score/src/coremsg.c
+++ b/c/src/exec/score/src/coremsg.c
@@ -422,7 +422,8 @@ CORE_message_queue_Status _CORE_message_queue_Submit(
_CORE_message_queue_Copy_buffer( buffer, the_message->Contents.buffer, size );
the_message->Contents.size = size;
-
+ the_message->priority = submit_type;
+
the_message_queue->number_of_pending_messages += 1;
switch ( submit_type ) {
@@ -432,7 +433,38 @@ CORE_message_queue_Status _CORE_message_queue_Submit(
case CORE_MESSAGE_QUEUE_URGENT_REQUEST:
_CORE_message_queue_Prepend( the_message_queue, the_message );
break;
+ default:
+ /* XXX interrupt critical section needs to be addressed */
+ {
+ CORE_message_queue_Buffer_control *this_message;
+ Chain_Node *the_node;
+
+ the_message->priority = submit_type;
+ for ( the_node = the_message_queue->Pending_messages.first ;
+ !_Chain_Is_tail( &the_message_queue->Pending_messages, the_node ) ;
+ the_node = the_node->next ) {
+
+ this_message = (CORE_message_queue_Buffer_control *) the_node;
+
+ if ( this_message->priority >= the_message->priority )
+ continue;
+
+ _Chain_Insert( the_node, &the_message->Node );
+ break;
+ }
+ }
+ break;
}
+ /*
+ * According to POSIX, does this happen before or after the message
+ * is actually enqueued. It is logical to think afterwards, because
+ * the message is actually in the queue at this point.
+ */
+
+ if ( the_message_queue->number_of_pending_messages == 1 &&
+ the_message_queue->notify_handler )
+ (*the_message_queue->notify_handler)( the_message_queue->notify_argument );
+
return CORE_MESSAGE_QUEUE_STATUS_SUCCESSFUL;
}