| /kernel/liteos_a/syscall/ |
| H A D | ipc_syscall.c | 156 int SysMqTimedSend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, in SysMqTimedSend() argument
169 if (msgLen == 0) { in SysMqTimedSend()
172 msgIntr = (char *)malloc(msgLen); in SysMqTimedSend()
176 ret = LOS_ArchCopyFromUser(msgIntr, msg, msgLen); in SysMqTimedSend()
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
204 if (msgLen == 0) { in SysMqTimedReceive()
207 msgIntr = (char *)malloc(msgLen); in SysMqTimedReceive()
212 receiveLen = mq_timedreceive(personal, msgIntr, msgLen, &kMsgPrio, absTimeout ? &timeout : NULL); in SysMqTimedReceive()
|
| H A 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/ |
| H A D | mqueue.h | 250 * @param msgLen [IN] Length of the message to be sent.
274 extern int mq_send(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio);
290 * @param msgLen [IN] Length of the message to be received.
311 extern ssize_t mq_receive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio);
360 * @param msgLen [IN] Length of the message to be sent.
384 extern int mq_timedsend(mqd_t personal, const char *msg, size_t msgLen,
403 * @param msgLen [IN] Length of the message to be received.
426 extern ssize_t mq_timedreceive(mqd_t personal, char *msg, size_t msgLen,
|
| /kernel/liteos_m/kal/posix/src/ |
| H A 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)), EMSGSIZE); 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()
[all...] |
| /kernel/liteos_a/compat/posix/src/ |
| H A D | mqueue.c | 733 STATIC INLINE BOOL MqParamCheck(mqd_t personal, const char *msg, size_t msgLen) in MqParamCheck() argument
739 if ((msg == NULL) || (msgLen == 0)) { in MqParamCheck()
785 int mq_timedsend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, in mq_timedsend() argument
793 OS_MQ_GOTO_ERROUT_IF(!MqParamCheck(personal, msg, msgLen), errno); in mq_timedsend()
802 OS_MQ_GOTO_ERROUT_UNLOCK_IF(msgLen > (size_t)(mqueueCB->mqcb->queueSize - sizeof(UINT32)), EMSGSIZE); in mq_timedsend()
816 err = LOS_QueueWriteCopy(mqueueID, (VOID *)msg, (UINT32)msgLen, (UINT32)absTicks); in mq_timedsend()
827 ssize_t mq_timedreceive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio, in mq_timedreceive() argument
836 if (!MqParamCheck(personal, msg, msgLen)) { in mq_timedreceive()
852 if (msgLen < (size_t)(mqueueCB->mqcb->queueSize - sizeof(UINT32))) { in mq_timedreceive()
866 receiveLen = msgLen; in mq_timedreceive()
[all...] |