| /kernel/liteos_a/syscall/ |
| D | ipc_syscall.c | 150 int SysMqTimedSend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, in SysMqTimedSend() argument
163 if (msgLen == 0) { in SysMqTimedSend()
166 msgIntr = (char *)malloc(msgLen); in SysMqTimedSend()
170 ret = LOS_ArchCopyFromUser(msgIntr, msg, msgLen); in SysMqTimedSend()
176 ret = mq_timedsend(personal, msgIntr, msgLen, msgPrio, absTimeout ? &timeout : NULL); in SysMqTimedSend()
184 ssize_t SysMqTimedReceive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio, in SysMqTimedReceive() argument
198 if (msgLen == 0) { in SysMqTimedReceive()
201 msgIntr = (char *)malloc(msgLen); in SysMqTimedReceive()
206 … receiveLen = mq_timedreceive(personal, msgIntr, msgLen, &kMsgPrio, absTimeout ? &timeout : NULL); 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_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);
384 extern int mq_timedsend(mqd_t personal, const char *msg, size_t msgLen,
426 extern ssize_t mq_timedreceive(mqd_t personal, char *msg, size_t msgLen,
|
| /kernel/liteos_m/kal/posix/src/ |
| D | mqueue.c | 511 STATIC INLINE BOOL MqParamCheck(mqd_t personal, const char *msg, size_t msgLen) in MqParamCheck() argument
517 if ((msg == NULL) || (msgLen == 0)) { in MqParamCheck()
534 int mq_timedsend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, in mq_timedsend() argument
542 OS_MQ_GOTO_ERROUT_IF(!MqParamCheck(personal, msg, msgLen), errno); in mq_timedsend()
551 …OS_MQ_GOTO_ERROUT_UNLOCK_IF(msgLen > (size_t)(mqueueCB->mqcb->queueSize - sizeof(UINT32)), EMSGSIZ… in mq_timedsend()
561 err = LOS_QueueWriteCopy(mqueueID, (VOID *)msg, (UINT32)msgLen, (UINT32)absTicks); in mq_timedsend()
572 ssize_t mq_timedreceive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio, in mq_timedreceive() argument
581 if (!MqParamCheck(personal, msg, msgLen)) { in mq_timedreceive()
597 if (msgLen < (size_t)(mqueueCB->mqcb->queueSize - sizeof(UINT32))) { in mq_timedreceive()
611 receiveLen = msgLen; in mq_timedreceive()
|
| /kernel/liteos_a/compat/posix/src/ |
| D | mqueue.c | 725 STATIC INLINE BOOL MqParamCheck(mqd_t personal, const char *msg, size_t msgLen) in MqParamCheck() argument
731 if ((msg == NULL) || (msgLen == 0)) { in MqParamCheck()
777 int mq_timedsend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, in mq_timedsend() argument
785 OS_MQ_GOTO_ERROUT_IF(!MqParamCheck(personal, msg, msgLen), errno); in mq_timedsend()
794 …OS_MQ_GOTO_ERROUT_UNLOCK_IF(msgLen > (size_t)(mqueueCB->mqcb->queueSize - sizeof(UINT32)), EMSGSIZ… in mq_timedsend()
808 err = LOS_QueueWriteCopy(mqueueID, (VOID *)msg, (UINT32)msgLen, (UINT32)absTicks); in mq_timedsend()
819 ssize_t mq_timedreceive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio, in mq_timedreceive() argument
828 if (!MqParamCheck(personal, msg, msgLen)) { in mq_timedreceive()
844 if (msgLen < (size_t)(mqueueCB->mqcb->queueSize - sizeof(UINT32))) { in mq_timedreceive()
858 receiveLen = msgLen; in mq_timedreceive()
|