Searched refs:MessageQueue (Results 1 – 15 of 15) sorted by relevance
/openthread-2.7.6/src/core/api/ |
D | message_api.cpp | 126 MessageQueue &queue = *static_cast<MessageQueue *>(aQueue); in otMessageQueueEnqueue() 134 MessageQueue &queue = *static_cast<MessageQueue *>(aQueue); in otMessageQueueEnqueueAtHead() 136 queue.Enqueue(message, MessageQueue::kQueuePositionHead); in otMessageQueueEnqueueAtHead() 142 MessageQueue &queue = *static_cast<MessageQueue *>(aQueue); in otMessageQueueDequeue() 149 MessageQueue &queue = *static_cast<MessageQueue *>(aQueue); in otMessageQueueGetHead() 161 MessageQueue & queue = *static_cast<MessageQueue *>(aQueue); in otMessageQueueGetNext()
|
/openthread-2.7.6/tests/unit/ |
D | test_message_queue.cpp | 47 void VerifyMessageQueueContent(ot::MessageQueue &aMessageQueue, int aExpectedLength, ...) in VerifyMessageQueueContent() 80 ot::MessageQueue messageQueue; in TestMessageQueue() 104 messageQueue.Enqueue(*messages[0], ot::MessageQueue::kQueuePositionHead); in TestMessageQueue() 148 messageQueue.Enqueue(*messages[2], ot::MessageQueue::kQueuePositionHead); in TestMessageQueue() 160 messageQueue.Enqueue(*messages[1], ot::MessageQueue::kQueuePositionHead); in TestMessageQueue() 164 messageQueue.Enqueue(*messages[2], ot::MessageQueue::kQueuePositionTail); in TestMessageQueue()
|
D | test_priority_queue.cpp | 112 void VerifyMsgQueueContent(ot::MessageQueue &aMessageQueue, int aExpectedLength, ...) in VerifyMsgQueueContent() 148 ot::MessageQueue messageQueue; in TestPriorityQueue()
|
/openthread-2.7.6/src/core/common/ |
D | message.hpp | 142 class MessageQueue; 157 … MessageQueue * mMessage; ///< Identifies the message queue (if any) where this message is queued. 310 friend class MessageQueue; 1145 MessageQueue *GetMessageQueue(void) const in GetMessageQueue() 1287 void SetMessageQueue(MessageQueue *aMessageQueue); 1383 class MessageQueue : public otMessageQueue class 1404 MessageQueue(void); 1487 friend class MessageQueue; 1599 friend class MessageQueue;
|
D | message.cpp | 254 MessageQueue *messageQueue = GetMessageQueue(); in GetNext() 727 void Message::SetMessageQueue(MessageQueue *aMessageQueue) in SetMessageQueue() 739 MessageQueue::MessageQueue(void) in MessageQueue() function in ot::MessageQueue 744 Message *MessageQueue::GetHead(void) const in GetHead() 749 void MessageQueue::Enqueue(Message &aMessage, QueuePosition aPosition) in Enqueue() 780 void MessageQueue::Dequeue(Message &aMessage) in Dequeue() 804 void MessageQueue::DequeueAndFree(Message &aMessage) in DequeueAndFree() 810 void MessageQueue::DequeueAndFreeAll(void) in DequeueAndFreeAll() 820 void MessageQueue::GetInfo(uint16_t &aMessageCount, uint16_t &aBufferCount) const in GetInfo()
|
/openthread-2.7.6/src/core/coap/ |
D | coap_message.hpp | 986 class MessageQueue : public ot::MessageQueue class 993 MessageQueue(void) = default; 1001 Message *GetHead(void) const { return static_cast<Message *>(ot::MessageQueue::GetHead()); } in GetHead() 1018 …void Enqueue(Message &aMessage, QueuePosition aPosition) { ot::MessageQueue::Enqueue(aMessage, aPo… in Enqueue() 1026 void Dequeue(Message &aMessage) { ot::MessageQueue::Dequeue(aMessage); } in Dequeue() 1034 void DequeueAndFree(Message &aMessage) { ot::MessageQueue::DequeueAndFree(aMessage); } in DequeueAndFree()
|
D | coap.hpp | 327 const MessageQueue &GetResponses(void) const { return mQueue; } in GetResponses() 348 MessageQueue mQueue; 644 const MessageQueue &GetRequestMessages(void) const { return mPendingRequests; } in GetRequestMessages() 652 const MessageQueue &GetCachedResponses(void) const { return mResponsesQueue.GetResponses(); } in GetCachedResponses() 770 MessageQueue mPendingRequests;
|
D | coap_secure.hpp | 416 ot::MessageQueue mTransmitQueue;
|
/openthread-2.7.6/src/core/net/ |
D | ip6_mpl.hpp | 273 const MessageQueue &GetBufferedMessageSet(void) const { return mBufferedMessageSet; } in GetBufferedMessageSet() 321 MessageQueue mBufferedMessageSet;
|
D | ip6.hpp | 376 MessageQueue mReassemblyList;
|
D | sntp_client.hpp | 538 MessageQueue mPendingQueries;
|
D | dns_client.hpp | 683 typedef MessageQueue QueryList; // List of queries.
|
/openthread-2.7.6/src/core/meshcop/ |
D | joiner_router.hpp | 126 MessageQueue mDelayedJoinEnts;
|
/openthread-2.7.6/src/core/thread/ |
D | mesh_forwarder.hpp | 286 const MessageQueue &GetReassemblyQueue(void) const { return mReassemblyList; } in GetReassemblyQueue() 564 MessageQueue mReassemblyList;
|
D | mle.hpp | 657 const MessageQueue &GetMessageQueue(void) const { return mDelayedResponses; } in GetMessageQueue() 1841 MessageQueue mDelayedResponses;
|