Home
last modified time | relevance | path

Searched refs:messageInfo (Results 1 – 25 of 35) sorted by relevance

12

/openthread-latest/src/core/net/
Dsntp_client.cpp84 const Ip6::MessageInfo *messageInfo; in Query() local
95 messageInfo = AsCoreTypePtr(aQuery->mMessageInfo); in Query()
100 queryMetadata.mSourceAddress = messageInfo->GetSockAddr(); in Query()
101 queryMetadata.mDestinationPort = messageInfo->GetPeerPort(); in Query()
102 queryMetadata.mDestinationAddress = messageInfo->GetPeerAddr(); in Query()
106 SuccessOrExit(error = SendMessage(*message, *messageInfo)); in Query()
225 Ip6::MessageInfo messageInfo; in HandleRetransmissionTimer() local
246 messageInfo.SetPeerAddr(queryMetadata.mDestinationAddress); in HandleRetransmissionTimer()
247 messageInfo.SetPeerPort(queryMetadata.mDestinationPort); in HandleRetransmissionTimer()
248 messageInfo.SetSockAddr(queryMetadata.mSourceAddress); in HandleRetransmissionTimer()
[all …]
Ddhcp6_client.cpp256 Ip6::MessageInfo messageInfo; in Solicit() local
269 messageInfo.GetPeerAddr().SetToRealmLocalAllRoutersMulticast(); in Solicit()
271 …messageInfo.GetPeerAddr().SetToRoutingLocator(Get<Mle::MleRouter>().GetMeshLocalPrefix(), aRloc16); in Solicit()
273 messageInfo.SetSockAddr(Get<Mle::MleRouter>().GetMeshLocalRloc()); in Solicit()
274 messageInfo.mPeerPort = kDhcpServerPort; in Solicit()
276 SuccessOrExit(error = mSocket.SendTo(*message, messageInfo)); in Solicit()
Dip6.cpp765 MessageInfo messageInfo; in SendIcmpError() local
769 messageInfo.SetPeerAddr(header.GetSource()); in SendIcmpError()
770 messageInfo.SetSockAddr(header.GetDestination()); in SendIcmpError()
771 messageInfo.SetHopLimit(header.GetHopLimit()); in SendIcmpError()
773 error = mIcmp.SendError(aIcmpType, aIcmpCode, messageInfo, aMessage); in SendIcmpError()
873 MessageInfo messageInfo; in Receive() local
875 messageInfo.Clear(); in Receive()
876 messageInfo.SetPeerAddr(aIp6Header.GetSource()); in Receive()
877 messageInfo.SetSockAddr(aIp6Header.GetDestination()); in Receive()
878 messageInfo.SetHopLimit(aIp6Header.GetHopLimit()); in Receive()
[all …]
Ddhcp6_server.cpp323 Ip6::MessageInfo messageInfo; in SendReply() local
335 messageInfo.SetPeerAddr(aDst); in SendReply()
336 messageInfo.SetPeerPort(kDhcpClientPort); in SendReply()
337 SuccessOrExit(error = mSocket.SendTo(*message, messageInfo)); in SendReply()
/openthread-latest/tests/unit/
Dtest_checksum.cpp189 Ip6::MessageInfo messageInfo; in TestUdpMessageChecksum() local
209 SuccessOrQuit(messageInfo.GetSockAddr().FromString(kSourceAddress)); in TestUdpMessageChecksum()
210 SuccessOrQuit(messageInfo.GetPeerAddr().FromString(kDestAddress)); in TestUdpMessageChecksum()
215 …Checksum::UpdateMessageChecksum(*message, messageInfo.GetSockAddr(), messageInfo.GetPeerAddr(), Ip… in TestUdpMessageChecksum()
222 …VerifyOrQuit(CalculateChecksum(messageInfo.GetSockAddr(), messageInfo.GetPeerAddr(), Ip6::kProtoUd… in TestUdpMessageChecksum()
228 SuccessOrQuit(Checksum::VerifyMessageChecksum(*message, messageInfo, Ip6::kProtoUdp)); in TestUdpMessageChecksum()
234 … VerifyOrQuit(Checksum::VerifyMessageChecksum(*message, messageInfo, Ip6::kProtoUdp) != kErrorNone, in TestUdpMessageChecksum()
257 Ip6::MessageInfo messageInfo; in TestIcmp6MessageChecksum() local
277 SuccessOrQuit(messageInfo.GetSockAddr().FromString(kSourceAddress)); in TestIcmp6MessageChecksum()
278 SuccessOrQuit(messageInfo.GetPeerAddr().FromString(kDestAddress)); in TestIcmp6MessageChecksum()
[all …]
/openthread-latest/src/core/api/
Dudp_api.cpp98 Ip6::MessageInfo messageInfo; in otUdpForwardReceive() local
100 messageInfo.SetSockAddr(AsCoreType(aInstance).Get<Mle::MleRouter>().GetMeshLocalRloc()); in otUdpForwardReceive()
101 messageInfo.SetSockPort(aSockPort); in otUdpForwardReceive()
102 messageInfo.SetPeerAddr(AsCoreType(aPeerAddr)); in otUdpForwardReceive()
103 messageInfo.SetPeerPort(aPeerPort); in otUdpForwardReceive()
104 messageInfo.SetIsHostInterface(true); in otUdpForwardReceive()
106 AsCoreType(aInstance).Get<Ip6::Udp>().HandlePayload(AsCoreType(aMessage), messageInfo); in otUdpForwardReceive()
/openthread-latest/src/core/utils/
Dping_sender.cpp125 Ip6::MessageInfo messageInfo; in SendPing() local
127 messageInfo.SetSockAddr(mConfig.GetSource()); in SendPing()
128 messageInfo.SetPeerAddr(mConfig.GetDestination()); in SendPing()
129 messageInfo.mHopLimit = mConfig.mHopLimit; in SendPing()
130 messageInfo.mAllowZeroHopLimit = mConfig.mAllowZeroHopLimit; in SendPing()
131 messageInfo.mMulticastLoop = mConfig.mMulticastLoop; in SendPing()
144 SuccessOrExit(Get<Ip6::Icmp>().SendEchoRequest(*message, messageInfo, mIdentifier)); in SendPing()
/openthread-latest/src/cli/
Dcli_coap.cpp79 otMessageInfo messageInfo; in CancelResourceSubscription() local
81 ClearAllBytes(messageInfo); in CancelResourceSubscription()
82 messageInfo.mPeerAddr = mRequestAddr; in CancelResourceSubscription()
83 messageInfo.mPeerPort = OT_DEFAULT_COAP_PORT; in CancelResourceSubscription()
95 …SuccessOrExit(error = otCoapSendRequest(GetInstancePtr(), message, &messageInfo, &Coap::HandleResp… in CancelResourceSubscription()
238 otMessageInfo messageInfo; in Process() local
252 ClearAllBytes(messageInfo); in Process()
253 messageInfo.mPeerAddr = mSubscriberSock.mAddress; in Process()
254 messageInfo.mPeerPort = mSubscriberSock.mPort; in Process()
273 … SuccessOrExit(error = otCoapSendRequest(GetInstancePtr(), notificationMessage, &messageInfo, in Process()
[all …]
Dcli_udp.cpp256 otMessageInfo messageInfo; in Process() local
261 ClearAllBytes(messageInfo); in Process()
274 …SuccessOrExit(error = ParseToIp6Address(GetInstancePtr(), aArgs[0], messageInfo.mPeerAddr, nat64Sy… in Process()
279 OutputIp6AddressLine(messageInfo.mPeerAddr); in Process()
282 SuccessOrExit(error = aArgs[1].ParseAsUint16(messageInfo.mPeerPort)); in Process()
318 SuccessOrExit(error = otUdpSend(GetInstancePtr(), &mSocket, message, &messageInfo)); in Process()
/openthread-latest/src/core/backbone_router/
Dbbr_manager.cpp314 Ip6::MessageInfo messageInfo; in SendBackboneMulticastListenerRegistration() local
330 messageInfo.SetPeerAddr(Get<Local>().GetAllNetworkBackboneRoutersAddress()); in SendBackboneMulticastListenerRegistration()
331 …messageInfo.SetPeerPort(BackboneRouter::kBackboneUdpPort); // TODO: Provide API for configuring Ba… in SendBackboneMulticastListenerRegistration()
333 messageInfo.SetHopLimit(kDefaultHoplimit); in SendBackboneMulticastListenerRegistration()
334 messageInfo.SetIsHostInterface(true); in SendBackboneMulticastListenerRegistration()
336 SuccessOrExit(error = backboneTmf.SendMessage(*message, messageInfo)); in SendBackboneMulticastListenerRegistration()
510 Ip6::MessageInfo messageInfo; in SendBackboneQuery() local
524 messageInfo.SetPeerAddr(Get<Local>().GetAllDomainBackboneRoutersAddress()); in SendBackboneQuery()
525 messageInfo.SetPeerPort(BackboneRouter::kBackboneUdpPort); in SendBackboneQuery()
527 messageInfo.SetHopLimit(kDefaultHoplimit); in SendBackboneQuery()
[all …]
/openthread-latest/src/core/meshcop/
Djoiner_router.cpp121 Tmf::MessageInfo messageInfo(GetInstance()); in HandleUdpReceive() local
144 messageInfo.SetSockAddrToRlocPeerAddrTo(borderAgentRloc); in HandleUdpReceive()
146 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in HandleUdpReceive()
165 Ip6::MessageInfo messageInfo; in HandleTmf() local
180 messageInfo.GetPeerAddr().SetToLinkLocalAddress(joinerIid); in HandleTmf()
181 messageInfo.SetPeerPort(joinerPort); in HandleTmf()
183 SuccessOrExit(error = mSocket.SendTo(*message, messageInfo)); in HandleTmf()
189 DelaySendingJoinerEntrust(messageInfo, kek); in HandleTmf()
Dannounce_begin_client.cpp55 Tmf::MessageInfo messageInfo(GetInstance()); in SendRequest() local
72 messageInfo.SetSockAddrToRlocPeerAddrTo(aAddress); in SendRequest()
74 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in SendRequest()
Dborder_agent.cpp350 Tmf::MessageInfo messageInfo(GetInstance()); in ForwardToLeader() local
386 messageInfo.SetSockAddrToRlocPeerAddrToLeaderAloc(); in ForwardToLeader()
387 messageInfo.SetSockPortToTmf(); in ForwardToLeader()
390 … Get<Tmf::Agent>().SendMessage(*message, messageInfo, HandleCoapResponse, forwardContext.Get())); in ForwardToLeader()
662 Ip6::MessageInfo messageInfo; in HandleTmfProxyTx() local
678 messageInfo.SetSockPort(udpEncapHeader.GetSourcePort()); in HandleTmfProxyTx()
679 messageInfo.SetSockAddr(mCommissionerAloc.GetAddress()); in HandleTmfProxyTx()
680 messageInfo.SetPeerPort(udpEncapHeader.GetDestinationPort()); in HandleTmfProxyTx()
682 SuccessOrExit(error = Tlv::Find<Ip6AddressTlv>(aMessage, messageInfo.GetPeerAddr())); in HandleTmfProxyTx()
684 SuccessOrExit(error = Get<Ip6::Udp>().SendDatagram(*message, messageInfo)); in HandleTmfProxyTx()
[all …]
Dpanid_query_client.cpp56 Tmf::MessageInfo messageInfo(GetInstance()); in SendQuery() local
72 messageInfo.SetSockAddrToRlocPeerAddrTo(aAddress); in SendQuery()
73 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in SendQuery()
Denergy_scan_client.cpp58 Tmf::MessageInfo messageInfo(GetInstance()); in SendQuery() local
76 messageInfo.SetSockAddrToRlocPeerAddrTo(aAddress); in SendQuery()
77 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in SendQuery()
Dcommissioner.cpp608 Tmf::MessageInfo messageInfo(GetInstance()); in SendMgmtCommissionerGetRequest() local
622 messageInfo.SetSockAddrToRlocPeerAddrToLeaderAloc(); in SendMgmtCommissionerGetRequest()
623 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo, in SendMgmtCommissionerGetRequest()
661 Tmf::MessageInfo messageInfo(GetInstance()); in SendMgmtCommissionerSetRequest() local
693 messageInfo.SetSockAddrToRlocPeerAddrToLeaderAloc(); in SendMgmtCommissionerSetRequest()
694 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo, in SendMgmtCommissionerSetRequest()
737 Tmf::MessageInfo messageInfo(GetInstance()); in SendPetition() local
746 messageInfo.SetSockAddrToRlocPeerAddrToLeaderAloc(); in SendPetition()
748 …error = Get<Tmf::Agent>().SendMessage(*message, messageInfo, Commissioner::HandleLeaderPetitionRes… in SendPetition()
823 Tmf::MessageInfo messageInfo(GetInstance()); in SendKeepAlive() local
[all …]
Dmeshcop_leader.cpp188 Tmf::MessageInfo messageInfo(GetInstance()); in SendDatasetChanged() local
194 messageInfo.SetSockAddrToRlocPeerAddrTo(aAddress); in SendDatasetChanged()
195 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in SendDatasetChanged()
Ddataset_manager.cpp478 Tmf::MessageInfo messageInfo(GetInstance()); in SendSetRequest() local
486 messageInfo.SetSockAddrToRlocPeerAddrToLeaderAloc(); in SendSetRequest()
488 …SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo, HandleMgmtSetResponse, … in SendSetRequest()
647 Tmf::MessageInfo messageInfo(GetInstance()); in SendGetRequest() local
728 messageInfo.SetSockAddrToRlocPeerAddrToLeaderAloc(); in SendGetRequest()
733 messageInfo.SetPeerAddr(AsCoreType(aAddress)); in SendGetRequest()
736 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in SendGetRequest()
/openthread-latest/src/core/thread/
Dpanid_query_server.cpp99 Tmf::MessageInfo messageInfo(GetInstance()); in SendConflict() local
109 messageInfo.SetSockAddrToRlocPeerAddrTo(mCommissioner); in SendConflict()
111 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in SendConflict()
Danycast_locator.cpp52 Tmf::MessageInfo messageInfo(GetInstance()); in Locate() local
65 messageInfo.SetSockAddrToRlocPeerAddrTo(aAnycastAddress); in Locate()
67 … SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo, HandleResponse, this)); in Locate()
Denergy_scan_server.cpp177 Tmf::MessageInfo messageInfo(GetInstance()); in SendReport() local
184 messageInfo.SetSockAddrToRlocPeerAddrTo(mCommissioner); in SendReport()
186 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*mReportMessage, messageInfo)); in SendReport()
Ddua_manager.cpp425 Tmf::MessageInfo messageInfo(GetInstance()); in PerformNextRegistration() local
508 mle.GetServiceAloc(pbbrServiceId, messageInfo.GetPeerAddr()); in PerformNextRegistration()
512 messageInfo.GetPeerAddr().SetToRoutingLocator(mle.GetMeshLocalPrefix(), in PerformNextRegistration()
516 messageInfo.SetSockAddrToRloc(); in PerformNextRegistration()
518 …SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo, &DuaManager::HandleDuaR… in PerformNextRegistration()
721 Tmf::MessageInfo messageInfo(GetInstance()); in SendAddressNotification() local
730 messageInfo.SetSockAddrToRlocPeerAddrTo(aChild.GetRloc16()); in SendAddressNotification()
732 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in SendAddressNotification()
Daddress_resolver.cpp616 Tmf::MessageInfo messageInfo(GetInstance()); in SendAddressQuery() local
623 messageInfo.SetSockAddrToRlocPeerAddrToRealmLocalAllRoutersMulticast(); in SendAddressQuery()
625 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in SendAddressQuery()
725 Tmf::MessageInfo messageInfo(GetInstance()); in SendAddressError() local
738 messageInfo.SetSockAddrToRlocPeerAddrToRealmLocalAllRoutersMulticast(); in SendAddressError()
742 messageInfo.SetSockAddrToRlocPeerAddrTo(*aDestination); in SendAddressError()
745 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in SendAddressError()
899 Tmf::MessageInfo messageInfo(GetInstance()); in SendAddressQueryResponse() local
913 messageInfo.SetSockAddrToRlocPeerAddrTo(aDestination); in SendAddressQueryResponse()
915 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in SendAddressQueryResponse()
Dnetwork_data_notifier.cpp188 Tmf::MessageInfo messageInfo(GetInstance()); in SendServerDataNotification() local
212 messageInfo.SetSockAddrToRlocPeerAddrToLeaderAloc(); in SendServerDataNotification()
213 …SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo, HandleCoapResponse, thi… in SendServerDataNotification()
/openthread-latest/src/posix/platform/
Dudp.cpp623 otMessageInfo messageInfo; in Process() local
628 memset(&messageInfo, 0, sizeof(messageInfo)); in Process()
629 messageInfo.mSockPort = socket->mSockName.mPort; in Process()
631 if (OT_ERROR_NONE != receivePacket(fd, payload, length, messageInfo)) in Process()
649 socket->mHandler(socket->mContext, message, &messageInfo); in Process()

12