Searched refs:mqueueID (Results 1 – 2 of 2) sorted by relevance
| /kernel/liteos_m/kal/posix/src/ |
| D | mqueue.c | 182 UINT32 mqueueID; in DoMqueueCreate() local
184 UINT32 err = LOS_QueueCreate(NULL, attr->mq_maxmsg, &mqueueID, 0, attr->mq_msgsize); in DoMqueueCreate()
189 if (g_queueTable[GET_QUEUE_INDEX(mqueueID)].mqcb == NULL) { in DoMqueueCreate()
190 mqueueCB = &(g_queueTable[GET_QUEUE_INDEX(mqueueID)]); in DoMqueueCreate()
191 mqueueCB->mq_id = mqueueID; in DoMqueueCreate()
537 UINT32 mqueueID, err; in mq_timedsend() local
558 mqueueID = mqueueCB->mq_id; in mq_timedsend()
561 err = LOS_QueueWriteCopy(mqueueID, (VOID *)msg, (UINT32)msgLen, (UINT32)absTicks); in mq_timedsend()
575 UINT32 mqueueID, err; in mq_timedreceive() local
612 mqueueID = mqueueCB->mq_id; in mq_timedreceive()
[all …]
|
| /kernel/liteos_a/compat/posix/src/ |
| D | mqueue.c | 184 UINT32 mqueueID; in DoMqueueCreate() local
191 UINT32 err = LOS_QueueCreate(NULL, attr->mq_maxmsg, &mqueueID, 0, attr->mq_msgsize); in DoMqueueCreate()
196 if (IPC_QUEUE_TABLE[GET_QUEUE_INDEX(mqueueID)].mqcb == NULL) { in DoMqueueCreate()
197 mqueueCB = &(IPC_QUEUE_TABLE[GET_QUEUE_INDEX(mqueueID)]); in DoMqueueCreate()
198 mqueueCB->mq_id = mqueueID; in DoMqueueCreate()
780 UINT32 mqueueID, err; in mq_timedsend() local
801 mqueueID = mqueueCB->mq_id; in mq_timedsend()
808 err = LOS_QueueWriteCopy(mqueueID, (VOID *)msg, (UINT32)msgLen, (UINT32)absTicks); in mq_timedsend()
822 UINT32 mqueueID, err; in mq_timedreceive() local
859 mqueueID = mqueueCB->mq_id; in mq_timedreceive()
[all …]
|