espressif/openthread
1
0
Fork 0
mirror of https://github.com/espressif/openthread.git synced 2026-09-11 19:50:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

[dataset] update SendGetRequest() to use TlvList array (#10066)

Browse Source
This commit is contained in:
Abtin Keshavarzian
2024-04-26 11:40:50 -07:00
committed by GitHub
parent ca45026ba5
commit 20a6e887f9
1 changed files with 20 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/meshcop/dataset_manager.cpp
+20 -31
View File
@@ -470,90 +470,79 @@ Error DatasetManager::SendGetRequest(const Dataset::Components &aDatasetComponen
Error error = kErrorNone;
Coap::Message *message;
Tmf::MessageInfo messageInfo(GetInstance());
Tlv tlv;
uint8_t datasetTlvs[kMaxDatasetTlvs];
uint8_t length;
length = 0;
TlvList tlvList;
if (aDatasetComponents.IsPresent<Dataset::kActiveTimestamp>())
{
datasetTlvs[length++] = Tlv::kActiveTimestamp;
tlvList.Add(Tlv::kActiveTimestamp);
}
if (aDatasetComponents.IsPresent<Dataset::kPendingTimestamp>())
{
datasetTlvs[length++] = Tlv::kPendingTimestamp;
tlvList.Add(Tlv::kPendingTimestamp);
}
if (aDatasetComponents.IsPresent<Dataset::kNetworkKey>())
{
datasetTlvs[length++] = Tlv::kNetworkKey;
tlvList.Add(Tlv::kNetworkKey);
}
if (aDatasetComponents.IsPresent<Dataset::kNetworkName>())
{
datasetTlvs[length++] = Tlv::kNetworkName;
tlvList.Add(Tlv::kNetworkName);
}
if (aDatasetComponents.IsPresent<Dataset::kExtendedPanId>())
{
datasetTlvs[length++] = Tlv::kExtendedPanId;
tlvList.Add(Tlv::kExtendedPanId);
}
if (aDatasetComponents.IsPresent<Dataset::kMeshLocalPrefix>())
{
datasetTlvs[length++] = Tlv::kMeshLocalPrefix;
tlvList.Add(Tlv::kMeshLocalPrefix);
}
if (aDatasetComponents.IsPresent<Dataset::kDelay>())
{
datasetTlvs[length++] = Tlv::kDelayTimer;
tlvList.Add(Tlv::kDelayTimer);
}
if (aDatasetComponents.IsPresent<Dataset::kPanId>())
{
datasetTlvs[length++] = Tlv::kPanId;
tlvList.Add(Tlv::kPanId);
}
if (aDatasetComponents.IsPresent<Dataset::kChannel>())
{
datasetTlvs[length++] = Tlv::kChannel;
tlvList.Add(Tlv::kChannel);
}
if (aDatasetComponents.IsPresent<Dataset::kPskc>())
{
datasetTlvs[length++] = Tlv::kPskc;
tlvList.Add(Tlv::kPskc);
}
if (aDatasetComponents.IsPresent<Dataset::kSecurityPolicy>())
{
datasetTlvs[length++] = Tlv::kSecurityPolicy;
tlvList.Add(Tlv::kSecurityPolicy);
}
if (aDatasetComponents.IsPresent<Dataset::kChannelMask>())
{
datasetTlvs[length++] = Tlv::kChannelMask;
tlvList.Add(Tlv::kChannelMask);
}
for (uint8_t index = 0; index < aLength; index++)
{
tlvList.Add(aTlvTypes[index]);
}
message = Get<Tmf::Agent>().NewPriorityConfirmablePostMessage(IsActiveDataset() ? kUriActiveGet : kUriPendingGet);
VerifyOrExit(message != nullptr, error = kErrorNoBufs);
if (aLength + length > 0)
if (!tlvList.IsEmpty())
{
tlv.SetType(Tlv::kGet);
tlv.SetLength(aLength + length);
SuccessOrExit(error = message->Append(tlv));
if (length > 0)
{
SuccessOrExit(error = message->AppendBytes(datasetTlvs, length));
}
if (aLength > 0)
{
SuccessOrExit(error = message->AppendBytes(aTlvTypes, aLength));
}
SuccessOrExit(error = Tlv::AppendTlv(*message, Tlv::kGet, tlvList.GetArrayBuffer(), tlvList.GetLength()));
}
IgnoreError(messageInfo.SetSockAddrToRlocPeerAddrToLeaderAloc());