Home
last modified time | relevance | path

Searched refs:queueId (Results 1 – 11 of 11) sorted by relevance

/kernel/uniproton/src/include/uapi/
Dprt_queue.h243 extern U32 PRT_QueueCreate(U16 nodeNum, U16 maxNodeSize, U32 *queueId);
270 extern U32 PRT_QueueRead(U32 queueId, void *bufferAddr, U32 *len, U32 timeOut);
297 extern U32 PRT_QueueWrite(U32 queueId, void *bufferAddr, U32 bufferSize, U32 timeOut, U32 prio);
318 extern U32 PRT_QueueDelete(U32 queueId);
339 extern U32 PRT_QueueGetUsedPeak(U32 queueId, U32 *queueUsedNum);
362 extern U32 PRT_QueueGetNodeNum(U32 queueId, U32 taskPid, U32 *queueNum);
/kernel/uniproton/src/core/ipc/queue/
Dprt_queue_init.c60 OS_SEC_L4_TEXT U32 OsQueueCreatParaCheck(U16 nodeNum, U16 nodeSize, const U32 *queueId) in OsQueueCreatParaCheck() argument
62 if (queueId == NULL) { in OsQueueCreatParaCheck()
76 OS_SEC_L4_TEXT U32 OsQueueCreate(U16 nodeNum, U16 maxNodeSize, U32 *queueId) in OsQueueCreate() argument
119 *queueId = qId; in OsQueueCreate()
127 OS_SEC_L4_TEXT U32 PRT_QueueCreate(U16 nodeNum, U16 maxNodeSize, U32 *queueId) in PRT_QueueCreate() argument
133 ret = OsQueueCreatParaCheck(nodeNum, maxNodeSize, queueId); in PRT_QueueCreate()
145 *queueId = qId; in PRT_QueueCreate()
Dprt_queue_minor.c37 OS_SEC_L2_TEXT U32 PRT_QueueGetUsedPeak(U32 queueId, U32 *queueUsedNum) in PRT_QueueGetUsedPeak() argument
39 U32 innerId = OS_QUEUE_INNER_ID(queueId); in PRT_QueueGetUsedPeak()
60 OS_SEC_L2_TEXT U32 PRT_QueueGetNodeNum(U32 queueId, U32 taskPid, U32 *queueNum) in PRT_QueueGetNodeNum() argument
67 U32 innerId = OS_QUEUE_INNER_ID(queueId); in PRT_QueueGetNodeNum()
Dprt_queue_del.c21 OS_SEC_L4_TEXT U32 PRT_QueueDelete(U32 queueId) in PRT_QueueDelete() argument
25 U32 innerId = OS_QUEUE_INNER_ID(queueId); in PRT_QueueDelete()
Dprt_queue.c129 OS_SEC_L4_TEXT U32 PRT_QueueRead(U32 queueId, void *bufferAddr, U32 *len, U32 timeOut) in PRT_QueueRead() argument
134 U32 innerId = OS_QUEUE_INNER_ID(queueId); in PRT_QueueRead()
263 OS_SEC_L4_TEXT U32 PRT_QueueWrite(U32 queueId, void *bufferAddr, U32 bufferSize, U32 timeOut, U32 p… in PRT_QueueWrite() argument
267 U32 innerId = OS_QUEUE_INNER_ID(queueId); in PRT_QueueWrite()
/kernel/uniproton/src/core/ipc/include/
Dprt_queue_external.h32 #define GET_QUEUE_HANDLE(queueId) (((struct TagQueCb *)g_allQueue) + (queueId)) argument
34 #define OS_QUEUE_INNER_ID(queueId) ((queueId) - 1) argument
/kernel/liteos_m/components/trace/
Dlos_trace.h350 #define QUEUE_CREATE_PARAMS(queueId, queueSz, itemSz, queueAddr, memType) \ argument
351 queueId, queueSz, itemSz, queueAddr, memType
352 #define QUEUE_DELETE_PARAMS(queueId, state, readable) queueId, state, readable argument
353 #define QUEUE_RW_PARAMS(queueId, queueSize, bufSize, operateType, readable, writable, timeout) \ argument
354 queueId, queueSize, bufSize, operateType, readable, writable, timeout
/kernel/liteos_a/kernel/include/
Dlos_trace.h377 #define QUEUE_CREATE_PARAMS(queueId, queueSz, itemSz, queueAddr, memType) \ argument
378 queueId, queueSz, itemSz, queueAddr, memType
379 #define QUEUE_DELETE_PARAMS(queueId, state, readable) queueId, state, readable argument
380 #define QUEUE_RW_PARAMS(queueId, queueSize, bufSize, operateType, readable, writable, timeout) \ argument
381 queueId, queueSize, bufSize, operateType, readable, writable, timeout
/kernel/uniproton/doc/design/
Dinterface_description.md447 U32 PRT_QueueCreate(U16 nodeNum, U16 maxNodeSize, U32 *queueId)
456 queueId [OUT] 类型#U32 *,存储队列ID,ID从1开始。
464 U32 PRT_QueueRead(U32 queueId, void *bufferAddr, U32 *len, U32 timeOut)
471 queueId [IN] 类型#U32,队列ID。
484 U32 PRT_QueueWrite(U32 queueId, void *bufferAddr, U32 bufferSize, U32 timeOut, U32 prio)
491 queueId [IN] 类型#U32,队列ID。
504 U32 PRT_QueueDelete(U32 queueId)
511 queueId [IN] 类型#U32,队列ID。
518 U32 PRT_QueueGetUsedPeak(U32 queueId, U32 *queueUsedNum)
525 queueId [IN] 类型#U32,队列ID
[all …]
/kernel/liteos_m/kal/cmsis/
Dcmsis_liteos2.c1245 UINT32 queueId; in osMessageQueueNew() local
1272 ret = LOS_QueueCreateStatic((const CHAR *)queueName, (UINT16)msg_count, &queueId, \ in osMessageQueueNew()
1275 … ret = LOS_QueueCreate((const CHAR *)queueName, (UINT16)msg_count, &queueId, 0, (UINT16)msg_size); in osMessageQueueNew()
1278 … ret = LOS_QueueCreate((const CHAR *)queueName, (UINT16)msg_count, &queueId, 0, (UINT16)msg_size); in osMessageQueueNew()
1282 handle = (osMessageQueueId_t)(GET_QUEUE_HANDLE(queueId)); in osMessageQueueNew()
/kernel/uniproton/doc/
Dcontribute_guide.md279 #define GET_QUEUE_HANDLE(queueId) (((struct TagQueCb *)g_allQueue) + (queueId))