diff options
author | Eric Andersen <andersen@codepoet.org> | 2005-01-11 09:41:40 +0000 |
---|---|---|
committer | Eric Andersen <andersen@codepoet.org> | 2005-01-11 09:41:40 +0000 |
commit | 50a6ac7fb90ad4008b354ff8e72c6ce511dbeb3a (patch) | |
tree | bbfa2262a83889c6aeed9e9017df8517536e3b4a /librt/mq_receive.c | |
parent | 45a95a466117aee2cd60f97be8310b6a04197244 (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.c | 36 |
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 |