Searched refs:messageCopy (Results 1 – 6 of 6) sorted by relevance
/openthread-latest/src/core/net/ |
D | sntp_client.cpp | 82 Message *messageCopy = nullptr; in Query() local 105 …VerifyOrExit((messageCopy = CopyAndEnqueueMessage(*message, queryMetadata)) != nullptr, error = kE… in Query() 117 if (messageCopy) in Query() 119 DequeueMessage(*messageCopy); in Query() 141 Message *messageCopy = nullptr; in CopyAndEnqueueMessage() local 144 VerifyOrExit((messageCopy = aMessage.Clone()) != nullptr, error = kErrorNoBufs); in CopyAndEnqueueMessage() 147 SuccessOrExit(error = aQueryMetadata.AppendTo(*messageCopy)); in CopyAndEnqueueMessage() 148 mPendingQueries.Enqueue(*messageCopy); in CopyAndEnqueueMessage() 153 FreeAndNullMessageOnError(messageCopy, error); in CopyAndEnqueueMessage() 154 return messageCopy; in CopyAndEnqueueMessage() [all …]
|
D | ip6_mpl.cpp | 333 Message *messageCopy = nullptr; in AddBufferedMessage() local 346 VerifyOrExit((messageCopy = aMessage.Clone()) != nullptr, error = kErrorNoBufs); in AddBufferedMessage() 352 messageCopy->Write(Header::kHopLimitFieldOffset, hopLimit); in AddBufferedMessage() 368 SuccessOrExit(error = metadata.AppendTo(*messageCopy)); in AddBufferedMessage() 369 mBufferedMessageSet.Enqueue(*messageCopy); in AddBufferedMessage() 374 FreeMessageOnError(messageCopy, error); in AddBufferedMessage() 384 Message *messageCopy; in HandleRetransmissionTimer() local 417 messageCopy = message.Clone(); in HandleRetransmissionTimer() 425 messageCopy = &message; in HandleRetransmissionTimer() 428 if (messageCopy != nullptr) in HandleRetransmissionTimer() [all …]
|
D | ip6.cpp | 198 Message *messageCopy = aMessage.Clone(); in PrepareMulticastToLargerThanRealmLocal() local 200 if (messageCopy != nullptr) in PrepareMulticastToLargerThanRealmLocal() 202 EnqueueDatagram(*messageCopy); in PrepareMulticastToLargerThanRealmLocal()
|
/openthread-latest/tests/unit/ |
D | test_message.cpp | 53 Message *messageCopy; in TestMessage() local 86 messageCopy = message->Clone(); in TestMessage() 87 VerifyOrQuit(messageCopy->GetOffset() == message->GetOffset()); in TestMessage() 88 SuccessOrQuit(messageCopy->Read(0, readBuffer, kMaxSize)); in TestMessage() 90 VerifyOrQuit(messageCopy->CompareBytes(0, readBuffer, kMaxSize)); in TestMessage() 91 VerifyOrQuit(messageCopy->Compare(0, readBuffer)); in TestMessage() 92 VerifyOrQuit(messageCopy->GetLength() == kMaxSize); in TestMessage() 93 VerifyOrQuit(messageCopy->GetType() == message->GetType()); in TestMessage() 94 VerifyOrQuit(messageCopy->GetSubType() == message->GetSubType()); in TestMessage() 95 VerifyOrQuit(messageCopy->IsLinkSecurityEnabled() == message->IsLinkSecurityEnabled()); in TestMessage() [all …]
|
/openthread-latest/src/core/common/ |
D | message.cpp | 767 Message *messageCopy; in Clone() local 772 messageCopy = GetMessagePool()->Allocate(GetType(), GetReserved(), settings); in Clone() 773 VerifyOrExit(messageCopy != nullptr, error = kErrorNoBufs); in Clone() 774 SuccessOrExit(error = messageCopy->AppendBytesFromMessage(*this, 0, aLength)); in Clone() 779 messageCopy->SetOffset(offset); in Clone() 781 messageCopy->SetSubType(GetSubType()); in Clone() 782 messageCopy->SetLoopbackToHostAllowed(IsLoopbackToHostAllowed()); in Clone() 783 messageCopy->SetOrigin(GetOrigin()); in Clone() 784 messageCopy->SetTimestamp(GetTimestamp()); in Clone() 785 messageCopy->SetMeshDest(GetMeshDest()); in Clone() [all …]
|
/openthread-latest/src/core/coap/ |
D | coap.cpp | 547 Message *messageCopy = nullptr; in CopyAndEnqueueMessage() local 549 VerifyOrExit((messageCopy = aMessage.Clone(aCopyLength)) != nullptr, error = kErrorNoBufs); in CopyAndEnqueueMessage() 551 SuccessOrExit(error = aMetadata.AppendTo(*messageCopy)); in CopyAndEnqueueMessage() 555 mPendingRequests.Enqueue(*messageCopy); in CopyAndEnqueueMessage() 558 FreeAndNullMessageOnError(messageCopy, error); in CopyAndEnqueueMessage() 559 return messageCopy; in CopyAndEnqueueMessage() 974 Message *messageCopy = nullptr; in SendCopy() local 977 messageCopy = aMessage.Clone(aMessage.GetLength() - sizeof(Metadata)); in SendCopy() 978 VerifyOrExit(messageCopy != nullptr, error = kErrorNoBufs); in SendCopy() 980 SuccessOrExit(error = Send(*messageCopy, aMessageInfo)); in SendCopy() [all …]
|