diff options
Diffstat (limited to 'cpukit/posix/src/mqueueopen.c')
| -rw-r--r-- | cpukit/posix/src/mqueueopen.c | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/cpukit/posix/src/mqueueopen.c b/cpukit/posix/src/mqueueopen.c index a4a8ecc66b..8195e9d2af 100644 --- a/cpukit/posix/src/mqueueopen.c +++ b/cpukit/posix/src/mqueueopen.c @@ -2,8 +2,8 @@ * NOTE: The structure of the routines is identical to that of POSIX * Message_queues to leave the option of having unnamed message * queues at a future date. They are currently not part of the - * POSIX standard but unnamed message_queues are. This is also - * the reason for the apparently unnecessary tracking of + * POSIX standard but unnamed message_queues are. This is also + * the reason for the apparently unnecessary tracking of * the process_shared attribute. [In addition to the fact that * it would be trivial to add pshared to the mq_attr structure * and have process private message queues.] @@ -53,7 +53,7 @@ mqd_t mq_open( POSIX_Message_queue_Control *the_mq; POSIX_Message_queue_Control_fd *the_mq_fd; Objects_Locations location; - + _Thread_Disable_dispatch(); if ( oflag & O_CREAT ) { @@ -62,7 +62,7 @@ mqd_t mq_open( attr = (struct mq_attr *) va_arg( arg, struct mq_attr * ); va_end(arg); } - + the_mq_fd = _POSIX_Message_queue_Allocate_fd(); if ( !the_mq_fd ) { _Thread_Enable_dispatch(); @@ -78,9 +78,9 @@ mqd_t mq_open( * need to check to see if this is a "message queue does not exist" * or some other miscellaneous error on the name. */ - + if ( status ) { - + /* * Unless provided a valid name that did not already exist * and we are willing to create then it is an error. @@ -93,7 +93,7 @@ mqd_t mq_open( } } else { /* name -> ID translation succeeded */ - + /* * Check for existence with creation. */ @@ -120,21 +120,21 @@ mqd_t mq_open( _Thread_Enable_dispatch(); _Thread_Enable_dispatch(); return (mqd_t)the_mq_fd->Object.id; - + } - - /* + + /* * At this point, the message queue does not exist and everything has been * checked. We should go ahead and create a message queue. */ - + status = _POSIX_Message_queue_Create_support( name, TRUE, /* shared across processes */ attr, &the_mq ); - + /* * errno was set by Create_support, so don't set it again. */ @@ -144,14 +144,14 @@ mqd_t mq_open( _POSIX_Message_queue_Free_fd( the_mq_fd ); return (mqd_t) -1; } - + the_mq_fd->Queue = the_mq; _Objects_Open( &_POSIX_Message_queue_Information_fds, &the_mq_fd->Object, NULL ); - + _Thread_Enable_dispatch(); return (mqd_t) the_mq_fd->Object.id; |