Home
last modified time | relevance | path

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

/openthread-2.7.6/src/core/api/
Dmessage_api.cpp126 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/
Dtest_message_queue.cpp47 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()
Dtest_priority_queue.cpp112 void VerifyMsgQueueContent(ot::MessageQueue &aMessageQueue, int aExpectedLength, ...) in VerifyMsgQueueContent()
148 ot::MessageQueue messageQueue; in TestPriorityQueue()
/openthread-2.7.6/src/core/common/
Dmessage.hpp142 class MessageQueue;
157MessageQueue * 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;
Dmessage.cpp254 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/
Dcoap_message.hpp986 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()
Dcoap.hpp327 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;
Dcoap_secure.hpp416 ot::MessageQueue mTransmitQueue;
/openthread-2.7.6/src/core/net/
Dip6_mpl.hpp273 const MessageQueue &GetBufferedMessageSet(void) const { return mBufferedMessageSet; } in GetBufferedMessageSet()
321 MessageQueue mBufferedMessageSet;
Dip6.hpp376 MessageQueue mReassemblyList;
Dsntp_client.hpp538 MessageQueue mPendingQueries;
Ddns_client.hpp683 typedef MessageQueue QueryList; // List of queries.
/openthread-2.7.6/src/core/meshcop/
Djoiner_router.hpp126 MessageQueue mDelayedJoinEnts;
/openthread-2.7.6/src/core/thread/
Dmesh_forwarder.hpp286 const MessageQueue &GetReassemblyQueue(void) const { return mReassemblyList; } in GetReassemblyQueue()
564 MessageQueue mReassemblyList;
Dmle.hpp657 const MessageQueue &GetMessageQueue(void) const { return mDelayedResponses; } in GetMessageQueue()
1841 MessageQueue mDelayedResponses;