summaryrefslogtreecommitdiff
path: root/librt/mq_receive.c
diff options
context:
space:
mode:
authorEric Andersen <andersen@codepoet.org>2005-01-11 09:41:40 +0000
committerEric Andersen <andersen@codepoet.org>2005-01-11 09:41:40 +0000
commit50a6ac7fb90ad4008b354ff8e72c6ce511dbeb3a (patch)
treebbfa2262a83889c6aeed9e9017df8517536e3b4a /librt/mq_receive.c
parent45a95a466117aee2cd60f97be8310b6a04197244 (diff)
Patch from Paul Mundt (lethal) adding an initial librt implementation.
I then reworked the syscall handling and made minor cleanups. With luck I've not completely broken his patch...
Diffstat (limited to 'librt/mq_receive.c')
-rw-r--r--librt/mq_receive.c36
1 files changed, 36 insertions, 0 deletions
diff --git a/librt/mq_receive.c b/librt/mq_receive.c
new file mode 100644
index 000000000..4dd81f5e7
--- /dev/null
+++ b/librt/mq_receive.c
@@ -0,0 +1,36 @@
+/*
+ * mq_receive.c - functions for receiving from message queue.
+ */
+
+#include <errno.h>
+#include <stddef.h>
+#include <sys/syscall.h>
+
+#include <mqueue.h>
+
+#ifdef __NR_mq_timedreceive
+
+#define __NR___syscall_mq_timedreceive __NR_mq_timedreceive
+static inline _syscall5(int, __syscall_mq_timedreceive, int, mqdes,
+ char *, msg_ptr, size_t, msg_len, unsigned int *, msg_prio,
+ const void *, abs_timeout);
+
+/*
+ * Receive the oldest from highest priority messages.
+ * Stop waiting if abs_timeout expires.
+ */
+ssize_t mq_timedreceive(mqd_t mqdes, char *msg_ptr, size_t msg_len,
+ unsigned int *msg_prio,
+ const struct timespec *abs_timeout)
+{
+ return __syscall_mq_timedreceive(mqdes, msg_ptr, msg_len, msg_prio, abs_timeout);
+}
+
+/* Receive the oldest from highest priority messages */
+ssize_t mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len,
+ unsigned int *msg_prio)
+{
+ return mq_timedreceive(mqdes, msg_ptr, msg_len, msg_prio, NULL);
+}
+
+#endif