18 #pragma GCC system_header 19 #include_next <mqueue.h> 21 #ifndef _COBALT_MQUEUE_H 22 #define _COBALT_MQUEUE_H 24 #include <cobalt/wrappers.h> 30 COBALT_DECL(mqd_t,
mq_open(
const char *name,
34 COBALT_DECL(
int,
mq_close(mqd_t qd));
36 COBALT_DECL(
int,
mq_unlink(
const char *name));
39 struct mq_attr *attr));
42 const struct mq_attr *__restrict__ attr,
43 struct mq_attr *__restrict__ oattr));
45 COBALT_DECL(
int,
mq_send(mqd_t qd,
54 const struct timespec *timeout));
62 char *__restrict__ buffer,
64 unsigned *__restrict__ prio,
65 const struct timespec *__restrict__ timeout));
68 const struct sigevent *evp));
int mq_setattr(mqd_t qd, const struct mq_attr *__restrict__ attr, struct mq_attr *__restrict__ oattr)
Set message queue attributes
Definition: mq.c:270
int mq_close(mqd_t qd)
Close a message queue
Definition: mq.c:149
int mq_unlink(const char *name)
Unlink a message queue
Definition: mq.c:186
int mq_getattr(mqd_t qd, struct mq_attr *attr)
Get message queue attributes
Definition: mq.c:226
int mq_send(mqd_t qd, const char *buffer, size_t len, unsigned prio)
Send a message to a message queue.
Definition: mq.c:335
int mq_notify(mqd_t q, const struct sigevent *evp)
Enable notification on message arrival
Definition: mq.c:576
ssize_t mq_receive(mqd_t q, char *buffer, size_t len, unsigned *prio)
Receive a message from a message queue.
Definition: mq.c:455
int mq_timedsend(mqd_t q, const char *buffer, size_t len, unsigned prio, const struct timespec *timeout)
Attempt, during a bounded time, to send a message to a message queue.
Definition: mq.c:393
mqd_t mq_open(const char *name, int oflags,...)
Open a message queue
Definition: mq.c:105
ssize_t mq_timedreceive(mqd_t q, char *__restrict__ buffer, size_t len, unsigned *__restrict__ prio, const struct timespec *__restrict__ timeout)
Attempt, during a bounded time, to receive a message from a message queue.
Definition: mq.c:518