Lines Matching refs:mqcb
124 mqueueCB->mqcb = NULL;
196 if (IPC_QUEUE_TABLE[GET_QUEUE_INDEX(mqueueID)].mqcb == NULL) {
210 if (GetMqueueCBByID(mqueueCB->mq_id, &(mqueueCB->mqcb)) != LOS_OK) {
218 mqueueCB->mqcb->queueHandle = NULL;
219 mqueueCB->mqcb = NULL;
631 mqAttr->mq_maxmsg = mqueueCB->mqcb->queueLen;
632 mqAttr->mq_msgsize = mqueueCB->mqcb->queueSize - sizeof(UINT32);
633 mqAttr->mq_curmsgs = mqueueCB->mqcb->readWriteableCnt[OS_QUEUE_READ];
754 if ((mqnotify->pid) && (mqueueCB->mqcb->readWriteableCnt[OS_QUEUE_READ] == 0)) {
802 OS_MQ_GOTO_ERROUT_UNLOCK_IF(msgLen > (size_t)(mqueueCB->mqcb->queueSize - sizeof(UINT32)), EMSGSIZE);
812 if (LOS_ListEmpty(&mqueueCB->mqcb->readWriteList[OS_QUEUE_READ])) {
852 if (msgLen < (size_t)(mqueueCB->mqcb->queueSize - sizeof(UINT32))) {