Home
last modified time | relevance | path

Searched refs:Enqueue (Results 1 – 20 of 20) sorted by relevance

/openthread-latest/tests/unit/
Dtest_message_queue.cpp125 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 …]
Dtest_priority_queue.cpp229 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/
Dmessage_api.cpp127 AsCoreType(aQueue).Enqueue(AsCoreType(aMessage)); in otMessageQueueEnqueue()
132 AsCoreType(aQueue).Enqueue(AsCoreType(aMessage), MessageQueue::kQueuePositionHead); in otMessageQueueEnqueueAtHead()
/openthread-latest/src/core/thread/
Dmesh_forwarder_mtd.cpp49 mSendQueue.Enqueue(message); in SendMessage()
Dmesh_forwarder_ftd.cpp51 mSendQueue.Enqueue(message); in SendMessage()
Dnetwork_diagnostic.cpp467 mAnswerQueue.Enqueue(*aAnswer); in AllocateAnswer()
Dmesh_forwarder.cpp1515 mReassemblyList.Enqueue(*message); in HandleFragment()
Dmle.cpp4662 mSchedules.Enqueue(*schedule); in AddSchedule()
4689 schedulesToExecute.Enqueue(schedule); in HandleTimer()
/openthread-latest/src/core/coap/
Dcoap_message.hpp962 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
Dcoap_secure.cpp96 mTransmitQueue.Enqueue(aMessage); in Transmit()
Dcoap.cpp555 mPendingRequests.Enqueue(*messageCopy); in CopyAndEnqueueMessage()
1516 mQueue.Enqueue(*responseCopy); in EnqueueResponse()
/openthread-latest/src/core/common/
Dmessage.hpp1610 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);
Dmessage.cpp350 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/
Dsntp_client.cpp148 mPendingQueries.Enqueue(*messageCopy); in CopyAndEnqueueMessage()
Dip6_mpl.cpp369 mBufferedMessageSet.Enqueue(*messageCopy); in AddBufferedMessage()
Ddnssd_server.cpp1007 mProxyQueries.Enqueue(*query); in ResolveByProxy()
2119 nextActionQueries.Enqueue(query); in HandleResult()
2133 Get<Server>().mProxyQueries.Enqueue(query); in HandleResult()
Dip6.cpp400 mSendQueue.Enqueue(aMessage); in EnqueueDatagram()
671 mReassemblyList.Enqueue(*message); in HandleFragment()
Ddns_client.cpp999 mMainQueries.Enqueue(*query); in StartQuery()
/openthread-latest/src/core/meshcop/
Djoiner_router.cpp211 mDelayedJoinEnts.Enqueue(*message); in DelaySendingJoinerEntrust()
/openthread-latest/src/core/radio/
Dble_secure.cpp242 mTransmitQueue.Enqueue(*mSendMessage); in Flush()