Searched refs:queueNode (Results 1 – 7 of 7) sorted by relevance
| /kernel/liteos_a/kernel/base/ipc/ |
| D | los_queue_debug.c | 100 LosQueueCB queueNode = {0}; in SortQueueIndexArray() local
115 (VOID)memcpy_s(&queueNode, sizeof(LosQueueCB), in SortQueueIndexArray()
120 if (queueNode.queueState == OS_QUEUE_UNUSED) { in SortQueueIndexArray()
123 OsQueueInfoOutPut(&queueNode); in SortQueueIndexArray()
132 LosQueueCB queueNode = {0}; in OsQueueCheck() local
146 (VOID)memcpy_s(&queueNode, sizeof(LosQueueCB), in OsQueueCheck()
151 if ((queueNode.queueState == OS_QUEUE_UNUSED) || in OsQueueCheck()
152 ((queueNode.queueState == OS_QUEUE_INUSED) && (queueDebugNode.creator == NULL))) { in OsQueueCheck()
155 if ((queueNode.queueState == OS_QUEUE_INUSED) && in OsQueueCheck()
156 (queueNode.queueLen == queueNode.readWriteableCnt[OS_QUEUE_WRITE]) && in OsQueueCheck()
[all …]
|
| D | los_queue.c | 72 LosQueueCB *queueNode = ((LosQueueCB *)allQueue) + index; in OsAllQueueCBInit() local
73 queueNode->queueID = index; in OsAllQueueCBInit()
74 LOS_ListTailInsert(freeQueueList, &queueNode->readWriteList[OS_QUEUE_WRITE]); in OsAllQueueCBInit()
217 UINT8 *queueNode = NULL; in OsQueueBufferOperate() local
240 queueNode = &(queueCB->queueHandle[(queuePosition * (queueCB->queueSize))]); in OsQueueBufferOperate()
243 if (memcpy_s(&msgDataSize, sizeof(UINT32), queueNode + queueCB->queueSize - sizeof(UINT32), in OsQueueBufferOperate()
249 if (memcpy_s(bufferAddr, *bufferSize, queueNode, msgDataSize) != EOK) { 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()
|
| /kernel/uniproton/src/core/ipc/queue/ |
| D | prt_queue.c | 136 struct QueNode *queueNode = NULL; in PRT_QueueRead() local
167 …queueNode = (struct QueNode *)(uintptr_t)&queueCb->queue[(queueCb->queueHead) * (queueCb->nodeSize… in PRT_QueueRead()
170 if (*len > queueNode->size) { in PRT_QueueRead()
171 *len = queueNode->size; in PRT_QueueRead()
174 if (memcpy_s(bufferAddr, bufLen, (void *)queueNode->buf, *len) != EOK) { in PRT_QueueRead()
178 queueNode->srcPid = OS_QUEUE_PID_INVALID; in PRT_QueueRead()
225 struct QueNode *queueNode = NULL; in OsQueueCpData2Node() local
228 …queueNode = (struct QueNode *)(uintptr_t)&queueCb->queue[((queueCb->queueTail) * (queueCb->nodeSiz… in OsQueueCpData2Node()
241 …queueNode = (struct QueNode *)(uintptr_t)&queueCb->queue[((queueCb->queueHead) * (queueCb->nodeSiz… in OsQueueCpData2Node()
244 if (memcpy_s((void *)queueNode->buf, (queueCb->nodeSize - OS_QUEUE_NODE_HEAD_LEN), in OsQueueCpData2Node()
[all …]
|
| D | prt_queue_minor.c | 69 struct QueNode *queueNode = NULL; in PRT_QueueGetNodeNum() local
80 queueNode = (struct QueNode *)(uintptr_t)&queueCb->queue[loop * (queueCb->nodeSize)]; in PRT_QueueGetNodeNum()
81 if (queueNode->srcPid == taskPid) { in PRT_QueueGetNodeNum()
85 if (queueNode->srcPid != OS_QUEUE_PID_INVALID) { in PRT_QueueGetNodeNum()
|
| D | prt_queue_init.c | 80 struct QueNode *queueNode = NULL; in OsQueueCreate() local
104 queueNode = (struct QueNode *)(uintptr_t)&queueCb->queue[index * nodeSize]; in OsQueueCreate()
105 queueNode->srcPid = OS_QUEUE_PID_INVALID; in OsQueueCreate()
|
| /kernel/liteos_m/kernel/src/ |
| D | los_queue.c | 64 LosQueueCB *queueNode = NULL; in OsQueueInit() local
85 queueNode = ((LosQueueCB *)g_allQueue) + index; in OsQueueInit()
86 queueNode->queueID = index; in OsQueueInit()
87 LOS_ListTailInsert(&g_freeQueueList, &queueNode->readWriteList[OS_QUEUE_WRITE]); in OsQueueInit()
307 UINT8 *queueNode = NULL; in OsQueueBufferOperate() local
334 queueNode = &(queueCB->queue[(queuePosition * (queueCB->queueSize))]); in OsQueueBufferOperate()
338 *(UINTPTR *)bufferAddr = *(UINTPTR *)(VOID *)queueNode; in OsQueueBufferOperate()
340 *(UINTPTR *)(VOID *)queueNode = *(UINTPTR *)bufferAddr; in OsQueueBufferOperate()
344 msgDataSize = *((UINT32 *)(UINTPTR)((queueNode + queueCB->queueSize) - sizeof(UINT32))); in OsQueueBufferOperate()
346 rc = memcpy_s((VOID *)bufferAddr, *bufferSize, (VOID *)queueNode, msgDataSize); in OsQueueBufferOperate()
[all …]
|
| /kernel/liteos_m/testsuites/src/ |
| D | osTest.c | 121 LosQueueCB *queueNode = ((LosQueueCB *)g_allQueue) + index; in QueueUsedCountGet() local
122 if (queueNode->queueState == OS_QUEUE_INUSED) { in QueueUsedCountGet()
129 LosQueueCB *queueNode = ((LosQueueCB *)g_staticQueue) + index; in QueueUsedCountGet() local
130 if (queueNode->queueState == OS_QUEUE_INUSED) { in QueueUsedCountGet()
|