Welcome to mirror list, hosted at ThFree Co, Russian Federation.

cygwin.com/git/newlib-cygwin.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJeff Johnston <jjohnstn@redhat.com>2002-06-20 02:17:33 +0400
committerJeff Johnston <jjohnstn@redhat.com>2002-06-20 02:17:33 +0400
commitef467338e4a290b0f8978a0701b404e17c5bb048 (patch)
tree94570e7616b92bab0db3acef31bcf53dd6ce7a24 /newlib/libc/sys/linux/mq_getattr.c
parent676a64b87d76d8c0a518dbcb2e03d8ae4c59ced4 (diff)
2002-06-19 Jeff Johnston <jjohnstn@redhat.com>
* libc/sys/linux/Makefile.am: Add support for message queue routines, ipc routines, and ftok. * libc/sys/linux/Makefile.in: Regenerated. * libc/sys/linux/ftok.c: New file. * libc/sys/linux/ipc.c: Ditto. * libc/sys/linux/mq_close.c: Ditto. * libc/sys/linux/mq_getattr.c: Ditto. * libc/sys/linux/mq_notify.c: Ditto. * libc/sys/linux/mq_open.c: Ditto. * libc/sys/linux/mq_receive.c: Ditto. * libc/sys/linux/mq_send.c: Ditto. * libc/sys/linux/mq_setattr.c: Ditto. * libc/sys/linux/mq_unlink.c: Ditto. * libc/sys/linux/mqlocal.h: Ditto. * libc/sys/linux/include/mqueue.h: Ditto. * libc/sys/linux/sys/types.h: Define __gid_t_defined and __uid_t_defined.
Diffstat (limited to 'newlib/libc/sys/linux/mq_getattr.c')
-rw-r--r--newlib/libc/sys/linux/mq_getattr.c52
1 files changed, 52 insertions, 0 deletions
diff --git a/newlib/libc/sys/linux/mq_getattr.c b/newlib/libc/sys/linux/mq_getattr.c
new file mode 100644
index 000000000..b82906013
--- /dev/null
+++ b/newlib/libc/sys/linux/mq_getattr.c
@@ -0,0 +1,52 @@
+/* Copyright 2002, Red Hat Inc. */
+
+#include <mqueue.h>
+#include <errno.h>
+#include <sys/sem.h>
+#include <string.h>
+#define _LIBC
+#include <sys/lock.h>
+#undef _LIBC
+
+#include "mqlocal.h"
+
+int
+mq_getattr (mqd_t msgid, struct mq_attr *mqstat)
+{
+ struct libc_mq *info;
+ struct sembuf sb0 = {0, -1, 0};
+ int num_msgs;
+ int rc = 0;
+
+ info = __find_mq (msgid);
+
+ if (info == NULL)
+ {
+ errno = EBADF;
+ return -1;
+ }
+
+ /* temporarily lock message queue */
+ semop (info->semid, &sb0, 1);
+
+ num_msgs = semctl (info->semid, 3, GETVAL);
+ if (num_msgs >= 0)
+ {
+ memcpy (mqstat, info->attr, sizeof(struct mq_attr));
+ mqstat->mq_curmsgs = num_msgs;
+ }
+ else
+ rc = -1;
+
+ /* release message queue */
+ sb0.sem_op = 1;
+ semop (info->semid, &sb0, 1);
+
+ return rc;
+}
+
+
+
+
+
+