10 #include <boost/numeric/conversion/cast.hpp> 11 #include <boost/format.hpp> 21 void PeriodicCounterSelectionCommandHandler::ParseData(
const Packet& packet, CaptureData& captureData)
23 std::vector<uint16_t> counterIds;
28 if (packet.GetLength() < 4)
35 uint32_t capturePeriod =
ReadUint32(packet.GetData(), offset);
38 captureData.SetCapturePeriod(capturePeriod);
41 unsigned int counters = (packet.GetLength() - 4) / 2;
44 counterIds.reserve(counters);
45 offset += sizeOfUint32;
46 for (
unsigned int i = 0; i < counters; ++i)
49 uint16_t counterId =
ReadUint16(packet.GetData(), offset);
50 counterIds.emplace_back(counterId);
51 offset += sizeOfUint16;
56 captureData.SetCounterIds(counterIds);
67 throw RuntimeException(boost::str(boost::format(
"Periodic Counter Selection Command Handler invoked while in " 68 "an wrong state: %1%")
76 "received family = %1%, id = %2%")
83 ParseData(packet, captureData);
92 const std::vector<uint16_t>& counterIds = captureData.
GetCounterIds();
95 std::vector<uint16_t> validCounterIds;
96 for (uint16_t counterId : counterIds)
105 validCounterIds.emplace_back(counterId);
108 std::sort(validCounterIds.begin(), validCounterIds.end());
110 auto backendIdStart = std::find_if(validCounterIds.begin(), validCounterIds.end(), [&](uint16_t& counterId)
112 return counterId > m_MaxArmCounterId;
115 std::set<armnn::BackendId> activeBackends;
116 std::set<uint16_t> backendCounterIds = std::set<uint16_t>(backendIdStart, validCounterIds.end());
118 if (m_BackendCounterMap.size() != 0)
120 std::set<uint16_t> newCounterIds;
121 std::set<uint16_t> unusedCounterIds;
124 std::set_difference(backendCounterIds.begin(), backendCounterIds.end(),
125 m_PrevBackendCounterIds.begin(), m_PrevBackendCounterIds.end(),
126 std::inserter(newCounterIds, newCounterIds.begin()));
129 std::set_difference(m_PrevBackendCounterIds.begin(), m_PrevBackendCounterIds.end(),
130 backendCounterIds.begin(), backendCounterIds.end(),
131 std::inserter(unusedCounterIds, unusedCounterIds.begin()));
133 activeBackends = ProcessBackendCounterIds(capturePeriod, newCounterIds, unusedCounterIds);
137 activeBackends = ProcessBackendCounterIds(capturePeriod, backendCounterIds, {});
141 m_PrevBackendCounterIds = backendCounterIds;
145 m_CaptureDataHolder.
SetCaptureData(capturePeriod, {validCounterIds.begin(), backendIdStart}, activeBackends);
150 if (capturePeriod == 0 || validCounterIds.empty())
153 m_PeriodicCounterCapture.
Stop();
158 m_PeriodicCounterCapture.
Start();
164 throw RuntimeException(boost::str(boost::format(
"Unknown profiling service state: %1%")
165 % static_cast<int>(currentState)));
169 std::set<armnn::BackendId> PeriodicCounterSelectionCommandHandler::ProcessBackendCounterIds(
170 const u_int32_t capturePeriod,
171 std::set<uint16_t> newCounterIds,
172 std::set<uint16_t> unusedCounterIds)
174 std::set<armnn::BackendId> changedBackends;
177 for (uint16_t counterId : newCounterIds)
179 auto backendId = m_CounterIdMap.
GetBackendId(counterId);
180 m_BackendCounterMap[backendId.second].emplace_back(backendId.first);
181 changedBackends.insert(backendId.second);
184 activeBackends.insert(changedBackends.begin(), changedBackends.end());
186 for (uint16_t counterId : unusedCounterIds)
188 auto backendId = m_CounterIdMap.
GetBackendId(counterId);
189 std::vector<uint16_t>& backendCounters = m_BackendCounterMap[backendId.second];
191 backendCounters.erase(std::remove(backendCounters.begin(), backendCounters.end(), backendId.first));
193 if(backendCounters.size() == 0)
197 activeBackends.erase(backendId.second);
198 ActivateBackedCounters(backendId.second, 0, {});
202 changedBackends.insert(backendId.second);
207 if(capturePeriod == m_PrevCapturePeriod)
209 for (
auto backend : changedBackends)
211 ActivateBackedCounters(backend, capturePeriod, m_BackendCounterMap[backend]);
217 for (
auto backend : m_BackendCounterMap)
219 ActivateBackedCounters(backend.first, capturePeriod, backend.second);
221 if(capturePeriod == 0)
225 m_PrevCapturePeriod = capturePeriod;
228 return activeBackends;
ProfilingState GetCurrentState() const
const std::set< armnn::BackendId > & GetActiveBackends() const
const std::vector< uint16_t > & GetCounterIds() const
virtual void SendPeriodicCounterSelectionPacket(uint32_t capturePeriod, const std::vector< uint16_t > &selectedCounterIds)=0
Create and write a PeriodicCounterSelectionPacket from the parameters to the buffer.
void operator()(const Packet &packet) override
uint16_t ReadUint16(const IPacketBufferPtr &packetBuffer, unsigned int offset)
Copyright (c) 2020 ARM Limited.
uint32_t GetPacketFamily() const
uint32_t GetCapturePeriod() const
CaptureData GetCaptureData() const
void SetCaptureData(uint32_t capturePeriod, const std::vector< uint16_t > &counterIds, const std::set< armnn::BackendId > &activeBackends)
std::enable_if_t< std::is_unsigned< Source >::value &&std::is_unsigned< Dest >::value, Dest > numeric_cast(Source source)
constexpr unsigned int LOWEST_CAPTURE_PERIOD
The lowest performance data capture interval we support is 10 miliseconds.
virtual bool IsCounterRegistered(uint16_t counterUid) const =0
uint32_t ReadUint32(const IPacketBufferPtr &packetBuffer, unsigned int offset)
uint32_t GetPacketId() const
virtual const std::pair< uint16_t, armnn::BackendId > & GetBackendId(uint16_t globalCounterId) const =0
constexpr char const * GetProfilingStateName(ProfilingState state)