diff options
author | Sebastian Huber <sebastian.huber@embedded-brains.de> | 2016-04-26 21:20:31 +0200 |
---|---|---|
committer | Sebastian Huber <sebastian.huber@embedded-brains.de> | 2016-05-02 07:46:15 +0200 |
commit | c8982e5f6a4857444676165deab1e08dc91a6847 (patch) | |
tree | 9862d54650522b55afac8a4e1b84ab078a69dff5 /cpukit/posix/src/mqueuedeletesupp.c | |
parent | rtems: Avoid Giant lock for message queues (diff) | |
download | rtems-c8982e5f6a4857444676165deab1e08dc91a6847.tar.bz2 |
posix: Simplify message queues
The mq_open() function returns a descriptor to a POSIX message queue
object identified by a name. This is similar to sem_open(). In
contrast to the POSIX semaphore the POSIX message queues use a separate
object for the descriptor. This extra object is superfluous, since the
object identifier can be used directly for this purpose, just like for
the semaphores.
Update #2702.
Update #2555.
Diffstat (limited to 'cpukit/posix/src/mqueuedeletesupp.c')
-rw-r--r-- | cpukit/posix/src/mqueuedeletesupp.c | 56 |
1 files changed, 11 insertions, 45 deletions
diff --git a/cpukit/posix/src/mqueuedeletesupp.c b/cpukit/posix/src/mqueuedeletesupp.c index 5382dd4149..61f330a1fb 100644 --- a/cpukit/posix/src/mqueuedeletesupp.c +++ b/cpukit/posix/src/mqueuedeletesupp.c @@ -18,56 +18,22 @@ #include "config.h" #endif -#include <stdarg.h> - -#include <pthread.h> -#include <limits.h> -#include <errno.h> -#include <fcntl.h> -#include <mqueue.h> - -#include <rtems/system.h> -#include <rtems/score/watchdog.h> -#include <rtems/score/wkspace.h> -#include <rtems/seterr.h> #include <rtems/posix/mqueueimpl.h> -#if defined(RTEMS_DEBUG) - #include <rtems/bspIo.h> -#endif void _POSIX_Message_queue_Delete( - POSIX_Message_queue_Control *the_mq + POSIX_Message_queue_Control *the_mq, + ISR_lock_Context *lock_context ) { - if ( !the_mq->linked && !the_mq->open_count ) { - Objects_Control *the_object = &the_mq->Object; - ISR_lock_Context lock_context; - - #if defined(RTEMS_DEBUG) - /* - * the name memory will have been freed by unlink. - */ - if ( the_object->name.name_p ) { - printk( - "POSIX MQ name (%p) not freed by unlink\n", - (void *)the_object->name.name_p - ); - _Workspace_Free( (void *)the_object->name.name_p ); - } - #endif - - _CORE_message_queue_Acquire( &the_mq->Message_queue, &lock_context ); - - _Objects_Close( &_POSIX_Message_queue_Information, the_object ); - - _CORE_message_queue_Close( - &the_mq->Message_queue, - NULL, /* no MP support */ - 0, - &lock_context - ); - + if ( !the_mq->linked && the_mq->open_count == 0 ) { + _CORE_message_queue_Close( + &the_mq->Message_queue, + NULL, /* no MP support */ + 0, + lock_context + ); _POSIX_Message_queue_Free( the_mq ); - + } else { + _CORE_message_queue_Release( &the_mq->Message_queue, lock_context ); } } |