Searched refs:messageQueue (Results 1 – 3 of 3) sorted by relevance
/openthread-2.7.6/tests/unit/ |
D | test_message_queue.cpp | 80 ot::MessageQueue messageQueue; in TestMessageQueue() local 95 VerifyMessageQueueContent(messageQueue, 0); in TestMessageQueue() 98 messageQueue.Enqueue(*messages[0]); in TestMessageQueue() 99 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue() 100 messageQueue.Dequeue(*messages[0]); in TestMessageQueue() 101 VerifyMessageQueueContent(messageQueue, 0); in TestMessageQueue() 104 messageQueue.Enqueue(*messages[0], ot::MessageQueue::kQueuePositionHead); in TestMessageQueue() 105 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue() 106 messageQueue.Dequeue(*messages[0]); in TestMessageQueue() 107 VerifyMessageQueueContent(messageQueue, 0); in TestMessageQueue() [all …]
|
D | test_priority_queue.cpp | 148 ot::MessageQueue messageQueue; in TestPriorityQueue() local 262 messageQueue.Enqueue(*msgNor[1]); in TestPriorityQueue() 263 messageQueue.Enqueue(*msgHigh[1]); in TestPriorityQueue() 264 messageQueue.Enqueue(*msgNet[1]); in TestPriorityQueue() 265 VerifyMsgQueueContent(messageQueue, 3, msgNor[1], msgHigh[1], msgNet[1]); in TestPriorityQueue() 269 VerifyMsgQueueContent(messageQueue, 3, msgNor[1], msgHigh[1], msgNet[1]); in TestPriorityQueue() 273 VerifyMsgQueueContent(messageQueue, 3, msgNor[1], msgHigh[1], msgNet[1]); in TestPriorityQueue() 278 VerifyMsgQueueContent(messageQueue, 3, msgNor[1], msgHigh[1], msgNet[1]); in TestPriorityQueue() 280 messageQueue.Dequeue(*msgNet[1]); in TestPriorityQueue() 282 VerifyMsgQueueContent(messageQueue, 2, msgNor[1], msgHigh[1]); in TestPriorityQueue() [all …]
|
/openthread-2.7.6/src/core/common/ |
D | message.cpp | 254 MessageQueue *messageQueue = GetMessageQueue(); in GetNext() local 255 VerifyOrExit(messageQueue != nullptr, next = nullptr); in GetNext() 256 tail = messageQueue->GetTail(); in GetNext()
|