| /kernel/liteos_a/kernel/base/ipc/ |
| H A D | los_queue.c | 147 queueCB->queueSize = msgSize; in LOS_QueueCreate()
240 queueNode = &(queueCB->queueHandle[(queuePosition * (queueCB->queueSize))]); in OsQueueBufferOperate()
243 if (memcpy_s(&msgDataSize, sizeof(UINT32), queueNode + queueCB->queueSize - sizeof(UINT32), in OsQueueBufferOperate()
256 if (memcpy_s(queueNode, queueCB->queueSize, bufferAddr, *bufferSize) != EOK) { in OsQueueBufferOperate()
260 if (memcpy_s(queueNode + queueCB->queueSize - sizeof(UINT32), sizeof(UINT32), bufferSize, in OsQueueBufferOperate()
275 if (OS_QUEUE_IS_WRITE(operateType) && (*bufferSize > (queueCB->queueSize - sizeof(UINT32)))) { in OsQueueOperateParamCheck()
495 queueInfo->usQueueSize = queueCB->queueSize; in LOS_QueueInfoGet()
|
| /kernel/liteos_m/kernel/src/ |
| H A D | los_queue.c | 187 queueCB->queueSize = msgSize;
in OsQueueCreate()
333 queueNode = &(queueCB->queue[(queuePosition * (queueCB->queueSize))]);
in OsQueueBufferOperate()
343 msgDataSize = *((UINT32 *)(UINTPTR)((queueNode + queueCB->queueSize) - sizeof(UINT32)));
in OsQueueBufferOperate()
353 *((UINT32 *)(UINTPTR)((queueNode + queueCB->queueSize) - sizeof(UINT32))) = *bufferSize;
in OsQueueBufferOperate()
354 rc = memcpy_s((VOID *)queueNode, queueCB->queueSize, (VOID *)bufferAddr, *bufferSize);
in OsQueueBufferOperate()
369 if (OS_QUEUE_IS_WRITE(operateType) && (*bufferSize > (queueCB->queueSize - sizeof(UINT32)))) {
in OsQueueOperateParamCheck()
762 queueInfo->queueSize = queueCB->queueSize;
in LOS_QueueInfoGet()
|
| /kernel/liteos_m/kal/cmsis/ |
| H A D | cmsis_liteos2.c | 1251 UINT32 queueSize = 0;
in osMessageQueueNew() local
1262 queueSize = attr->mq_size;
in osMessageQueueNew()
1264 if (((queueSize == 0) && (staticMem != NULL)) || ((queueSize != 0) && (staticMem == NULL))) {
in osMessageQueueNew()
1273 (UINT8 *)staticMem, 0, (UINT16)queueSize / msg_count);
in osMessageQueueNew()
1300 bufferSize = (UINT32)(queueCB->queueSize - sizeof(UINT32));
in osMessageQueueOp()
1348 attrVal = queueCB->queueSize - sizeof(UINT32);
in osMessageQueueGetAttr()
|
| /kernel/liteos_a/kernel/base/include/ |
| H A D | los_queue_pri.h | 72 UINT16 queueSize; /**< Node size */ member
|
| /kernel/liteos_m/components/trace/ |
| H A D | los_trace.h | 353 #define QUEUE_RW_PARAMS(queueId, queueSize, bufSize, operateType, readable, writable, timeout) \
354 queueId, queueSize, bufSize, operateType, readable, writable, timeout
|
| /kernel/liteos_m/components/trace/cnv/ |
| H A D | trace_cnv.c | 94 LOS_TRACE(QUEUE_CREATE, queueCB->queueID, queueCB->queueLen, queueCB->queueSize - sizeof(UINT32), in LOS_TraceQueueCreate()
101 LOS_TRACE(QUEUE_RW, queueCB->queueID, queueCB->queueSize, bufferSize, operateType, in LOS_TraceQueueRW()
|
| /kernel/liteos_m/kernel/include/ |
| H A D | los_queue.h | 365 UINT16 queueSize; /**< Node size */
member
1074 UINT16 queueSize; /**< Node size */
member
|
| /kernel/liteos_m/kal/posix/src/ |
| H A D | mqueue.c | 392 mqAttr->mq_msgsize = mqueueCB->mqcb->queueSize - sizeof(UINT32); 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->queueSize - sizeof(UINT32))) { in mq_timedreceive()
|
| /kernel/liteos_a/kernel/extended/trace/cnv/ |
| H A D | trace_cnv.c | 95 LOS_TRACE(QUEUE_CREATE, queueCB->queueID, queueCB->queueLen, queueCB->queueSize - sizeof(UINT32), in LOS_TraceQueueCreate()
102 LOS_TRACE(QUEUE_RW, queueCB->queueID, queueCB->queueSize, bufferSize, operateType, in LOS_TraceQueueRW()
|
| /kernel/liteos_a/kernel/include/ |
| H A D | los_trace.h | 380 #define QUEUE_RW_PARAMS(queueId, queueSize, bufSize, operateType, readable, writable, timeout) \
381 queueId, queueSize, bufSize, operateType, readable, writable, timeout
|
| /kernel/liteos_a/compat/posix/src/ |
| H A D | mqueue.c | 632 mqAttr->mq_msgsize = mqueueCB->mqcb->queueSize - sizeof(UINT32); in OsMqGetAttr()
802 OS_MQ_GOTO_ERROUT_UNLOCK_IF(msgLen > (size_t)(mqueueCB->mqcb->queueSize - sizeof(UINT32)), EMSGSIZE); in mq_timedsend()
852 if (msgLen < (size_t)(mqueueCB->mqcb->queueSize - sizeof(UINT32))) { in mq_timedreceive()
|