Mirrors_Framework/rtems
1
0
Fork 0
mirror of https://gitlab.rtems.org/rtems/rtos/rtems.git synced 2026-09-10 16:51:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

score: _CORE_message_queue_Seize()

Browse Source 
Move lock acquire to caller of _CORE_message_queue_Seize() to allow
state checks during receive operations under lock protection.
This commit is contained in:
Sebastian Huber
2016-05-02 07:46:14 +02:00
parent 7580995b47
commit b0eba5ed8a
3 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cpukit/posix/src/mqueuerecvsupp.c
+5
View File
@@ -96,6 +96,11 @@ ssize_t _POSIX_Message_queue_Receive_support(
else
do_wait = wait;
_CORE_message_queue_Acquire_critical(
&the_mq->Message_queue,
&lock_context
);
/*
* Now perform the actual message receive
*/
cpukit/rtems/src/msgqreceive.c
+5
View File
@@ -68,6 +68,11 @@ rtems_status_code rtems_message_queue_receive(
else
wait = true;
_CORE_message_queue_Acquire_critical(
&the_message_queue->message_queue,
&lock_context
);
executing = _Thread_Executing;
_CORE_message_queue_Seize(
&the_message_queue->message_queue,
cpukit/score/src/coremsgseize.c
-1
View File
@@ -40,7 +40,6 @@ void _CORE_message_queue_Seize(
CORE_message_queue_Buffer_control *the_message;
executing->Wait.return_code = CORE_MESSAGE_QUEUE_STATUS_SUCCESSFUL;
_CORE_message_queue_Acquire_critical( the_message_queue, lock_context );
the_message = _CORE_message_queue_Get_pending_message( the_message_queue );
if ( the_message != NULL ) {
the_message_queue->number_of_pending_messages -= 1;