Lines Matching refs:aMessage
106 void MessagePool::Free(Message *aMessage) in Free() argument
108 OT_ASSERT(aMessage->Next() == nullptr && aMessage->Prev() == nullptr); in Free()
110 FreeBuffers(static_cast<Buffer *>(aMessage)); in Free()
415 Error Message::AppendBytesFromMessage(const Message &aMessage, const OffsetRange &aOffsetRange) in AppendBytesFromMessage() argument
417 return AppendBytesFromMessage(aMessage, aOffsetRange.GetOffset(), aOffsetRange.GetLength()); in AppendBytesFromMessage()
420 Error Message::AppendBytesFromMessage(const Message &aMessage, uint16_t aOffset, uint16_t aLength) in AppendBytesFromMessage() argument
426 VerifyOrExit(aMessage.GetLength() >= aOffset + aLength, error = kErrorParse); in AppendBytesFromMessage()
429 aMessage.GetFirstChunk(aOffset, aLength, chunk); in AppendBytesFromMessage()
435 aMessage.GetNextChunk(aLength, chunk); in AppendBytesFromMessage()
739 const Message &aMessage, in WriteBytesFromMessage() argument
743 if ((&aMessage != this) || (aReadOffset >= aWriteOffset)) in WriteBytesFromMessage()
747 aMessage.GetFirstChunk(aReadOffset, aLength, chunk); in WriteBytesFromMessage()
753 aMessage.GetNextChunk(aLength, chunk); in WriteBytesFromMessage()
899 void MessageQueue::Enqueue(Message &aMessage, QueuePosition aPosition) in Enqueue() argument
901 OT_ASSERT(!aMessage.IsInAQueue()); in Enqueue()
902 OT_ASSERT((aMessage.Next() == nullptr) && (aMessage.Prev() == nullptr)); in Enqueue()
904 aMessage.SetMessageQueue(this); in Enqueue()
908 aMessage.Next() = &aMessage; in Enqueue()
909 aMessage.Prev() = &aMessage; in Enqueue()
911 SetTail(&aMessage); in Enqueue()
917 aMessage.Next() = head; in Enqueue()
918 aMessage.Prev() = GetTail(); in Enqueue()
920 head->Prev() = &aMessage; in Enqueue()
921 GetTail()->Next() = &aMessage; in Enqueue()
925 SetTail(&aMessage); in Enqueue()
930 void MessageQueue::Dequeue(Message &aMessage) in Dequeue() argument
932 OT_ASSERT(aMessage.GetMessageQueue() == this); in Dequeue()
933 OT_ASSERT((aMessage.Next() != nullptr) && (aMessage.Prev() != nullptr)); in Dequeue()
935 if (&aMessage == GetTail()) in Dequeue()
939 if (&aMessage == GetTail()) in Dequeue()
945 aMessage.Prev()->Next() = aMessage.Next(); in Dequeue()
946 aMessage.Next()->Prev() = aMessage.Prev(); in Dequeue()
948 aMessage.Prev() = nullptr; in Dequeue()
949 aMessage.Next() = nullptr; in Dequeue()
951 aMessage.SetMessageQueue(nullptr); in Dequeue()
954 void MessageQueue::DequeueAndFree(Message &aMessage) in DequeueAndFree() argument
956 Dequeue(aMessage); in DequeueAndFree()
957 aMessage.Free(); in DequeueAndFree()
1040 void PriorityQueue::Enqueue(Message &aMessage) in Enqueue() argument
1046 OT_ASSERT(!aMessage.IsInAQueue()); in Enqueue()
1048 aMessage.SetPriorityQueue(this); in Enqueue()
1050 priority = aMessage.GetPriority(); in Enqueue()
1058 aMessage.Next() = next; in Enqueue()
1059 aMessage.Prev() = tail; in Enqueue()
1060 next->Prev() = &aMessage; in Enqueue()
1061 tail->Next() = &aMessage; in Enqueue()
1065 aMessage.Next() = &aMessage; in Enqueue()
1066 aMessage.Prev() = &aMessage; in Enqueue()
1069 mTails[priority] = &aMessage; in Enqueue()
1072 void PriorityQueue::Dequeue(Message &aMessage) in Dequeue() argument
1077 OT_ASSERT(aMessage.GetPriorityQueue() == this); in Dequeue()
1079 priority = aMessage.GetPriority(); in Dequeue()
1083 if (&aMessage == tail) in Dequeue()
1087 if ((&aMessage == tail) || (tail->GetPriority() != priority)) in Dequeue()
1095 aMessage.Next()->Prev() = aMessage.Prev(); in Dequeue()
1096 aMessage.Prev()->Next() = aMessage.Next(); in Dequeue()
1097 aMessage.Next() = nullptr; in Dequeue()
1098 aMessage.Prev() = nullptr; in Dequeue()
1100 aMessage.SetPriorityQueue(nullptr); in Dequeue()
1103 void PriorityQueue::DequeueAndFree(Message &aMessage) in DequeueAndFree() argument
1105 Dequeue(aMessage); in DequeueAndFree()
1106 aMessage.Free(); in DequeueAndFree()