Searched refs:MessageQueue (Results 1 – 20 of 20) sorted by relevance
| /openthread-latest/tests/unit/ |
| D | test_message_queue.cpp | 49 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()
|
| D | test_priority_queue.cpp | 139 void VerifyMsgQueueContent(MessageQueue &aMessageQueue, int aExpectedLength, ...) in VerifyMsgQueueContent()
175 MessageQueue messageQueue; in TestPriorityQueue()
|
| /openthread-latest/src/core/coap/ |
| D | coap_message.hpp | 162 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()
|
| D | coap.hpp | 313 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;
|
| D | coap_secure.hpp | 133 ot::MessageQueue mTransmitQueue;
|
| D | coap_message.cpp | 494 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/ |
| D | message.hpp | 146 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);
|
| D | message.cpp | 265 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/ |
| D | ip6_mpl.hpp | 196 const MessageQueue &GetBufferedMessageSet(void) const { return mBufferedMessageSet; } in GetBufferedMessageSet()
239 MessageQueue mBufferedMessageSet;
|
| D | ip6.hpp | 404 MessageQueue mReassemblyList;
|
| D | sntp_client.hpp | 266 MessageQueue mPendingQueries;
|
| D | dns_client.hpp | 765 typedef MessageQueue QueryList; // List of queries.
|
| D | dnssd_server.hpp | 317 typedef MessageQueue ProxyQueryList;
|
| /openthread-latest/src/core/meshcop/ |
| D | joiner_router.hpp | 121 MessageQueue mDelayedJoinEnts;
|
| /openthread-latest/src/core/radio/ |
| D | ble_secure.hpp | 312 ot::MessageQueue mTransmitQueue;
|
| /openthread-latest/src/core/api/ |
| D | message_api.cpp | 132 AsCoreType(aQueue).Enqueue(AsCoreType(aMessage), MessageQueue::kQueuePositionHead); in otMessageQueueEnqueueAtHead()
|
| /openthread-latest/src/core/thread/ |
| D | mesh_forwarder.hpp | 265 const MessageQueue &GetReassemblyQueue(void) const { return mReassemblyList; } in GetReassemblyQueue()
624 MessageQueue mReassemblyList;
|
| D | network_diagnostic.hpp | 229 Coap::MessageQueue mAnswerQueue;
|
| D | mle.hpp | 594 const MessageQueue &GetMessageQueue(void) const { return mDelayedSender.GetQueue(); } in GetMessageQueue()
1154 const MessageQueue &GetQueue(void) const { return mSchedules; } in GetQueue()
1181 MessageQueue mSchedules;
|
| D | mle.cpp | 4674 MessageQueue schedulesToExecute; in HandleTimer()
|
