| /kernel/uniproton/src/include/uapi/ |
| H A D | prt_queue.h | 235 * @param queueId [OUT] 类型#U32 *，存储队列ID，ID从1开始。
243 extern U32 PRT_QueueCreate(U16 nodeNum, U16 maxNodeSize, U32 *queueId);
258 * @param queueId [IN] 类型#U32，队列ID。
270 extern U32 PRT_QueueRead(U32 queueId, void *bufferAddr, U32 *len, U32 timeOut);
284 * @param queueId [IN] 类型#U32，队列ID。
297 extern U32 PRT_QueueWrite(U32 queueId, void *bufferAddr, U32 bufferSize, U32 timeOut, U32 prio);
309 * @param queueId [IN] 类型#U32，队列ID。
318 extern U32 PRT_QueueDelete(U32 queueId);
329 * @param queueId [IN] 类型#U32，队列ID
339 extern U32 PRT_QueueGetUsedPeak(U32 queueId, U3
[all...] |
| /kernel/uniproton/src/core/ipc/queue/ |
| H A D | prt_queue_init.c | 60 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()
|
| H A D | prt_queue_minor.c | 37 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()
|
| H A D | prt_queue_del.c | 21 OS_SEC_L4_TEXT U32 PRT_QueueDelete(U32 queueId) in PRT_QueueDelete() argument
25 U32 innerId = OS_QUEUE_INNER_ID(queueId); in PRT_QueueDelete()
|
| H A D | prt_queue.c | 129 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 prio) in PRT_QueueWrite() argument
267 U32 innerId = OS_QUEUE_INNER_ID(queueId); in PRT_QueueWrite()
|
| /kernel/uniproton/src/core/ipc/include/ |
| H A D | prt_queue_external.h | 32 #define GET_QUEUE_HANDLE(queueId) (((struct TagQueCb *)g_allQueue) + (queueId))
34 #define OS_QUEUE_INNER_ID(queueId) ((queueId) - 1)
|
| /kernel/liteos_m/components/trace/ |
| H A D | los_trace.h | 350 #define QUEUE_CREATE_PARAMS(queueId, queueSz, itemSz, queueAddr, memType) \
351 queueId, queueSz, itemSz, queueAddr, memType
352 #define QUEUE_DELETE_PARAMS(queueId, state, readable) queueId, state, readable
353 #define QUEUE_RW_PARAMS(queueId, queueSize, bufSize, operateType, readable, writable, timeout) \
354 queueId, queueSize, bufSize, operateType, readable, writable, timeout
|
| /kernel/liteos_a/kernel/include/ |
| H A D | los_trace.h | 377 #define QUEUE_CREATE_PARAMS(queueId, queueSz, itemSz, queueAddr, memType) \
378 queueId, queueSz, itemSz, queueAddr, memType
379 #define QUEUE_DELETE_PARAMS(queueId, state, readable) queueId, state, readable
380 #define QUEUE_RW_PARAMS(queueId, queueSize, bufSize, operateType, readable, writable, timeout) \
381 queueId, queueSize, bufSize, operateType, readable, writable, timeout
|
| /kernel/liteos_m/kal/cmsis/ |
| H A D | cmsis_liteos2.c | 1245 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()
|