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