Home
last modified time | relevance | path

Searched refs:mqcb (Results 1 - 4 of 4) sorted by relevance

/kernel/liteos_m/kal/posix/src/
H A Dmqueue.c140 mqueueCB->mqcb = NULL; in DoMqueueDelete()
189 if (g_queueTable[GET_QUEUE_INDEX(mqueueID)].mqcb == NULL) { in DoMqueueCreate()
203 if (GetMqueueCBByID(mqueueCB->mq_id, &(mqueueCB->mqcb)) != LOS_OK) { in DoMqueueCreate()
211 mqueueCB->mqcb->queue = NULL; in DoMqueueCreate()
212 mqueueCB->mqcb = NULL; in DoMqueueCreate()
391 mqAttr->mq_maxmsg = mqueueCB->mqcb->queueLen; in OsMqGetAttr()
392 mqAttr->mq_msgsize = mqueueCB->mqcb->queueSize - sizeof(UINT32); in OsMqGetAttr()
393 mqAttr->mq_curmsgs = mqueueCB->mqcb->readWriteableCnt[OS_QUEUE_READ]; in OsMqGetAttr()
551 OS_MQ_GOTO_ERROUT_UNLOCK_IF(msgLen > (size_t)(mqueueCB->mqcb->queueSize - sizeof(UINT32)), EMSGSIZE); in mq_timedsend()
597 if (msgLen < (size_t)(mqueueCB->mqcb in mq_timedreceive()
[all...]
H A Dmqueue_impl.h129 LosQueueCB *mqcb; member
/kernel/liteos_a/compat/posix/src/
H A Dmqueue.c124 mqueueCB->mqcb = NULL; in DoMqueueDelete()
196 if (IPC_QUEUE_TABLE[GET_QUEUE_INDEX(mqueueID)].mqcb == NULL) { in DoMqueueCreate()
210 if (GetMqueueCBByID(mqueueCB->mq_id, &(mqueueCB->mqcb)) != LOS_OK) { in DoMqueueCreate()
218 mqueueCB->mqcb->queueHandle = NULL; in DoMqueueCreate()
219 mqueueCB->mqcb = NULL; in DoMqueueCreate()
631 mqAttr->mq_maxmsg = mqueueCB->mqcb->queueLen; in OsMqGetAttr()
632 mqAttr->mq_msgsize = mqueueCB->mqcb->queueSize - sizeof(UINT32); in OsMqGetAttr()
633 mqAttr->mq_curmsgs = mqueueCB->mqcb->readWriteableCnt[OS_QUEUE_READ]; in OsMqGetAttr()
754 if ((mqnotify->pid) && (mqueueCB->mqcb->readWriteableCnt[OS_QUEUE_READ] == 0)) { in MqSendNotify()
802 OS_MQ_GOTO_ERROUT_UNLOCK_IF(msgLen > (size_t)(mqueueCB->mqcb in mq_timedsend()
[all...]
/kernel/liteos_a/compat/posix/include/
H A Dmqueue.h103 LosQueueCB *mqcb; member

Completed in 4 milliseconds