Home
last modified time | relevance | path

Searched refs:mMessage (Results 1 – 21 of 21) sorted by relevance

/openthread-latest/src/core/common/
Dappender.cpp41 mShared.mMessage.mMessage = &aMessage; in Appender()
42 mShared.mMessage.mStartOffset = aMessage.GetLength(); in Appender()
58 error = mShared.mMessage.mMessage->AppendBytes(aBuffer, aLength); in AppendBytes()
76 length = mShared.mMessage.mMessage->GetLength() - mShared.mMessage.mStartOffset; in GetAppendedLength()
Dappender.hpp136 Message &GetMessage(void) const { return *mShared.mMessage.mMessage; } in GetMessage()
162 Message *mMessage; member
164 } mMessage; member
/openthread-latest/src/core/net/
Dsrp_client.cpp996 info.mMessage.Reset(mSocket.NewMessage()); in SendUpdate()
997 VerifyOrExit(info.mMessage != nullptr, error = kErrorNoBufs); in SendUpdate()
1001 length = info.mMessage->GetLength() + sizeof(Ip6::Udp::Header) + sizeof(Ip6::Header); in SendUpdate()
1007 IgnoreError(info.mMessage->SetLength(0)); in SendUpdate()
1011 SuccessOrExit(error = mSocket.SendTo(*info.mMessage, Ip6::MessageInfo())); in SendUpdate()
1016 info.mMessage.Release(); in SendUpdate()
1132 SuccessOrExit(error = aInfo.mMessage->Append(header)); in PrepareUpdateMessage()
1136 aInfo.mDomainNameOffset = aInfo.mMessage->GetLength(); in PrepareUpdateMessage()
1137 SuccessOrExit(error = Dns::Name::AppendName(mDomainName, *aInfo.mMessage)); in PrepareUpdateMessage()
1138 SuccessOrExit(error = aInfo.mMessage->Append(Dns::Zone())); in PrepareUpdateMessage()
[all …]
Ddnssd_server.cpp139 request.mMessage = &aMessage; in HandleUdpReceive()
236 mMessage.Reset(Get<Server>().mSocket.NewMessage()); in AllocateAndInitFrom()
237 VerifyOrExit(!mMessage.IsNull(), error = kErrorNoBufs); in AllocateAndInitFrom()
250 error = mMessage->Append(mHeader); in AllocateAndInitFrom()
255 mMessage.Free(); in AllocateAndInitFrom()
265 VerifyOrExit(!mMessage.IsNull()); in Send()
272 IgnoreError(mMessage->SetLength(sizeof(Header))); in Send()
275 mMessage->Write(0, mHeader); in Send()
277 SuccessOrExit(Get<Server>().mSocket.SendTo(*mMessage, aMessageInfo)); in Send()
282 mMessage.Release(); in Send()
[all …]
Ddns_client.cpp168 VerifyOrExit(mMessage != nullptr, error = kErrorNotFound); in CheckForHostNameAlias()
173 …error = ResourceRecord::FindRecord(*mMessage, offset, numRecords, /* aIndex */ 0, aHostName, cname… in CheckForHostNameAlias()
187 aHostName.SetFromMessage(*mMessage, offset); in CheckForHostNameAlias()
188 SuccessOrExit(error = Name::ParseName(*mMessage, offset)); in CheckForHostNameAlias()
215 …SuccessOrExit(error = ResourceRecord::FindRecord(*mMessage, offset, numRecords, aIndex, name, aaaa… in FindHostAddress()
235 error = ResourceRecord::FindRecord(*mMessage, offset, numRecords, aIndex, name, aARecord); in FindARecord()
282 VerifyOrExit(mMessage != nullptr, error = kErrorNotFound); in ReadServiceInfo()
286 …SuccessOrExit(error = ResourceRecord::FindRecord(*mMessage, offset, numRecords, /* aIndex */ 0, aN… in ReadServiceInfo()
293 hostName.SetFromMessage(*mMessage, offset); in ReadServiceInfo()
297 …SuccessOrExit(error = srvRecord.ReadTargetHostName(*mMessage, offset, aServiceInfo.mHostNameBuffer, in ReadServiceInfo()
[all …]
Ddns_types.cpp125 SuccessOrExit(CompareLabel(*mMessage, offset, aFirstLabel)); in Matches()
128 SuccessOrExit(CompareMultipleLabels(*mMessage, offset, aLabels)); in Matches()
129 SuccessOrExit(CompareName(*mMessage, offset, aDomain)); in Matches()
178 LabelIterator iterator(*mMessage, mOffset); in AppendTo()
554 … : (aName.IsFromMessage() ? CompareName(aMessage, aOffset, *aName.mMessage, aName.mOffset) in CompareName()
567 SuccessOrExit(error = mMessage.Read(mNextLabelOffset, labelLength)); in GetNextLabel()
599 SuccessOrExit(error = mMessage.Read(mNextLabelOffset, pointerValue)); in GetNextLabel()
608 …nextLabelOffset = mMessage.GetOffset() + (BigEndian::HostSwap16(pointerValue) & kPointerLabelOffse… in GetNextLabel()
631 SuccessOrExit(error = mMessage.Read(mLabelStartOffset, aLabelBuffer, mLabelLength)); in ReadLabel()
662 matches = mMessage.CompareBytes(mLabelStartOffset, aName, mLabelLength, CaseInsensitiveMatch); in CompareLabel()
[all …]
Ddns_types.hpp524 bool IsEmpty(void) const { return (mString == nullptr) && (mMessage == nullptr); } in IsEmpty()
538 bool IsFromMessage(void) const { return mMessage != nullptr; } in IsFromMessage()
559 mMessage = nullptr; in Set()
572 mMessage = &aMessage; in SetFromMessage()
597 return *mMessage; in GetAsMessage()
1059 : mMessage(aMessage) in LabelIterator()
1075 const Message &mMessage; // Message to read labels from. member
1085 , mMessage(aMessage) in Name()
1094 …const Message *mMessage; // Message containing the encoded name, or `nullptr` if `Name` is not fro… member in ot::Dns::Name
Ddnssd_server.hpp357 const Message *mMessage; member
441 OwnedPtr<Message> mMessage; member in ot::Dns::ServiceDiscovery::Server::Response
Ddns_client.hpp311 const Message *mMessage; // The response message. member in ot::Dns::Client::Response
Dsrp_client.hpp994 OwnedPtr<Message> mMessage; member
/openthread-latest/src/core/thread/
Ddiscover_scanner.cpp316 …SuccessOrExit(error = Tlv::FindTlvValueOffsetRange(aRxInfo.mMessage, Tlv::kDiscovery, offsetRange)… in HandleDiscoveryResponse()
320 result.mPanId = aRxInfo.mMessage.GetPanId(); in HandleDiscoveryResponse()
321 result.mChannel = aRxInfo.mMessage.GetChannel(); in HandleDiscoveryResponse()
322 result.mRssi = aRxInfo.mMessage.GetAverageRss(); in HandleDiscoveryResponse()
323 result.mLqi = aRxInfo.mMessage.GetAverageLqi(); in HandleDiscoveryResponse()
329 SuccessOrExit(error = tlvInfo.ParseFrom(aRxInfo.mMessage, offsetRange)); in HandleDiscoveryResponse()
339 SuccessOrExit(error = aRxInfo.mMessage.Read(offsetRange, discoveryResponse)); in HandleDiscoveryResponse()
346 …SuccessOrExit(error = Tlv::Read<MeshCoP::ExtendedPanIdTlv>(aRxInfo.mMessage, offsetRange.GetOffset… in HandleDiscoveryResponse()
351 …SuccessOrExit(error = Tlv::Read<MeshCoP::NetworkNameTlv>(aRxInfo.mMessage, offsetRange.GetOffset(), in HandleDiscoveryResponse()
363 aRxInfo.mMessage.ReadBytes(valueOffsetRange, steeringData.GetData()); in HandleDiscoveryResponse()
[all …]
Dmle_router.cpp699 SuccessOrExit(error = aRxInfo.mMessage.ReadChallengeTlv(info.mRxChallenge)); in HandleLinkRequest()
701 SuccessOrExit(error = aRxInfo.mMessage.ReadVersionTlv(version)); in HandleLinkRequest()
703 switch (aRxInfo.mMessage.ReadLeaderDataTlv(leaderData)) in HandleLinkRequest()
716 info.mLinkMargin = Get<Mac::Mac>().ComputeLinkMargin(aRxInfo.mMessage.GetAverageRss()); in HandleLinkRequest()
718 switch (Tlv::Find<SourceAddressTlv>(aRxInfo.mMessage, sourceAddress)) in HandleLinkRequest()
751 switch (aRxInfo.mMessage.ReadTlvRequestTlv(info.mRequestedTlvList)) in HandleLinkRequest()
763 …neighbor->SetTimeSyncEnabled(Tlv::Find<TimeRequestTlv>(aRxInfo.mMessage, nullptr, 0) == kErrorNone… in HandleLinkRequest()
904 SuccessOrExit(error = Tlv::Find<SourceAddressTlv>(aRxInfo.mMessage, sourceAddress)); in HandleLinkAcceptVariant()
914 SuccessOrExit(error = aRxInfo.mMessage.ReadResponseTlv(response)); in HandleLinkAcceptVariant()
941 SuccessOrExit(error = aRxInfo.mMessage.ReadVersionTlv(version)); in HandleLinkAcceptVariant()
[all …]
Dmle.cpp1100 aNeighbor.GetLinkInfo().AddRss(aRxInfo.mMessage.GetAverageRss()); in InitNeighbor()
2739 SuccessOrExit(error = Tlv::Find<SourceAddressTlv>(aRxInfo.mMessage, sourceAddress)); in HandleAdvertisement()
2743 SuccessOrExit(error = aRxInfo.mMessage.ReadLeaderDataTlv(leaderData)); in HandleAdvertisement()
2806 …if (Tlv::FindTlvValueOffsetRange(aRxInfo.mMessage, Tlv::kLinkMetricsReport, offsetRange) == kError… in HandleDataResponse()
2808 Get<LinkMetrics::Initiator>().HandleReport(aRxInfo.mMessage, offsetRange, in HandleDataResponse()
2850 SuccessOrExit(error = aRxInfo.mMessage.ReadLeaderDataTlv(leaderData)); in HandleLeaderData()
2870 switch (Tlv::Find<ActiveTimestampTlv>(aRxInfo.mMessage, activeTimestamp)) in HandleLeaderData()
2885 VerifyOrExit(aRxInfo.mMessage.ContainsTlv(Tlv::kActiveDataset), dataRequest = true); in HandleLeaderData()
2898 switch (Tlv::Find<PendingTimestampTlv>(aRxInfo.mMessage, pendingTimestamp)) in HandleLeaderData()
2909 VerifyOrExit(aRxInfo.mMessage.ContainsTlv(Tlv::kPendingDataset), dataRequest = true); in HandleLeaderData()
[all …]
Dmle.hpp1081 : mMessage(static_cast<RxMessage &>(aMessage)) in RxInfo()
1092 RxMessage &mMessage; // The MLE message. member
/openthread-latest/src/core/meshcop/
Dmeshcop_tlvs.cpp147 entriesData.mMessage = &aMessage; in FindIn()
178 if (mMessage != nullptr) in Parse()
184 mMessage->ReadBytes(mOffsetRange.GetOffset(), &readEntry, kEntryHeaderSize); in Parse()
203 if (mMessage != nullptr) in Parse()
205 IgnoreError(mMessage->Read(mOffsetRange, readEntry)); in Parse()
Dmeshcop_tlvs.hpp691 const Message *mMessage; member
/openthread-latest/src/core/utils/
Dmesh_diag.cpp404 ip6AddrIterator.mMessage = &aMessage; in ProcessChildrenIp6AddrsAnswer()
527 mMessage = &aMessage; in InitFrom()
537 VerifyOrExit(mMessage != nullptr, error = kErrorNotFound); in GetNextAddress()
539 VerifyOrExit(mMessage->Read(mOffsetRange, aAddress) == kErrorNone, error = kErrorNotFound); in GetNextAddress()
555 mMessage = &aMessage; in InitFrom()
567 VerifyOrExit(mMessage != nullptr, error = kErrorNotFound); in GetNextChildInfo()
569 VerifyOrExit(mMessage->Read(mOffsetRange, entry) == kErrorNone, error = kErrorNotFound); in GetNextChildInfo()
576 aChildInfo.mIsThisDevice = mMessage->Get<Mle::Mle>().HasRloc16(aChildInfo.mRloc16); in GetNextChildInfo()
577 …aChildInfo.mIsBorderRouter = mMessage->Get<NetworkData::Leader>().ContainsBorderRouterWithRloc(aCh… in GetNextChildInfo()
Dmesh_diag.hpp104 const Message *mMessage; member in ot::Utils::MeshDiag::Ip6AddrIterator
147 const Message *mMessage; member in ot::Utils::MeshDiag::ChildIterator
/openthread-latest/include/openthread/
Dcoap.h163 const otMessage *mMessage; ///< CoAP message member
/openthread-latest/src/core/coap/
Dcoap_message.hpp1089 const Message &GetMessage(void) const { return *static_cast<const Message *>(mMessage); } in GetMessage()
Dcoap_message.cpp511 mMessage = &aMessage; in Init()