| /kernel/liteos_a/kernel/base/ipc/ |
| D | los_queue.c | 73 queueNode->queueID = index; in OsAllQueueCBInit()
101 LITE_OS_SEC_TEXT_INIT UINT32 LOS_QueueCreate(CHAR *queueName, UINT16 len, UINT32 *queueID, in LOS_QueueCreate() argument
113 if (queueID == NULL) { in LOS_QueueCreate()
158 OsQueueDbgUpdateHook(queueCB->queueID, OsCurrTaskGet()->taskEntry); in LOS_QueueCreate()
161 *queueID = queueCB->queueID; in LOS_QueueCreate()
166 STATIC LITE_OS_SEC_TEXT UINT32 OsQueueReadParameterCheck(UINT32 queueID, const VOID *bufferAddr, in OsQueueReadParameterCheck() argument
169 if (GET_QUEUE_INDEX(queueID) >= LOSCFG_BASE_IPC_QUEUE_LIMIT) { in OsQueueReadParameterCheck()
180 OsQueueDbgTimeUpdateHook(queueID); in OsQueueReadParameterCheck()
190 STATIC LITE_OS_SEC_TEXT UINT32 OsQueueWriteParameterCheck(UINT32 queueID, const VOID *bufferAddr, in OsQueueWriteParameterCheck() argument
193 if (GET_QUEUE_INDEX(queueID) >= LOSCFG_BASE_IPC_QUEUE_LIMIT) { in OsQueueWriteParameterCheck()
[all …]
|
| /kernel/liteos_m/testsuites/sample/kernel/queue/ |
| D | It_los_queue_090.c | 39 UINT32 queueID[LOSCFG_BASE_IPC_QUEUE_LIMIT + 1]; in Testcase() local
51 ret = LOS_QueueCreate(NULL, len, &queueID[index], 0, count); in Testcase()
54 ret = LOS_QueueInfoGet(queueID[index], &queueInfo); in Testcase()
57 ICUNIT_GOTO_EQUAL(queueInfo.queueID, queueID[index], queueInfo.queueID, EXIT); in Testcase()
60 ret = LOS_QueueCreate("Q1", len, &queueID[LOSCFG_BASE_IPC_QUEUE_LIMIT + 1], 0, count); in Testcase()
66 ret = LOS_QueueWrite(queueID[index], filebuf, count, 0); in Testcase()
69 ret = LOS_QueueWrite(queueID[index], filebuf, count, 0); in Testcase()
74 ret = LOS_QueueRead(queueID[index], readbuf, count, 0); in Testcase()
77 ret = LOS_QueueRead(queueID[index], readbuf, count, 0); in Testcase()
81 ret = LOS_QueueWrite(queueID[limit - 1], filebuf, count, 0); in Testcase()
[all …]
|
| D | It_los_queue_021.c | 39 UINT32 queueID[LOSCFG_BASE_IPC_QUEUE_LIMIT + 1]; in Testcase() local
45 ret = LOS_QueueCreate(NULL, QUEUE_BASE_NUM, &queueID[index], 0, QUEUE_BASE_MSGSIZE); in Testcase()
48 ret = LOS_QueueWrite(queueID[limit - 1], &buff1, QUEUE_BASE_MSGSIZE, 0); in Testcase()
51 ret = LOS_QueueRead(queueID[limit - 1], &buff2, QUEUE_BASE_MSGSIZE, 0); in Testcase()
54 ret = LOS_QueueCreate("Q1", QUEUE_BASE_NUM, &queueID[index], 0, QUEUE_BASE_MSGSIZE); in Testcase()
57 ret = LOS_QueueCreate("Q1", QUEUE_BASE_NUM, &queueID[index], 0, QUEUE_BASE_MSGSIZE); in Testcase()
62 ret = LOS_QueueDelete(queueID[index]); in Testcase()
|
| D | It_los_queue_head_015.c | 39 UINT32 queueID[LOSCFG_BASE_IPC_QUEUE_LIMIT + 1]; in Testcase() local
45 ret = LOS_QueueCreate(NULL, QUEUE_BASE_NUM, &queueID[index], 0, QUEUE_BASE_MSGSIZE); in Testcase()
49 ret = LOS_QueueWriteHead(queueID[limit - 1], &buff1, QUEUE_BASE_MSGSIZE, 0); in Testcase()
52 ret = LOS_QueueRead(queueID[limit - 1], &buff2, QUEUE_BASE_MSGSIZE, 0); in Testcase()
55 ret = LOS_QueueCreate("Q1", QUEUE_BASE_NUM, &queueID[index], 0, QUEUE_BASE_MSGSIZE); in Testcase()
60 ret = LOS_QueueDelete(queueID[index]); in Testcase()
|
| /kernel/liteos_m/kernel/src/ |
| D | los_queue.c | 86 queueNode->queueID = index; in OsQueueInit()
102 queueNodeStatic->queueID = index + LOSCFG_BASE_IPC_QUEUE_LIMIT; in OsQueueInit()
113 UINT32 *queueID, in OsQueueCreate() argument
126 if (queueID == NULL) { in OsQueueCreate()
200 *queueID = queueCB->queueID; in OsQueueCreate()
221 UINT32 *queueID, in LOS_QueueCreateStatic() argument
230 ret = OsQueueCreate(queueName, len, queueID, staticMem, 0, maxMsgSize); in LOS_QueueCreateStatic()
247 UINT32 *queueID, in LOS_QueueCreate() argument
255 ret = OsQueueCreate(queueName, len, queueID, NULL, 0, maxMsgSize); in LOS_QueueCreate()
259 static INLINE LITE_OS_SEC_TEXT UINT32 OsQueueReadParameterCheck(UINT32 queueID, VOID *bufferAddr, in OsQueueReadParameterCheck() argument
[all …]
|
| /kernel/liteos_a/testsuites/kernel/sample/kernel_base/ipc/queue/full/ |
| D | It_los_queue_103.c | 43 UINT32 queueID; in Testcase() local
48 queueID = LOSCFG_BASE_IPC_QUEUE_CONFIG; in Testcase()
49 ret = LOS_QueueWriteCopy(queueID, &buff1, 8, 0); // 8, Incoming buffer size. in Testcase()
52 queueID = LOSCFG_BASE_IPC_QUEUE_CONFIG + 1; in Testcase()
53 ret = LOS_QueueWriteCopy(queueID, &buff1, 8, 0); // 8, Incoming buffer size. in Testcase()
56 queueID = LOSCFG_BASE_IPC_QUEUE_CONFIG - 1; in Testcase()
57 ret = LOS_QueueWriteCopy(queueID, &buff1, 8, 0); // 8, Incoming buffer size. in Testcase()
60 queueID = 0; in Testcase()
61 ret = LOS_QueueWriteCopy(queueID - 1, &buff1, 8, 0); // 8, Incoming buffer size. in Testcase()
67 LOS_QueueDelete(queueID); in Testcase()
|
| D | It_los_queue_104.c | 43 UINT32 queueID; in Testcase() local
48 …ret = LOS_QueueCreate("Q1", 3, &queueID, 0, 8); // 3, Set the queue length; 8, Set the node size o… in Testcase()
51 ret = LOS_QueueWriteCopy(queueID, &buff1, 8, 0); // 8, Incoming buffer size. in Testcase()
54 ret = LOS_QueueInfoGet(queueID, &queueInfo); in Testcase()
57 ICUNIT_GOTO_EQUAL(queueInfo.uwQueueID, queueID, queueInfo.uwQueueID, EXIT); in Testcase()
59 ret = LOS_QueueDelete(queueID); in Testcase()
62 ret = LOS_QueueWriteCopy(queueID, &buff1, 8, 0); // 8, Incoming buffer size. in Testcase()
65 ret = LOS_QueueDelete(queueID); in Testcase()
71 LOS_QueueDelete(queueID); in Testcase()
|
| D | It_los_queue_096.c | 43 UINT32 queueID; in Testcase() local
48 queueID = LOSCFG_BASE_IPC_QUEUE_CONFIG + 1; in Testcase()
49 ret = LOS_QueueInfoGet(queueID, &queueInfo); in Testcase()
52 queueID = LOSCFG_BASE_IPC_QUEUE_CONFIG; in Testcase()
53 ret = LOS_QueueInfoGet(queueID, &queueInfo); in Testcase()
56 queueID = LOSCFG_BASE_IPC_QUEUE_CONFIG - 1; in Testcase()
57 ret = LOS_QueueInfoGet(queueID, &queueInfo); in Testcase()
63 LOS_QueueDelete(queueID); in Testcase()
|
| D | It_los_queue_098.c | 43 UINT32 queueID; in Testcase() local
49 queueID = LOSCFG_BASE_IPC_QUEUE_CONFIG + 1; in Testcase()
53 ret = LOS_QueueReadCopy(queueID, &buff2, &readSize, 0); in Testcase()
57 queueID = LOSCFG_BASE_IPC_QUEUE_CONFIG; in Testcase()
62 ret = LOS_QueueReadCopy(queueID, &buff2, &readSize, 0); in Testcase()
66 queueID = LOSCFG_BASE_IPC_QUEUE_CONFIG - 1; in Testcase()
70 ret = LOS_QueueReadCopy(queueID, &buff2, &readSize, 0); in Testcase()
74 queueID = 0; in Testcase()
78 ret = LOS_QueueReadCopy(queueID - 1, &buff2, &readSize, 0); in Testcase()
85 LOS_QueueDelete(queueID); in Testcase()
|
| D | It_los_queue_102.c | 43 UINT32 queueID; in Testcase() local
49 ret = LOS_QueueCreate("Q1", 3, &queueID, 0, sizeof(UINTPTR)); // 3, Set the queue length. in Testcase()
52 ret = LOS_QueueWrite(queueID, &buff1, 8, 0); // 8, Write the setting size of queue buffer. in Testcase()
58 ret = LOS_QueueReadCopy(queueID, &buff2, &readSize, 0xffffffff); in Testcase()
61 ret = LOS_QueueWrite(queueID, &buff1, 8, 0); // 8, Write the setting size of queue buffer. in Testcase()
67 ret = LOS_QueueReadCopy(queueID, &buff2, &readSize, 0xffffffff + 1); in Testcase()
70 ret = LOS_QueueWrite(queueID, &buff1, 8, 0); // 8, Write the setting size of queue buffer. in Testcase()
76 ret = LOS_QueueReadCopy(queueID, &buff2, &readSize, 0xffffffff - 1); in Testcase()
79 ret = LOS_QueueDelete(queueID); in Testcase()
85 LOS_QueueDelete(queueID); in Testcase()
|
| D | It_los_queue_107.c | 43 UINT32 queueID; in Testcase() local
48 …ret = LOS_QueueCreate("Q1", 3, &queueID, 0, QUEUE_SHORT_BUFFER_LENGTH); // 3, Set the queue length. in Testcase()
51 ret = LOS_QueueWriteCopy(queueID, &buff1, QUEUE_SHORT_BUFFER_LENGTH, 0xffffffff); in Testcase()
56 ret = LOS_QueueRead(queueID, &buff2, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
59 ret = LOS_QueueWriteCopy(queueID, &buff1, QUEUE_SHORT_BUFFER_LENGTH, 0xffffffff + 1); in Testcase()
64 ret = LOS_QueueRead(queueID, &buff2, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
67 ret = LOS_QueueWriteCopy(queueID, &buff1, QUEUE_SHORT_BUFFER_LENGTH, 0xffffffff - 1); in Testcase()
72 ret = LOS_QueueRead(queueID, &buff2, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
75 ret = LOS_QueueDelete(queueID); in Testcase()
81 LOS_QueueDelete(queueID); in Testcase()
|
| D | It_los_queue_114.c | 44 UINT32 queueID; in Testcase() local
49 …ret = LOS_QueueCreate("Q1", 3, &queueID, 0, QUEUE_SHORT_BUFFER_LENGTH); // 3, Set the queue length. in Testcase()
53 ret = LOS_QueueWriteCopy(queueID, &buff1, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
57 ret = LOS_QueueWrite(queueID, &buff1, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
60 ret = LOS_QueueWriteCopy(queueID, &buff1, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
63 ret = LOS_QueueInfoGet(queueID, &queueInfo); in Testcase()
66 ICUNIT_GOTO_EQUAL(queueInfo.uwQueueID, queueID, queueInfo.uwQueueID, EXIT); in Testcase()
68 ret = LOS_QueueDelete(queueID); in Testcase()
74 LOS_QueueDelete(queueID); in Testcase()
|
| D | It_los_queue_106.c | 43 UINT32 queueID; in Testcase() local
48 …ret = LOS_QueueCreate("Q1", 3, &queueID, 0, QUEUE_SHORT_BUFFER_LENGTH); // 3, Set the queue length. in Testcase()
51 ret = LOS_QueueWriteCopy(queueID, NULL, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
56 ret = LOS_QueueRead(queueID, &buff2, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
59 ret = LOS_QueueWriteCopy(queueID, &buff1, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
64 ret = LOS_QueueRead(queueID, &buff2, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
67 ret = LOS_QueueDelete(queueID); in Testcase()
73 LOS_QueueDelete(queueID); in Testcase()
|
| D | It_los_queue_099.c | 43 UINT32 queueID; in Testcase() local
49 …ret = LOS_QueueCreate("Q1", 3, &queueID, 0, 8); // 3, Set the queue length; 8, Set the node size o… in Testcase()
52 ret = LOS_QueueInfoGet(queueID, &queueInfo); in Testcase()
55 ret = LOS_QueueDelete(queueID); in Testcase()
61 ret = LOS_QueueReadCopy(queueID, &buff2, &readSize, 0); in Testcase()
64 ret = LOS_QueueInfoGet(queueID, &queueInfo); in Testcase()
70 LOS_QueueDelete(queueID); in Testcase()
|
| D | It_los_queue_101.c | 43 UINT32 queueID; in Testcase() local
49 ret = LOS_QueueCreate("Q1", 3, &queueID, 0, sizeof(UINTPTR)); // 3, Set the queue length. in Testcase()
52 ret = LOS_QueueWrite(queueID, &buff1, 8, 0); // 8, Write the setting size of queue buffer. in Testcase()
58 ret = LOS_QueueReadCopy(queueID, NULL, &readSize, 0); in Testcase()
64 ret = LOS_QueueReadCopy(queueID, &buff2, &readSize, 0); in Testcase()
67 ret = LOS_QueueDelete(queueID); in Testcase()
73 LOS_QueueDelete(queueID); in Testcase()
|
| D | It_los_queue_021.c | 44 UINT32 queueID[LOSCFG_BASE_IPC_QUEUE_CONFIG + 1]; in Testcase() local
50 … ret = LOS_QueueCreate(NULL, 3, &queueID[index], 0, sizeof(UINTPTR)); // 3, Set the queue length. in Testcase()
54 …ret = LOS_QueueWrite(queueID[index - 1], &buff1, 8, 0); // 8, Write the setting size of queue buff… in Testcase()
57 …ret = LOS_QueueRead(queueID[index - 1], &buff2, 8, 0); // 8, Read the setting size of queue buffer. in Testcase()
60 …ret = LOS_QueueCreate("Q1", 3, &queueID[index], 0, 8); // 3, Set the queue length; 8, Set the node… in Testcase()
63 …ret = LOS_QueueCreate("Q1", 3, &queueID[index], 0, 8); // 3, Set the queue length; 8, Set the node… in Testcase()
68 ret = LOS_QueueDelete(queueID[index]); in Testcase()
|
| D | It_los_queue_head_015.c | 43 UINT32 queueID[LOSCFG_BASE_IPC_QUEUE_CONFIG + 1]; in Testcase() local
49 … ret = LOS_QueueCreate(NULL, 3, &queueID[index], 0, sizeof(UINTPTR)); // 3, Set the queue length. in Testcase()
53 ret = LOS_QueueWriteHead(queueID[index - 1], &buff1, sizeof(UINTPTR), 0); in Testcase()
56 ret = LOS_QueueRead(queueID[index - 1], &buff2, sizeof(UINTPTR), 0); in Testcase()
59 …ret = LOS_QueueCreate("Q1", 3, &queueID[index], 0, 8); // 3, Set the queue length; 8, Set the node… in Testcase()
63 ret = LOS_QueueDelete(queueID[index]); in Testcase()
|
| /kernel/liteos_a/testsuites/kernel/sample/kernel_base/ipc/queue/smoke/ |
| D | It_los_queue_105.c | 43 UINT32 queueID; in Testcase() local
49 …ret = LOS_QueueCreate("Q1", 3, &queueID, 0, QUEUE_SHORT_BUFFER_LENGTH); // 3, Set the queue length. in Testcase()
52 ret = LOS_QueueWriteCopy(queueID, &buff1, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
57 ret = LOS_QueueRead(queueID, &buff2, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
60 ret = LOS_QueueWriteCopy(queueID, &buff1, QUEUE_SHORT_BUFFER_LENGTH + PER_ADDED_VALUE, 0); in Testcase()
65 ret = LOS_QueueRead(queueID, &buff2, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
68 ret = LOS_QueueWrite(queueID, &buff1, QUEUE_SHORT_BUFFER_LENGTH - 1, 0); in Testcase()
73 ret = LOS_QueueRead(queueID, &buff2, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
78 ret = LOS_QueueRead(queueID, &buff2, QUEUE_SHORT_BUFFER_LENGTH, 0); in Testcase()
81 ret = LOS_QueueWrite(queueID, &buff1, 0, 0); in Testcase()
[all …]
|
| D | It_los_queue_100.c | 43 UINT32 queueID; in Testcase() local
48 ret = LOS_QueueCreate("Q1", 3, &queueID, 0, sizeof(UINTPTR)); // 3, Set the queue length. in Testcase()
51 ret = LOS_QueueWrite(queueID, &buff1, 8, 0); // 8, Write the setting size of queue buffer. in Testcase()
57 ret = LOS_QueueReadCopy(queueID, &buff2, &readSize, 0); in Testcase()
60 ret = LOS_QueueWrite(queueID, &buff1, 8, 0); // 8, Write the setting size of queue buffer. in Testcase()
66 ret = LOS_QueueReadCopy(queueID, &buff2, &readSize, 0); in Testcase()
69 ret = LOS_QueueWrite(queueID, &buff1, 8, 0); // 8, Write the setting size of queue buffer. in Testcase()
75 ret = LOS_QueueReadCopy(queueID, &buff2, &readSize, 0); in Testcase()
78 ret = LOS_QueueWrite(queueID, &buff1, 8, 0); // 8, Write the setting size of queue buffer. in Testcase()
84 ret = LOS_QueueReadCopy(queueID, &buff2, &readSize, 0); in Testcase()
[all …]
|
| D | It_los_queue_097.c | 42 UINT32 queueID; in Testcase() local
47 …ret = LOS_QueueCreate("Q1", 3, &queueID, 0, 8); // 3, Set the queue length; 8, Set the node size o… in Testcase()
50 ret = LOS_QueueWrite(queueID, &buff1, 8, 0); // 8, Write the setting size of queue buffer. in Testcase()
53 ret = LOS_QueueInfoGet(queueID, &queueInfo); in Testcase()
56 ICUNIT_GOTO_EQUAL(queueInfo.uwQueueID, queueID, queueInfo.uwQueueID, EXIT); in Testcase()
58 ret = LOS_QueueDelete(queueID); in Testcase()
61 ret = LOS_QueueInfoGet(queueID, &queueInfo); in Testcase()
64 ret = LOS_QueueDelete(queueID); in Testcase()
70 LOS_QueueDelete(queueID); in Testcase()
|
| /kernel/liteos_a/kernel/base/include/ |
| D | los_queue_pri.h | 73 UINT32 queueID; /**< queueID */ member
124 #define SET_QUEUE_ID(count, queueID) (((count) << QUEUE_SPLIT_BIT) | (queueID)) argument
130 #define GET_QUEUE_INDEX(queueID) ((queueID) & ((1U << QUEUE_SPLIT_BIT) - 1)) argument
136 #define GET_QUEUE_COUNT(queueID) ((queueID) >> QUEUE_SPLIT_BIT) argument
143 #define GET_QUEUE_HANDLE(queueID) (((LosQueueCB *)IPC_ALL_QUEUE) + GET_QUEUE_INDEX(queueID)) argument
174 extern VOID *OsQueueMailAlloc(UINT32 queueID, VOID *mailPool, UINT32 timeout);
200 extern UINT32 OsQueueMailFree(UINT32 queueID, VOID *mailPool, VOID *mailMem);
|
| D | los_queue_debug_pri.h | 56 extern VOID OsQueueDbgTimeUpdate(UINT32 queueID);
57 STATIC INLINE VOID OsQueueDbgTimeUpdateHook(UINT32 queueID) in OsQueueDbgTimeUpdateHook() argument
60 OsQueueDbgTimeUpdate(queueID); in OsQueueDbgTimeUpdateHook()
64 extern VOID OsQueueDbgUpdate(UINT32 queueID, TSK_ENTRY_FUNC entry);
65 STATIC INLINE VOID OsQueueDbgUpdateHook(UINT32 queueID, TSK_ENTRY_FUNC entry) in OsQueueDbgUpdateHook() argument
68 OsQueueDbgUpdate(queueID, entry); in OsQueueDbgUpdateHook()
|
| /kernel/liteos_m/kernel/include/ |
| D | los_queue.h | 362 UINT32 queueID; /**< Queue ID */ member
403 UINT32 *queueID,
437 UINT32 *queueID,
485 extern UINT32 LOS_QueueReadCopy(UINT32 queueID,
531 extern UINT32 LOS_QueueWriteCopy(UINT32 queueID,
580 extern UINT32 LOS_QueueRead(UINT32 queueID,
627 extern UINT32 LOS_QueueWrite(UINT32 queueID,
674 extern UINT32 LOS_QueueWriteHead(UINT32 queueID,
721 extern UINT32 LOS_QueueWriteHeadCopy(UINT32 queueID,
752 extern UINT32 LOS_QueueDelete(UINT32 queueID);
[all …]
|
| /kernel/liteos_a/kernel/include/ |
| D | los_queue.h | 380 UINT32 *queueID,
428 extern UINT32 LOS_QueueReadCopy(UINT32 queueID,
475 extern UINT32 LOS_QueueWriteCopy(UINT32 queueID,
526 extern UINT32 LOS_QueueRead(UINT32 queueID,
574 extern UINT32 LOS_QueueWrite(UINT32 queueID,
622 extern UINT32 LOS_QueueWriteHead(UINT32 queueID,
670 extern UINT32 LOS_QueueWriteHeadCopy(UINT32 queueID,
701 extern UINT32 LOS_QueueDelete(UINT32 queueID);
727 extern UINT32 LOS_QueueInfoGet(UINT32 queueID, QUEUE_INFO_S *queueInfo);
|
| /kernel/liteos_m/kal/posix/src/ |
| D | mqueue_impl.h | 88 #define SET_QUEUE_ID(count, queueID) (((count) << QUEUE_SPLIT_BIT) | (queueID)) argument
94 #define GET_QUEUE_INDEX(queueID) ((queueID) & ((1U << QUEUE_SPLIT_BIT) - 1)) argument
100 #define GET_QUEUE_COUNT(queueID) ((queueID) >> QUEUE_SPLIT_BIT) argument
|