| /kernel/liteos_a/kernel/base/ipc/ |
| D | los_queue.c | 104 LosQueueCB *queueCB = NULL; in LOS_QueueCreate() local
145 queueCB = GET_QUEUE_LIST(unusedQueue); in LOS_QueueCreate()
146 queueCB->queueLen = len; in LOS_QueueCreate()
147 queueCB->queueSize = msgSize; in LOS_QueueCreate()
148 queueCB->queueHandle = queue; in LOS_QueueCreate()
149 queueCB->queueState = OS_QUEUE_INUSED; in LOS_QueueCreate()
150 queueCB->readWriteableCnt[OS_QUEUE_READ] = 0; in LOS_QueueCreate()
151 queueCB->readWriteableCnt[OS_QUEUE_WRITE] = len; in LOS_QueueCreate()
152 queueCB->queueHead = 0; in LOS_QueueCreate()
153 queueCB->queueTail = 0; in LOS_QueueCreate()
[all …]
|
| /kernel/liteos_m/kernel/src/ |
| D | los_queue.c | 118 LosQueueCB *queueCB = NULL; in OsQueueCreate() local
185 queueCB = (GET_QUEUE_LIST(unusedQueue)); in OsQueueCreate()
186 queueCB->queueName = (UINT8 *)queueName; // The name can be null in OsQueueCreate()
187 queueCB->queueLen = len; in OsQueueCreate()
188 queueCB->queueSize = msgSize; in OsQueueCreate()
189 queueCB->queue = queue; in OsQueueCreate()
190 queueCB->queueState = OS_QUEUE_INUSED; in OsQueueCreate()
191 queueCB->readWriteableCnt[OS_QUEUE_READ] = 0; in OsQueueCreate()
192 queueCB->readWriteableCnt[OS_QUEUE_WRITE] = len; in OsQueueCreate()
193 queueCB->queueHead = 0; in OsQueueCreate()
[all …]
|
| /kernel/liteos_m/components/trace/cnv/ |
| D | trace_cnv.c | 92 STATIC VOID LOS_TraceQueueCreate(const LosQueueCB *queueCB) in LOS_TraceQueueCreate() argument
94 … LOS_TRACE(QUEUE_CREATE, queueCB->queueID, queueCB->queueLen, queueCB->queueSize - sizeof(UINT32), in LOS_TraceQueueCreate()
95 (UINTPTR)queueCB, 0); in LOS_TraceQueueCreate()
98 STATIC VOID LOS_TraceQueueRW(const LosQueueCB *queueCB, UINT32 operateType, in LOS_TraceQueueRW() argument
101 LOS_TRACE(QUEUE_RW, queueCB->queueID, queueCB->queueSize, bufferSize, operateType, in LOS_TraceQueueRW()
102 … queueCB->readWriteableCnt[OS_QUEUE_READ], queueCB->readWriteableCnt[OS_QUEUE_WRITE], timeout); in LOS_TraceQueueRW()
105 STATIC VOID LOS_TraceQueueDelete(const LosQueueCB *queueCB) in LOS_TraceQueueDelete() argument
107 …LOS_TRACE(QUEUE_DELETE, queueCB->queueID, queueCB->queueState, queueCB->readWriteableCnt[OS_QUEUE_… in LOS_TraceQueueDelete()
|
| /kernel/liteos_a/kernel/extended/trace/cnv/ |
| D | trace_cnv.c | 93 STATIC VOID LOS_TraceQueueCreate(const LosQueueCB *queueCB) in LOS_TraceQueueCreate() argument
95 … LOS_TRACE(QUEUE_CREATE, queueCB->queueID, queueCB->queueLen, queueCB->queueSize - sizeof(UINT32), in LOS_TraceQueueCreate()
96 (UINTPTR)queueCB, 0); in LOS_TraceQueueCreate()
99 STATIC VOID LOS_TraceQueueRW(const LosQueueCB *queueCB, UINT32 operateType, in LOS_TraceQueueRW() argument
102 LOS_TRACE(QUEUE_RW, queueCB->queueID, queueCB->queueSize, bufferSize, operateType, in LOS_TraceQueueRW()
103 … queueCB->readWriteableCnt[OS_QUEUE_READ], queueCB->readWriteableCnt[OS_QUEUE_WRITE], timeout); in LOS_TraceQueueRW()
106 STATIC VOID LOS_TraceQueueDelete(const LosQueueCB *queueCB) in LOS_TraceQueueDelete() argument
108 …LOS_TRACE(QUEUE_DELETE, queueCB->queueID, queueCB->queueState, queueCB->readWriteableCnt[OS_QUEUE_… in LOS_TraceQueueDelete()
|
| /kernel/liteos_m/utils/internal/ |
| D | los_hook_types.h | 69 …LOS_HOOK_TYPE_DEF(LOS_HOOK_TYPE_QUEUE_CREATE, (const LosQueueCB *queueCB)) …
70 …LOS_HOOK_TYPE_DEF(LOS_HOOK_TYPE_QUEUE_READ, (const LosQueueCB *queueCB, UINT32 operateType, …
72 …LOS_HOOK_TYPE_DEF(LOS_HOOK_TYPE_QUEUE_READ_COPY, (const LosQueueCB *queueCB, UINT32 operateType, …
74 …LOS_HOOK_TYPE_DEF(LOS_HOOK_TYPE_QUEUE_WRITE, (const LosQueueCB *queueCB, UINT32 operateType, …
76 …LOS_HOOK_TYPE_DEF(LOS_HOOK_TYPE_QUEUE_WRITE_COPY, (const LosQueueCB *queueCB, UINT32 operateType, …
78 …LOS_HOOK_TYPE_DEF(LOS_HOOK_TYPE_QUEUE_DELETE, (const LosQueueCB *queueCB)) …
|
| /kernel/liteos_a/kernel/base/misc/ |
| D | sysinfo_shellcmd.c | 91 LosQueueCB *queueCB = NULL; in OsShellCmdQueueCntGet() local
94 queueCB = IPC_ALL_QUEUE; in OsShellCmdQueueCntGet()
95 for (loop = 0; loop < LOSCFG_BASE_IPC_QUEUE_LIMIT; loop++, queueCB++) { in OsShellCmdQueueCntGet()
96 if (queueCB->queueState == OS_QUEUE_INUSED) { in OsShellCmdQueueCntGet()
|
| /kernel/liteos_a/kernel/extended/hook/include/ |
| D | los_hook_types.h | 67 …LOS_HOOK_TYPE_DEF(LOS_HOOK_TYPE_QUEUE_CREATE, (const LosQueueCB *queueCB)) …
68 …LOS_HOOK_TYPE_DEF(LOS_HOOK_TYPE_QUEUE_READ, (const LosQueueCB *queueCB, UINT32 operateType, …
70 …LOS_HOOK_TYPE_DEF(LOS_HOOK_TYPE_QUEUE_WRITE, (const LosQueueCB *queueCB, UINT32 operateType, …
72 …LOS_HOOK_TYPE_DEF(LOS_HOOK_TYPE_QUEUE_DELETE, (const LosQueueCB *queueCB)) …
|
| /kernel/liteos_a/testsuites/kernel/src/ |
| D | iCunit.c | 232 LosQueueCB *queueCB = NULL; in ICunitRunF() local
274 queueCB = g_allQueue; in ICunitRunF()
275 for (i = 0; i < LOSCFG_BASE_IPC_QUEUE_LIMIT; i++, queueCB++) { in ICunitRunF()
276 if (queueCB->queueState == OS_QUEUE_UNUSED) { in ICunitRunF()
354 queueCB = g_allQueue; in ICunitRunF()
355 for (i = 0; i < LOSCFG_BASE_IPC_QUEUE_LIMIT; i++, queueCB++) { in ICunitRunF()
356 if (queueCB->queueState == OS_QUEUE_UNUSED) { in ICunitRunF()
|
| D | osTest.c | 208 LosQueueCB *queueCB = (LosQueueCB *)NULL; in QueueCountGetTest() local
211 queueCB = g_allQueue; in QueueCountGetTest()
212 for (loop = 0; loop < LOSCFG_BASE_IPC_QUEUE_CONFIG; loop++, queueCB++) { in QueueCountGetTest()
213 if (queueCB->queueState == OS_QUEUE_INUSED) { in QueueCountGetTest()
|
| /kernel/liteos_m/kal/cmsis/ |
| D | cmsis_liteos2.c | 1292 LosQueueCB *queueCB = (LosQueueCB *)mq_id; in osMessageQueueOp() local
1296 if ((queueCB == NULL) || (msg_ptr == NULL) || (OS_INT_ACTIVE && (timeout != 0))) { in osMessageQueueOp()
1300 bufferSize = (UINT32)(queueCB->queueSize - sizeof(UINT32)); in osMessageQueueOp()
1302 ret = LOS_QueueWriteCopy(queueCB->queueID, msg_ptr, bufferSize, timeout); in osMessageQueueOp()
1304 ret = LOS_QueueReadCopy(queueCB->queueID, msg_ptr, &bufferSize, timeout); in osMessageQueueOp()
1332 LosQueueCB *queueCB = (LosQueueCB *)mq_id; in osMessageQueueGetAttr() local
1335 if (queueCB == NULL) { in osMessageQueueGetAttr()
1339 if (queueCB->queueState == OS_QUEUE_UNUSED) { in osMessageQueueGetAttr()
1345 attrVal = queueCB->queueLen; in osMessageQueueGetAttr()
1348 attrVal = queueCB->queueSize - sizeof(UINT32); in osMessageQueueGetAttr()
[all …]
|
| /kernel/liteos_m/kal/posix/src/ |
| D | mqueue.c | 97 STATIC INLINE UINT32 GetMqueueCBByID(UINT32 queueID, LosQueueCB **queueCB) in GetMqueueCBByID() argument
100 if (queueCB == NULL) { in GetMqueueCBByID()
108 *queueCB = tmpQueueCB; in GetMqueueCBByID()
|
| /kernel/liteos_a/compat/posix/src/ |
| D | mqueue.c | 80 STATIC INLINE UINT32 GetMqueueCBByID(UINT32 queueID, LosQueueCB **queueCB) in GetMqueueCBByID() argument
83 if (queueCB == NULL) { in GetMqueueCBByID()
91 *queueCB = tmpQueueCB; in GetMqueueCBByID()
|