Home
last modified time | relevance | path

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

/openthread-latest/tests/unit/
Dtest_message_queue.cpp49 void VerifyMessageQueueContent(MessageQueue &aMessageQueue, int aExpectedLength, ...) in VerifyMessageQueueContent()
51 const MessageQueue &constQueue = aMessageQueue; in VerifyMessageQueueContent()
107 MessageQueue messageQueue; in TestMessageQueue()
109 MessageQueue::Info info; in TestMessageQueue()
131 messageQueue.Enqueue(*messages[0], MessageQueue::kQueuePositionHead); in TestMessageQueue()
176 messageQueue.Enqueue(*messages[2], MessageQueue::kQueuePositionHead); in TestMessageQueue()
188 messageQueue.Enqueue(*messages[1], MessageQueue::kQueuePositionHead); in TestMessageQueue()
192 messageQueue.Enqueue(*messages[2], MessageQueue::kQueuePositionTail); in TestMessageQueue()
Dtest_priority_queue.cpp139 void VerifyMsgQueueContent(MessageQueue &aMessageQueue, int aExpectedLength, ...) in VerifyMsgQueueContent()
175 MessageQueue messageQueue; in TestPriorityQueue()
/openthread-latest/src/core/coap/
Dcoap_message.hpp162 friend class MessageQueue;
935 class MessageQueue : public ot::MessageQueue class
941 MessageQueue(void) = default;
948 Message *GetHead(void) { return static_cast<Message *>(ot::MessageQueue::GetHead()); } in GetHead()
955 …const Message *GetHead(void) const { return static_cast<const Message *>(ot::MessageQueue::GetHead… in GetHead()
970 …void Enqueue(Message &aMessage, QueuePosition aPosition) { ot::MessageQueue::Enqueue(aMessage, aPo… in Enqueue()
977 void Dequeue(Message &aMessage) { ot::MessageQueue::Dequeue(aMessage); } in Dequeue()
984 void DequeueAndFree(Message &aMessage) { ot::MessageQueue::DequeueAndFree(aMessage); } in DequeueAndFree()
Dcoap.hpp313 const MessageQueue &GetResponses(void) const { return mQueue; } in GetResponses()
331 MessageQueue mQueue;
727 const MessageQueue &GetRequestMessages(void) const { return mPendingRequests; } in GetRequestMessages()
734 const MessageQueue &GetCachedResponses(void) const { return mResponsesQueue.GetResponses(); } in GetCachedResponses()
874 MessageQueue mPendingRequests;
Dcoap_secure.hpp133 ot::MessageQueue mTransmitQueue;
Dcoap_message.cpp494 Message::Iterator MessageQueue::begin(void) { return Message::Iterator(GetHead()); } in begin()
496 Message::ConstIterator MessageQueue::begin(void) const { return Message::ConstIterator(GetHead()); } in begin()
/openthread-latest/src/core/common/
Dmessage.hpp146 class MessageQueue;
279 friend class MessageQueue;
1372 MessageQueue *GetMessageQueue(void) const in GetMessageQueue()
1374 … return !GetMetadata().mInPriorityQ ? static_cast<MessageQueue *>(GetMetadata().mQueue) : nullptr; in GetMessageQueue()
1549 void SetMessageQueue(MessageQueue *aMessageQueue);
1568 class MessageQueue : public otMessageQueue class
1589 MessageQueue(void) { SetTail(nullptr); } in MessageQueue() function in ot::MessageQueue
1674 friend class MessageQueue;
1808 friend class MessageQueue;
1904 DefineCoreType(otMessageQueue, MessageQueue);
Dmessage.cpp265 MessageQueue *messageQueue = GetMessageQueue(); in GetNext()
855 void Message::SetMessageQueue(MessageQueue *aMessageQueue) in SetMessageQueue()
870 void MessageQueue::Enqueue(Message &aMessage, QueuePosition aPosition) in Enqueue()
901 void MessageQueue::Dequeue(Message &aMessage) in Dequeue()
925 void MessageQueue::DequeueAndFree(Message &aMessage) in DequeueAndFree()
931 void MessageQueue::DequeueAndFreeAll(void) in DequeueAndFreeAll()
941 Message::Iterator MessageQueue::begin(void) { return Message::Iterator(GetHead()); } in begin()
943 Message::ConstIterator MessageQueue::begin(void) const { return Message::ConstIterator(GetHead()); } in begin()
945 void MessageQueue::GetInfo(Info &aInfo) const in GetInfo()
/openthread-latest/src/core/net/
Dip6_mpl.hpp196 const MessageQueue &GetBufferedMessageSet(void) const { return mBufferedMessageSet; } in GetBufferedMessageSet()
239 MessageQueue mBufferedMessageSet;
Dip6.hpp404 MessageQueue mReassemblyList;
Dsntp_client.hpp266 MessageQueue mPendingQueries;
Ddns_client.hpp765 typedef MessageQueue QueryList; // List of queries.
Ddnssd_server.hpp317 typedef MessageQueue ProxyQueryList;
/openthread-latest/src/core/meshcop/
Djoiner_router.hpp121 MessageQueue mDelayedJoinEnts;
/openthread-latest/src/core/radio/
Dble_secure.hpp312 ot::MessageQueue mTransmitQueue;
/openthread-latest/src/core/api/
Dmessage_api.cpp132 AsCoreType(aQueue).Enqueue(AsCoreType(aMessage), MessageQueue::kQueuePositionHead); in otMessageQueueEnqueueAtHead()
/openthread-latest/src/core/thread/
Dmesh_forwarder.hpp265 const MessageQueue &GetReassemblyQueue(void) const { return mReassemblyList; } in GetReassemblyQueue()
624 MessageQueue mReassemblyList;
Dnetwork_diagnostic.hpp229 Coap::MessageQueue mAnswerQueue;
Dmle.hpp594 const MessageQueue &GetMessageQueue(void) const { return mDelayedSender.GetQueue(); } in GetMessageQueue()
1154 const MessageQueue &GetQueue(void) const { return mSchedules; } in GetQueue()
1181 MessageQueue mSchedules;
Dmle.cpp4674 MessageQueue schedulesToExecute; in HandleTimer()