summaryrefslogtreecommitdiffstats
path: root/cpukit/posix/src/mqueuedeletesupp.c
diff options
context:
space:
mode:
authorSebastian Huber <sebastian.huber@embedded-brains.de>2016-04-26 21:20:31 +0200
committerSebastian Huber <sebastian.huber@embedded-brains.de>2016-05-02 07:46:15 +0200
commitc8982e5f6a4857444676165deab1e08dc91a6847 (patch)
tree9862d54650522b55afac8a4e1b84ab078a69dff5 /cpukit/posix/src/mqueuedeletesupp.c
parentrtems: Avoid Giant lock for message queues (diff)
downloadrtems-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.c56
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 );
}
}