/openthread-latest/tests/unit/ |
D | test_message_queue.cpp | 125 messageQueue.Enqueue(*messages[0]); in TestMessageQueue() 131 messageQueue.Enqueue(*messages[0], MessageQueue::kQueuePositionHead); in TestMessageQueue() 137 messageQueue.Enqueue(*messages[0]); in TestMessageQueue() 139 messageQueue.Enqueue(*messages[1]); in TestMessageQueue() 141 messageQueue.Enqueue(*messages[2]); in TestMessageQueue() 143 messageQueue.Enqueue(*messages[3]); in TestMessageQueue() 145 messageQueue.Enqueue(*messages[4]); in TestMessageQueue() 166 messageQueue.Enqueue(*messages[0]); in TestMessageQueue() 168 messageQueue.Enqueue(*messages[3]); in TestMessageQueue() 176 messageQueue.Enqueue(*messages[2], MessageQueue::kQueuePositionHead); in TestMessageQueue() [all …]
|
D | test_priority_queue.cpp | 229 queue.Enqueue(*msgHigh[0]); in TestPriorityQueue() 231 queue.Enqueue(*msgHigh[1]); in TestPriorityQueue() 233 queue.Enqueue(*msgNet[0]); in TestPriorityQueue() 235 queue.Enqueue(*msgNet[1]); in TestPriorityQueue() 237 queue.Enqueue(*msgHigh[2]); in TestPriorityQueue() 239 queue.Enqueue(*msgLow[0]); in TestPriorityQueue() 241 queue.Enqueue(*msgNor[0]); in TestPriorityQueue() 244 queue.Enqueue(*msgHigh[3]); in TestPriorityQueue() 268 queue.Enqueue(*msgNor[0]); in TestPriorityQueue() 270 queue.Enqueue(*msgHigh[0]); in TestPriorityQueue() [all …]
|
/openthread-latest/src/core/api/ |
D | message_api.cpp | 127 AsCoreType(aQueue).Enqueue(AsCoreType(aMessage)); in otMessageQueueEnqueue() 132 AsCoreType(aQueue).Enqueue(AsCoreType(aMessage), MessageQueue::kQueuePositionHead); in otMessageQueueEnqueueAtHead()
|
/openthread-latest/src/core/thread/ |
D | mesh_forwarder_mtd.cpp | 49 mSendQueue.Enqueue(message); in SendMessage()
|
D | mesh_forwarder_ftd.cpp | 51 mSendQueue.Enqueue(message); in SendMessage()
|
D | network_diagnostic.cpp | 467 mAnswerQueue.Enqueue(*aAnswer); in AllocateAnswer()
|
D | mesh_forwarder.cpp | 1515 mReassemblyList.Enqueue(*message); in HandleFragment()
|
D | mle.cpp | 4662 mSchedules.Enqueue(*schedule); in AddSchedule() 4689 schedulesToExecute.Enqueue(schedule); in HandleTimer()
|
/openthread-latest/src/core/coap/ |
D | coap_message.hpp | 962 void Enqueue(Message &aMessage) { Enqueue(aMessage, kQueuePositionTail); } in Enqueue() function in ot::Coap::MessageQueue 970 …void Enqueue(Message &aMessage, QueuePosition aPosition) { ot::MessageQueue::Enqueue(aMessage, aPo… in Enqueue() function in ot::Coap::MessageQueue
|
D | coap_secure.cpp | 96 mTransmitQueue.Enqueue(aMessage); in Transmit()
|
D | coap.cpp | 555 mPendingRequests.Enqueue(*messageCopy); in CopyAndEnqueueMessage() 1516 mQueue.Enqueue(*responseCopy); in EnqueueResponse()
|
/openthread-latest/src/core/common/ |
D | message.hpp | 1610 void Enqueue(Message &aMessage) { Enqueue(aMessage, kQueuePositionTail); } in Enqueue() function in ot::MessageQueue 1618 void Enqueue(Message &aMessage, QueuePosition aPosition); 1728 void Enqueue(Message &aMessage);
|
D | message.cpp | 350 priorityQueue->Enqueue(*this); in SetPriority() 870 void MessageQueue::Enqueue(Message &aMessage, QueuePosition aPosition) in Enqueue() function in ot::MessageQueue 1011 void PriorityQueue::Enqueue(Message &aMessage) in Enqueue() function in ot::PriorityQueue
|
/openthread-latest/src/core/net/ |
D | sntp_client.cpp | 148 mPendingQueries.Enqueue(*messageCopy); in CopyAndEnqueueMessage()
|
D | ip6_mpl.cpp | 369 mBufferedMessageSet.Enqueue(*messageCopy); in AddBufferedMessage()
|
D | dnssd_server.cpp | 1007 mProxyQueries.Enqueue(*query); in ResolveByProxy() 2119 nextActionQueries.Enqueue(query); in HandleResult() 2133 Get<Server>().mProxyQueries.Enqueue(query); in HandleResult()
|
D | ip6.cpp | 400 mSendQueue.Enqueue(aMessage); in EnqueueDatagram() 671 mReassemblyList.Enqueue(*message); in HandleFragment()
|
D | dns_client.cpp | 999 mMainQueries.Enqueue(*query); in StartQuery()
|
/openthread-latest/src/core/meshcop/ |
D | joiner_router.cpp | 211 mDelayedJoinEnts.Enqueue(*message); in DelaySendingJoinerEntrust()
|
/openthread-latest/src/core/radio/ |
D | ble_secure.cpp | 242 mTransmitQueue.Enqueue(*mSendMessage); in Flush()
|