/openthread-latest/src/core/thread/ |
D | neighbor.cpp | 63 bool Neighbor::AddressMatcher::Matches(const Neighbor &aNeighbor) const in Matches() 67 VerifyOrExit(aNeighbor.MatchesFilter(mStateFilter)); in Matches() 71 VerifyOrExit(mShortAddress == aNeighbor.GetRloc16()); in Matches() 76 VerifyOrExit(*mExtAddress == aNeighbor.GetExtAddress()); in Matches() 85 void Neighbor::Info::SetFrom(const Neighbor &aNeighbor) in SetFrom() argument 89 mExtAddress = aNeighbor.GetExtAddress(); in SetFrom() 90 mAge = Time::MsecToSec(TimerMilli::GetNow() - aNeighbor.GetLastHeard()); in SetFrom() 91 mRloc16 = aNeighbor.GetRloc16(); in SetFrom() 92 mLinkFrameCounter = aNeighbor.GetLinkFrameCounters().GetMaximum(); in SetFrom() 93 mMleFrameCounter = aNeighbor.GetMleFrameCounter(); in SetFrom() [all …]
|
D | radio_selector.cpp | 81 LogLevel RadioSelector::UpdatePreference(Neighbor &aNeighbor, Mac::RadioType aRadioType, int16_t aD… in UpdatePreference() argument 83 uint8_t old = aNeighbor.GetRadioPreference(aRadioType); in UpdatePreference() 98 aNeighbor.SetRadioPreference(aRadioType, static_cast<uint8_t>(preference)); in UpdatePreference() 108 void RadioSelector::UpdateOnReceive(Neighbor &aNeighbor, Mac::RadioType aRadioType, bool aIsDuplica… in UpdateOnReceive() argument 112 if (aNeighbor.GetSupportedRadioTypes().Contains(aRadioType)) in UpdateOnReceive() 114 logLevel = UpdatePreference(aNeighbor, aRadioType, in UpdateOnReceive() 117 Log(logLevel, aIsDuplicate ? "UpdateOnDupRx" : "UpdateOnRx", aRadioType, aNeighbor); in UpdateOnReceive() 121 aNeighbor.AddSupportedRadioType(aRadioType); in UpdateOnReceive() 122 aNeighbor.SetRadioPreference(aRadioType, kInitPreference); in UpdateOnReceive() 124 Log(logLevel, "NewRadio(OnRx)", aRadioType, aNeighbor); in UpdateOnReceive() [all …]
|
D | link_metrics.cpp | 353 …id Initiator::ProcessEnhAckIeData(const uint8_t *aData, uint8_t aLength, const Neighbor &aNeighbor) in ProcessEnhAckIeData() argument 360 values.SetMetrics(aNeighbor.GetEnhAckProbingMetrics()); in ProcessEnhAckIeData() 375 … mEnhAckProbingIeReportCallback.Invoke(aNeighbor.GetRloc16(), &aNeighbor.GetExtAddress(), &values); in ProcessEnhAckIeData() 381 Error Initiator::FindNeighbor(const Ip6::Address &aDestination, Neighbor *&aNeighbor) in FindNeighbor() argument 386 aNeighbor = nullptr; in FindNeighbor() 391 aNeighbor = Get<NeighborTable>().FindNeighbor(macAddress); in FindNeighbor() 392 VerifyOrExit(aNeighbor != nullptr); in FindNeighbor() 394 VerifyOrExit(aNeighbor->GetVersion() >= kThreadVersion1p2, error = kErrorNotCapable); in FindNeighbor() 409 Error Subject::AppendReport(Message &aMessage, const Message &aRequestMessage, Neighbor &aNeighbor) in AppendReport() argument 477 SeriesInfo *seriesInfo = aNeighbor.GetForwardTrackingSeriesInfo(queryId); in AppendReport() [all …]
|
D | radio_selector.hpp | 125 void UpdateOnReceive(Neighbor &aNeighbor, Mac::RadioType aRadioType, bool aIsDuplicate); 148 void UpdateOnDeferredAck(Neighbor &aNeighbor, Error aTxError, bool &aAllowNeighborRemove); 191 …LogLevel UpdatePreference(Neighbor &aNeighbor, Mac::RadioType aRadioType, int16_t aDifferenc… 192 Mac::RadioType Select(Mac::RadioTypes aRadioOptions, const Neighbor &aNeighbor); 193 … Log(LogLevel aLogLevel, const char *aActionText, Mac::RadioType aType, const Neighbor &aNeighbor);
|
D | link_metrics.hpp | 241 void ProcessEnhAckIeData(const uint8_t *aData, uint8_t aLength, const Neighbor &aNeighbor); 246 Error FindNeighbor(const Ip6::Address &aDestination, Neighbor *&aNeighbor); 285 Error AppendReport(Message &aMessage, const Message &aRequestMessage, Neighbor &aNeighbor); 297 Error HandleManagementRequest(const Message &aMessage, Neighbor &aNeighbor, Status &aStatus); 331 Neighbor &aNeighbor); 332 … Status ConfigureEnhAckProbing(uint8_t aEnhAckFlags, const Metrics &aMetrics, Neighbor &aNeighbor);
|
D | neighbor_table.cpp | 264 void NeighborTable::Signal(Event aEvent, const Neighbor &aNeighbor) in Signal() argument 280 OT_ASSERT(Get<ChildTable>().Contains(aNeighbor)); in Signal() 281 … static_cast<Child::Info &>(info.mInfo.mChild).SetFrom(static_cast<const Child &>(aNeighbor)); in Signal() 287 static_cast<Neighbor::Info &>(info.mInfo.mRouter).SetFrom(aNeighbor); in Signal() 302 Get<Utils::Otns>().EmitNeighborChange(aEvent, aNeighbor); in Signal() 314 Get<DuaManager>().HandleChildDuaAddressEvent(static_cast<const Child &>(aNeighbor), in Signal()
|
D | router_table.hpp | 260 bool Contains(const Neighbor &aNeighbor) const in Contains() 262 return mRouters.IsInArrayBuffer(&static_cast<const Router &>(aNeighbor)); in Contains() 364 void FillRouteTlv(Mle::RouteTlv &aRouteTlv, const Neighbor *aNeighbor = nullptr) const;
|
D | child_table.hpp | 302 bool Contains(const Neighbor &aNeighbor) const in Contains() 304 const Child *child = static_cast<const Child *>(&aNeighbor); in Contains()
|
D | mesh_forwarder.cpp | 1147 void MeshForwarder::UpdateNeighborLinkFailures(Neighbor &aNeighbor, in UpdateNeighborLinkFailures() argument 1156 aNeighbor.ResetLinkFailures(); in UpdateNeighborLinkFailures() 1160 aNeighbor.IncrementLinkFailures(); in UpdateNeighborLinkFailures() 1162 if (aAllowNeighborRemove && (Mle::IsRouterRloc16(aNeighbor.GetRloc16())) && in UpdateNeighborLinkFailures() 1163 (aNeighbor.GetLinkFailures() >= aFailLimit)) in UpdateNeighborLinkFailures() 1166 Get<Mle::MleRouter>().RemoveRouterLink(static_cast<Router &>(aNeighbor)); in UpdateNeighborLinkFailures() 1175 void MeshForwarder::HandleDeferredAck(Neighbor &aNeighbor, Error aError) in HandleDeferredAck() argument 1184 aNeighbor.GetExtAddress().ToString().AsCString(), aNeighbor.GetRloc16()); in HandleDeferredAck() 1190 Get<RadioSelector>().UpdateOnDeferredAck(aNeighbor, aError, allowNeighborRemove); in HandleDeferredAck() 1192 UpdateNeighborLinkFailures(aNeighbor, aError, allowNeighborRemove, kFailedRouterTransmissions); in HandleDeferredAck() [all …]
|
D | mle_router.cpp | 3246 void MleRouter::RemoveNeighbor(Neighbor &aNeighbor) in RemoveNeighbor() argument 3248 VerifyOrExit(!aNeighbor.IsStateInvalid()); in RemoveNeighbor() 3250 if (&aNeighbor == &mParent) in RemoveNeighbor() 3257 else if (&aNeighbor == &GetParentCandidate()) in RemoveNeighbor() 3261 else if (IsChildRloc16(aNeighbor.GetRloc16())) in RemoveNeighbor() 3263 OT_ASSERT(mChildTable.Contains(aNeighbor)); in RemoveNeighbor() 3265 if (aNeighbor.IsStateValidOrRestoring()) in RemoveNeighbor() 3267 mNeighborTable.Signal(NeighborTable::kChildRemoved, aNeighbor); in RemoveNeighbor() 3270 Get<IndirectSender>().ClearAllMessagesForSleepyChild(static_cast<Child &>(aNeighbor)); in RemoveNeighbor() 3272 if (aNeighbor.IsFullThreadDevice()) in RemoveNeighbor() [all …]
|
D | neighbor.hpp | 173 bool Matches(const Neighbor &aNeighbor) const; 199 void SetFrom(const Neighbor &aNeighbor);
|
D | mesh_forwarder.hpp | 339 void HandleDeferredAck(Neighbor &aNeighbor, Error aError); 541 …void UpdateNeighborLinkFailures(Neighbor &aNeighbor, Error aError, bool aAllowNeighborRemove, uint… 543 void UpdateSendMessage(Error aFrameTxError, Mac::Address &aMacDest, Neighbor *aNeighbor);
|
D | neighbor_table.hpp | 221 void Signal(Event aEvent, const Neighbor &aNeighbor);
|
D | router_table.cpp | 727 void RouterTable::FillRouteTlv(Mle::RouteTlv &aRouteTlv, const Neighbor *aNeighbor) const in FillRouteTlv() 735 if ((aNeighbor != nullptr) && Mle::IsRouterRloc16(aNeighbor->GetRloc16())) in FillRouteTlv() 751 … if (Get<Mle::Mle>().MatchesRouterId(routerId) || (routerId == aNeighbor->GetRouterId()) || in FillRouteTlv()
|
D | mle.cpp | 1096 void Mle::InitNeighbor(Neighbor &aNeighbor, const RxInfo &aRxInfo) in InitNeighbor() argument 1098 aRxInfo.mMessageInfo.GetPeerAddr().GetIid().ConvertToExtAddress(aNeighbor.GetExtAddress()); in InitNeighbor() 1099 aNeighbor.GetLinkInfo().Clear(); in InitNeighbor() 1100 aNeighbor.GetLinkInfo().AddRss(aRxInfo.mMessage.GetAverageRss()); in InitNeighbor() 1101 aNeighbor.ResetLinkFailures(); in InitNeighbor() 1102 aNeighbor.SetLastHeard(TimerMilli::GetNow()); in InitNeighbor() 2700 void Mle::ReestablishLinkWithNeighbor(Neighbor &aNeighbor) in ReestablishLinkWithNeighbor() argument 2702 VerifyOrExit(IsAttached() && aNeighbor.IsStateValid()); in ReestablishLinkWithNeighbor() 2704 if (IsChild() && (&aNeighbor == &mParent)) in ReestablishLinkWithNeighbor() 2713 if (IsRouterRloc16(aNeighbor.GetRloc16())) in ReestablishLinkWithNeighbor() [all …]
|
D | mle.hpp | 1020 Error AppendRouteTlv(Neighbor *aNeighbor = nullptr); 1318 void InitNeighbor(Neighbor &aNeighbor, const RxInfo &aRxInfo); 1323 void ReestablishLinkWithNeighbor(Neighbor &aNeighbor);
|
D | mle_router.hpp | 332 void RemoveNeighbor(Neighbor &aNeighbor);
|
/openthread-latest/src/core/radio/ |
D | trel_link.cpp | 296 void Link::HandleTimer(Neighbor &aNeighbor) in HandleTimer() argument 298 VerifyOrExit(!aNeighbor.IsStateInvalid()); in HandleTimer() 302 while (aNeighbor.mTrelPreviousPendingAcks > 0) in HandleTimer() 304 aNeighbor.mTrelPreviousPendingAcks--; in HandleTimer() 306 ReportDeferredAckStatus(aNeighbor, kErrorNoAck); in HandleTimer() 307 VerifyOrExit(!aNeighbor.IsStateInvalid()); in HandleTimer() 310 aNeighbor.mTrelPreviousPendingAcks = aNeighbor.mTrelCurrentPendingAcks; in HandleTimer() 311 aNeighbor.mTrelCurrentPendingAcks = 0; in HandleTimer() 477 void Link::ReportDeferredAckStatus(Neighbor &aNeighbor, Error aError) in ReportDeferredAckStatus() argument 479 … LogDebg("ReportDeferredAckStatus(): %s for %s", aNeighbor.GetExtAddress().ToString().AsCString(), in ReportDeferredAckStatus() [all …]
|
D | trel_link.hpp | 186 void ReportDeferredAckStatus(Neighbor &aNeighbor, Error aError); 187 void HandleTimer(Neighbor &aNeighbor);
|
/openthread-latest/src/core/utils/ |
D | otns.cpp | 107 void Otns::EmitNeighborChange(NeighborTable::Event aEvent, const Neighbor &aNeighbor) in EmitNeighborChange() argument 112 EmitStatus("router_added=%s", aNeighbor.GetExtAddress().ToString().AsCString()); in EmitNeighborChange() 115 EmitStatus("router_removed=%s", aNeighbor.GetExtAddress().ToString().AsCString()); in EmitNeighborChange() 118 EmitStatus("child_added=%s", aNeighbor.GetExtAddress().ToString().AsCString()); in EmitNeighborChange() 121 EmitStatus("child_removed=%s", aNeighbor.GetExtAddress().ToString().AsCString()); in EmitNeighborChange()
|
D | otns.hpp | 122 static void EmitNeighborChange(NeighborTable::Event aEvent, const Neighbor &aNeighbor);
|
/openthread-latest/src/core/mac/ |
D | mac.cpp | 1567 Error Mac::ProcessReceiveSecurity(RxFrame &aFrame, const Address &aSrcAddr, Neighbor *aNeighbor) in ProcessReceiveSecurity() argument 1597 VerifyOrExit(aNeighbor != nullptr); in ProcessReceiveSecurity() 1627 if (aNeighbor->IsStateValid()) in ProcessReceiveSecurity() 1629 VerifyOrExit(keySequence >= aNeighbor->GetKeySequence()); in ProcessReceiveSecurity() 1631 if (keySequence == aNeighbor->GetKeySequence()) in ProcessReceiveSecurity() 1636 neighborFrameCounter = aNeighbor->GetLinkFrameCounters().Get(aFrame.GetRadioType()); in ProcessReceiveSecurity() 1638 neighborFrameCounter = aNeighbor->GetLinkFrameCounters().Get(); in ProcessReceiveSecurity() 1682 if ((keyIdMode == Frame::kKeyIdMode1) && aNeighbor->IsStateValid()) in ProcessReceiveSecurity() 1684 if (aNeighbor->GetKeySequence() != keySequence) in ProcessReceiveSecurity() 1686 aNeighbor->SetKeySequence(keySequence); in ProcessReceiveSecurity() [all …]
|
D | mac_filter.cpp | 251 Error Filter::ApplyToRxFrame(RxFrame &aRxFrame, const ExtAddress &aExtAddress, Neighbor *aNeighbor)… in ApplyToRxFrame() 262 if (aNeighbor != nullptr) in ApplyToRxFrame() 266 aNeighbor->GetLinkInfo().ClearAverageRss(); in ApplyToRxFrame()
|
D | mac.hpp | 830 Error ProcessReceiveSecurity(RxFrame &aFrame, const Address &aSrcAddr, Neighbor *aNeighbor); 850 void UpdateNeighborLinkInfo(Neighbor &aNeighbor, const RxFrame &aRxFrame); 874 void ProcessEnhAckProbing(const RxFrame &aFrame, const Neighbor &aNeighbor);
|
D | mac_filter.hpp | 224 …Error ApplyToRxFrame(RxFrame &aRxFrame, const ExtAddress &aExtAddress, Neighbor *aNeighbor = nullp…
|