Searched refs:queueCb (Results 1 - 5 of 5) sorted by relevance
| /kernel/uniproton/src/core/ipc/queue/ |
| H A D | prt_queue.c | 135 struct TagQueCb *queueCb = NULL; in PRT_QueueRead() local
152 queueCb = (struct TagQueCb *)GET_QUEUE_HANDLE(innerId); in PRT_QueueRead()
155 if (queueCb->queueState == OS_QUEUE_UNUSED) { in PRT_QueueRead()
161 ret = OsInnerPend(&queueCb->readableCnt, &queueCb->readList, timeOut); in PRT_QueueRead()
167 queueNode = (struct QueNode *)(uintptr_t)&queueCb->queue[(queueCb->queueHead) * (queueCb->nodeSize)]; in PRT_QueueRead()
181 queueCb->queueHead++; in PRT_QueueRead()
183 if (queueCb in PRT_QueueRead()
221 OsQueueCpData2Node(U32 prio, uintptr_t bufferAddr, U32 bufferSize, struct TagQueCb *queueCb) OsQueueCpData2Node() argument
268 struct TagQueCb *queueCb = NULL; PRT_QueueWrite() local
[all...] |
| H A D | prt_queue_init.c | 82 struct TagQueCb *queueCb = NULL; in OsQueueCreate() local
85 queueCb = g_allQueue; in OsQueueCreate()
86 for (index = 0; index < g_maxQueue; index++, queueCb++) { in OsQueueCreate()
87 if (queueCb->queueState == OS_QUEUE_UNUSED) { in OsQueueCreate()
98 queueCb->queue = (U8 *)OsMemAlloc(OS_MID_QUEUE, OS_MEM_DEFAULT_FSC_PT, (U32)nodeNum * (U32)nodeSize); in OsQueueCreate()
99 if (queueCb->queue == NULL) { in OsQueueCreate()
104 queueNode = (struct QueNode *)(uintptr_t)&queueCb->queue[index * nodeSize]; in OsQueueCreate()
108 queueCb->nodeNum = nodeNum; in OsQueueCreate()
109 queueCb->nodeSize = nodeSize; in OsQueueCreate()
110 queueCb in OsQueueCreate()
[all...] |
| H A D | prt_queue_del.c | 26 struct TagQueCb *queueCb = NULL; in PRT_QueueDelete() local
33 queueCb = (struct TagQueCb *)GET_QUEUE_HANDLE(innerId); in PRT_QueueDelete()
35 if (queueCb->queueState == OS_QUEUE_UNUSED) { in PRT_QueueDelete()
40 if (!ListEmpty(&queueCb->writeList) || !ListEmpty(&queueCb->readList)) { in PRT_QueueDelete()
45 if ((queueCb->writableCnt + queueCb->readableCnt) != queueCb->nodeNum) { in PRT_QueueDelete()
50 ret = PRT_MemFree((U32)OS_MID_QUEUE, (void *)(queueCb->queue)); in PRT_QueueDelete()
55 queueCb in PRT_QueueDelete()
[all...] |
| H A D | prt_queue_minor.c | 17 OS_SEC_L2_TEXT U32 OsQueueGetParaCheck(U32 innerId, const U32 *num, struct TagQueCb **queueCb) in OsQueueGetParaCheck() argument
27 *queueCb = (struct TagQueCb *)GET_QUEUE_HANDLE(innerId); in OsQueueGetParaCheck()
28 if ((*queueCb)->queueState == OS_QUEUE_UNUSED) { in OsQueueGetParaCheck()
40 struct TagQueCb *queueCb = NULL; in PRT_QueueGetUsedPeak() local
45 ret = OsQueueGetParaCheck(innerId, queueUsedNum, &queueCb); in PRT_QueueGetUsedPeak()
51 *queueUsedNum = (U32)queueCb->nodePeak; in PRT_QueueGetUsedPeak()
68 struct TagQueCb *queueCb = NULL; in PRT_QueueGetNodeNum() local
72 ret = OsQueueGetParaCheck(innerId, queueNum, &queueCb); in PRT_QueueGetNodeNum()
79 for (loop = 0; loop < queueCb->nodeNum; loop++) { in PRT_QueueGetNodeNum()
80 queueNode = (struct QueNode *)(uintptr_t)&queueCb in PRT_QueueGetNodeNum()
[all...] |
| /kernel/uniproton/src/net/lwip-2.1/src/ |
| H A D | sys_arch.c | 259 struct TagQueCb *queueCb = NULL;
in sys_mbox_valid() local
260 queueCb = (struct TagQueCb *)GET_QUEUE_HANDLE(innerId);
in sys_mbox_valid()
261 return queueCb->queueState == OS_QUEUE_USED;
in sys_mbox_valid()
|
Completed in 2 milliseconds