| /kernel/liteos_a/compat/posix/include/ |
| D | mqueue.h | 274 extern int mq_send(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio);
311 extern ssize_t mq_receive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio);
385 unsigned int msgPrio, const struct timespec *absTimeout);
427 unsigned int *msgPrio, const struct timespec *absTimeout);
|
| /kernel/liteos_a/syscall/ |
| D | ipc_syscall.c | 156 int SysMqTimedSend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, in SysMqTimedSend() argument
182 ret = mq_timedsend(personal, msgIntr, msgLen, msgPrio, absTimeout ? &timeout : NULL); in SysMqTimedSend()
190 ssize_t SysMqTimedReceive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio, in SysMqTimedReceive() argument
218 if (msgPrio != NULL) { in SysMqTimedReceive()
219 ret = LOS_ArchCopyToUser(msgPrio, &kMsgPrio, sizeof(unsigned int)); in SysMqTimedReceive()
|
| D | los_syscall.h | 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,
|
| /kernel/liteos_m/testsuites/unittest/xts/cmsis/ |
| D | cmsis_msg_func_test.c | 52 UINT8 msgPrio = 0; in CmsisMessageQueueGetFunc001() local
55 uwRet = osMessageQueueGet(g_cmsisMqId, ucTemp, &msgPrio, TIMEOUT_COUNT); in CmsisMessageQueueGetFunc001()
228 UINT8 msgPrio = 0; variable
230 uwRet = osMessageQueueGet(NULL, ucTemp, &msgPrio, TIMEOUT_COUNT);
243 UINT8 msgPrio = 0; variable
247 uwRet = osMessageQueueGet(g_cmsisMqId, NULL, &msgPrio, TIMEOUT_COUNT);
|
| /kernel/liteos_a/testsuites/unittest/libc/posix/mqueue/full/ |
| D | It_posix_queue_144.cpp | 63 UINT32 msgPrio = 1; in PthreadF02() local
72 ret = mq_receive(g_gqueue, msgrcd[i], attr.mq_msgsize, &msgPrio); in PthreadF02()
|
| /kernel/liteos_m/kal/posix/src/ |
| D | mqueue.c | 534 int mq_timedsend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, in mq_timedsend() argument
544 OS_MQ_GOTO_ERROUT_IF(msgPrio > (MQ_PRIO_MAX - 1), EINVAL); in mq_timedsend()
572 ssize_t mq_timedreceive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio, in mq_timedreceive() argument
585 if (msgPrio != NULL) { in mq_timedreceive()
586 *msgPrio = 0; in mq_timedreceive()
|
| /kernel/liteos_a/compat/posix/src/ |
| D | mqueue.c | 777 int mq_timedsend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, in mq_timedsend() argument
786 OS_MQ_GOTO_ERROUT_IF(msgPrio > (MQ_PRIO_MAX - 1), EINVAL); in mq_timedsend()
819 ssize_t mq_timedreceive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio, in mq_timedreceive() argument
832 if (msgPrio != NULL) { in mq_timedreceive()
833 *msgPrio = 0; in mq_timedreceive()
|