| /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()
|
