RTOS/rtems
1
0
Fork 0
forked from Imagelibrary/rtems
Code Pull Requests Activity

+ Modified to correct return codes.

Browse Source 
+ Removed extra flag attribute from message queue structure.
+ Yellow-lined all posix message queue routines.
This commit is contained in:
Jennifer Averett
2000-01-12 18:43:21 +00:00
parent 70329c80ea
commit 352d01e0d3
2 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
c/src/exec/posix/src/mqueuegetattr.c
View File

@@ -42,10 +42,13 @@ int mq_getattr(
Objects_Locations location;
CORE_message_queue_Attributes *the_mq_attr;
if ( !mqstat )
set_errno_and_return_minus_one( EINVAL );
the_mq = _POSIX_Message_queue_Get( mqdes, &location );
switch ( location ) {
case OBJECTS_ERROR:
set_errno_and_return_minus_one( EINVAL );
set_errno_and_return_minus_one( EBADF );
case OBJECTS_REMOTE:
_Thread_Dispatch();
return POSIX_MP_NOT_IMPLEMENTED();
@@ -60,7 +63,7 @@ int mq_getattr(
the_mq_attr = &the_mq->Message_queue.Attributes;
mqstat->mq_flags = the_mq->flags;
mqstat->mq_flags = the_mq->oflag;
mqstat->mq_msgsize = the_mq->Message_queue.maximum_message_size;
mqstat->mq_maxmsg = the_mq->Message_queue.maximum_pending_messages;
mqstat->mq_curmsgs = the_mq->Message_queue.number_of_pending_messages;

7
cpukit/posix/src/mqueuegetattr.c
View File

@@ -42,10 +42,13 @@ int mq_getattr(
Objects_Locations location;
CORE_message_queue_Attributes *the_mq_attr;
if ( !mqstat )
set_errno_and_return_minus_one( EINVAL );
the_mq = _POSIX_Message_queue_Get( mqdes, &location );
switch ( location ) {
case OBJECTS_ERROR:
set_errno_and_return_minus_one( EINVAL );
set_errno_and_return_minus_one( EBADF );
case OBJECTS_REMOTE:
_Thread_Dispatch();
return POSIX_MP_NOT_IMPLEMENTED();
@@ -60,7 +63,7 @@ int mq_getattr(
the_mq_attr = &the_mq->Message_queue.Attributes;
mqstat->mq_flags = the_mq->flags;
mqstat->mq_flags = the_mq->oflag;
mqstat->mq_msgsize = the_mq->Message_queue.maximum_message_size;
mqstat->mq_maxmsg = the_mq->Message_queue.maximum_pending_messages;
mqstat->mq_curmsgs = the_mq->Message_queue.number_of_pending_messages;