/kernel/liteos_m/kal/libc/newlib/porting/include/ |
H A D | mqueue.h | 49 int mq_close(mqd_t personal); 50 int mq_getattr(mqd_t personal, struct mq_attr *attr); 52 ssize_t mq_receive(mqd_t personal, char *msg_ptr, size_t msg_len, unsigned *msg_prio); 53 int mq_send(mqd_t personal, const char *msg_ptr, size_t msg_len, unsigned msg_prio); 54 int mq_setattr(mqd_t personal, const struct mq_attr *__restrict new, struct mq_attr *__restrict old); 55 ssize_t mq_timedreceive(mqd_t personal, char *__restrict msg, size_t msg_len, \ 57 int mq_timedsend(mqd_t personal, const char *msg, size_t msg_len, unsigned msg_prio, const struct timespec *absTimeout);
|
/kernel/liteos_a/compat/posix/include/ |
H A D | mqueue.h | 186 * @param personal [IN] Message queue descriptor. 203 extern int mq_close(mqd_t personal); 248 * @param personal [IN] Message queue descriptor. 274 extern int mq_send(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio); 288 * @param personal [IN] Message queue descriptor. 311 extern ssize_t mq_receive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio); 324 * @param personal [IN] Message queue descriptor. 342 extern int mq_getsetattr(mqd_t personal, const struct mq_attr *mqSetAttr, struct mq_attr *MqOldAttr); 384 extern int mq_timedsend(mqd_t personal, const char *msg, size_t msgLen, 401 * @param personal [I [all...] |
/kernel/liteos_a/syscall/ |
H A D | ipc_syscall.c | 80 int SysMqClose(mqd_t personal) in SysMqClose() argument 83 int ufd = (INTPTR)personal; in SysMqClose() 85 MQUEUE_FD_U2K(personal); in SysMqClose() 86 ret = mq_close(personal); in SysMqClose() 94 int SysMqNotify(mqd_t personal, const struct sigevent *sigev) in SysMqNotify() argument 104 MQUEUE_FD_U2K(personal); in SysMqNotify() 105 ret = OsMqNotify(personal, &ksigev); in SysMqNotify() 156 int SysMqTimedSend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, in SysMqTimedSend() argument 181 MQUEUE_FD_U2K(personal); in SysMqTimedSend() 182 ret = mq_timedsend(personal, msgInt in SysMqTimedSend() 190 SysMqTimedReceive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio, const struct timespec *absTimeout) SysMqTimedReceive() argument [all...] |
H A D | los_syscall.h | 124 extern int SysMqClose(mqd_t personal);
127 extern int SysMqSend(mqd_t personal, const char *msgPtr, size_t msgLen, unsigned int msgPrio);
128 extern int SysMqTimedSend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio,
130 extern ssize_t SysMqTimedReceive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio,
132 extern int SysMqNotify(mqd_t personal, const struct sigevent *sigev);
|
/kernel/liteos_a/compat/posix/src/ |
H A D | mqueue.c | 287 /* find the personal and remove */ in DoMqueueClose() 305 /* free the personal */ in DoMqueueClose() 312 STATIC struct mqpersonal *MqGetPrivDataBuff(mqd_t personal) in MqGetPrivDataBuff() argument 314 INT32 sysFd = (INT32)personal; in MqGetPrivDataBuff() 350 STATIC VOID MqFreeSysFd(mqd_t personal) in MqFreeSysFd() argument 352 INT32 sysFd = (INT32)personal; in MqFreeSysFd() 367 /* Get the personal sysFd and reset personal fd -1 */ in MqueueRefer() 561 /* there are no more mq sysFd to use, close the personal */ in mq_open() 572 int mq_close(mqd_t personal) in mq_close() argument 606 OsMqGetAttr(mqd_t personal, struct mq_attr *mqAttr) OsMqGetAttr() argument 639 OsMqSetAttr(mqd_t personal, const struct mq_attr *mqSetAttr, struct mq_attr *mqOldAttr) OsMqSetAttr() argument 733 MqParamCheck(mqd_t personal, const char *msg, size_t msgLen) MqParamCheck() argument 785 mq_timedsend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, const struct timespec *absTimeout) mq_timedsend() argument 827 mq_timedreceive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio, const struct timespec *absTimeout) mq_timedreceive() argument 884 mq_send(mqd_t personal, const char *msg_ptr, size_t msg_len, unsigned int msg_prio) mq_send() argument 889 mq_receive(mqd_t personal, char *msg_ptr, size_t msg_len, unsigned int *msg_prio) mq_receive() argument 894 MqNotifyParamCheck(mqd_t personal, const struct sigevent *sigev) MqNotifyParamCheck() argument 917 OsMqNotify(mqd_t personal, const struct sigevent *sigev) OsMqNotify() argument [all...] |
/kernel/liteos_m/kal/posix/src/ |
H A D | mqueue.c | 313 int mq_close(mqd_t personal) in mq_close() argument 320 if ((personal == (mqd_t)NULL) || (personal == (mqd_t)-1)) { in mq_close() 326 privateMqPersonal = (struct mqpersonal *)personal; in mq_close() 338 /* find the personal and remove */ in mq_close() 356 /* free the personal */ in mq_close() 372 int OsMqGetAttr(mqd_t personal, struct mq_attr *mqAttr) in OsMqGetAttr() argument 383 privateMqPersonal = (struct mqpersonal *)personal; in OsMqGetAttr() 399 int OsMqSetAttr(mqd_t personal, const struct mq_attr *mqSetAttr, struct mq_attr *mqOldAttr) in OsMqSetAttr() argument 409 privateMqPersonal = (struct mqpersonal *)personal; in OsMqSetAttr() 511 MqParamCheck(mqd_t personal, const char *msg, size_t msgLen) MqParamCheck() argument 534 mq_timedsend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, const struct timespec *absTimeout) mq_timedsend() argument 572 mq_timedreceive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio, const struct timespec *absTimeout) mq_timedreceive() argument 629 mq_send(mqd_t personal, const char *msg_ptr, size_t msg_len, unsigned int msg_prio) mq_send() argument 634 mq_receive(mqd_t personal, char *msg_ptr, size_t msg_len, unsigned int *msg_prio) mq_receive() argument [all...] |