Home
last modified time | relevance | path

Searched refs:messageCopy (Results 1 – 6 of 6) sorted by relevance

/openthread-latest/src/core/net/
Dsntp_client.cpp82 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 …]
Dip6_mpl.cpp333 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 …]
Dip6.cpp198 Message *messageCopy = aMessage.Clone(); in PrepareMulticastToLargerThanRealmLocal() local
200 if (messageCopy != nullptr) in PrepareMulticastToLargerThanRealmLocal()
202 EnqueueDatagram(*messageCopy); in PrepareMulticastToLargerThanRealmLocal()
/openthread-latest/tests/unit/
Dtest_message.cpp53 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/
Dmessage.cpp767 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/
Dcoap.cpp547 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 …]