Searched refs:messageQueue (Results 1 – 3 of 3) sorted by relevance
/openthread-latest/tests/unit/ |
D | test_message_queue.cpp | 107 MessageQueue messageQueue; in TestMessageQueue() local 122 VerifyMessageQueueContent(messageQueue, 0); in TestMessageQueue() 125 messageQueue.Enqueue(*messages[0]); in TestMessageQueue() 126 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue() 127 messageQueue.Dequeue(*messages[0]); in TestMessageQueue() 128 VerifyMessageQueueContent(messageQueue, 0); in TestMessageQueue() 131 messageQueue.Enqueue(*messages[0], MessageQueue::kQueuePositionHead); in TestMessageQueue() 132 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue() 133 messageQueue.Dequeue(*messages[0]); in TestMessageQueue() 134 VerifyMessageQueueContent(messageQueue, 0); in TestMessageQueue() [all …]
|
D | test_priority_queue.cpp | 175 MessageQueue messageQueue; in TestPriorityQueue() local 289 messageQueue.Enqueue(*msgNor[1]); in TestPriorityQueue() 290 messageQueue.Enqueue(*msgHigh[1]); in TestPriorityQueue() 291 messageQueue.Enqueue(*msgNet[1]); in TestPriorityQueue() 292 VerifyMsgQueueContent(messageQueue, 3, msgNor[1], msgHigh[1], msgNet[1]); in TestPriorityQueue() 296 VerifyMsgQueueContent(messageQueue, 3, msgNor[1], msgHigh[1], msgNet[1]); in TestPriorityQueue() 300 VerifyMsgQueueContent(messageQueue, 3, msgNor[1], msgHigh[1], msgNet[1]); in TestPriorityQueue() 305 VerifyMsgQueueContent(messageQueue, 3, msgNor[1], msgHigh[1], msgNet[1]); in TestPriorityQueue() 307 messageQueue.Dequeue(*msgNet[1]); in TestPriorityQueue() 309 VerifyMsgQueueContent(messageQueue, 2, msgNor[1], msgHigh[1]); in TestPriorityQueue() [all …]
|
/openthread-latest/src/core/common/ |
D | message.cpp | 265 MessageQueue *messageQueue = GetMessageQueue(); in GetNext() local 266 VerifyOrExit(messageQueue != nullptr, next = nullptr); in GetNext() 267 tail = messageQueue->GetTail(); in GetNext()
|