diff options
author | Finn Williams <Finn.Williams@arm.com> | 2020-04-09 16:05:28 +0100 |
---|---|---|
committer | Finn Williams <Finn.Williams@arm.com> | 2020-04-10 14:48:56 +0100 |
commit | fe5a24beeef6e9a41366e694f41093565e748048 (patch) | |
tree | 72c660062f9c8287e54176dfbd8c5aa0269f2e51 /src/profiling | |
parent | bb446e576e120512d5752a5d6dc1ddc636f563ba (diff) | |
download | armnn-fe5a24beeef6e9a41366e694f41093565e748048.tar.gz |
IVGCVSW-4666 Call EnableProfiling when state switches to active
* Move the call to EnableProfiling() into ConnectionAcknowledgedHandler
* Fix an issue with MockGatord forcing some command handlers to be quiet
* Add some small unrelated improvements and typo fixes to the
periodic counter command handlers
Signed-off-by: Finn Williams <Finn.Williams@arm.com>
Change-Id: I9e6066b78d1f782cfaf27c11571c0ec5cb5d126f
Diffstat (limited to 'src/profiling')
-rw-r--r-- | src/profiling/ConnectionAcknowledgedCommandHandler.cpp | 14 | ||||
-rw-r--r-- | src/profiling/ConnectionAcknowledgedCommandHandler.hpp | 11 | ||||
-rw-r--r-- | src/profiling/CounterDirectory.cpp | 2 | ||||
-rw-r--r-- | src/profiling/PeriodicCounterCapture.cpp | 2 | ||||
-rw-r--r-- | src/profiling/PeriodicCounterCapture.hpp | 4 | ||||
-rw-r--r-- | src/profiling/PeriodicCounterSelectionCommandHandler.cpp | 5 | ||||
-rw-r--r-- | src/profiling/PeriodicCounterSelectionCommandHandler.hpp | 12 | ||||
-rw-r--r-- | src/profiling/ProfilingService.hpp | 3 |
8 files changed, 36 insertions, 17 deletions
diff --git a/src/profiling/ConnectionAcknowledgedCommandHandler.cpp b/src/profiling/ConnectionAcknowledgedCommandHandler.cpp index 0071bfc11e..995562fb3f 100644 --- a/src/profiling/ConnectionAcknowledgedCommandHandler.cpp +++ b/src/profiling/ConnectionAcknowledgedCommandHandler.cpp @@ -41,9 +41,21 @@ void ConnectionAcknowledgedCommandHandler::operator()(const Packet& packet) // Send the counter directory packet. m_SendCounterPacket.SendCounterDirectoryPacket(m_CounterDirectory); m_SendTimelinePacket.SendTimelineMessageDirectoryPackage(); - TimelineUtilityMethods::SendWellKnownLabelsAndEventClasses(m_SendTimelinePacket); + if(m_BackendProfilingContext.has_value()) + { + for (auto backendContext : m_BackendProfilingContext.value()) + { + // Enable profiling on the backend and assert that it returns true + if(!backendContext.second->EnableProfiling(true)) + { + throw BackendProfilingException( + "Unable to enable profiling on Backend Id: " + backendContext.first.Get()); + } + } + } + break; case ProfilingState::Active: return; // NOP diff --git a/src/profiling/ConnectionAcknowledgedCommandHandler.hpp b/src/profiling/ConnectionAcknowledgedCommandHandler.hpp index 6054306da8..e2bdff8e96 100644 --- a/src/profiling/ConnectionAcknowledgedCommandHandler.hpp +++ b/src/profiling/ConnectionAcknowledgedCommandHandler.hpp @@ -5,11 +5,13 @@ #pragma once +#include <armnn/backends/profiling/IBackendProfilingContext.hpp> #include "CommandHandlerFunctor.hpp" #include "ISendCounterPacket.hpp" #include "armnn/profiling/ISendTimelinePacket.hpp" #include "Packet.hpp" #include "ProfilingStateMachine.hpp" +#include <future> namespace armnn { @@ -20,6 +22,9 @@ namespace profiling class ConnectionAcknowledgedCommandHandler final : public CommandHandlerFunctor { +typedef const std::unordered_map<BackendId, std::shared_ptr<armnn::profiling::IBackendProfilingContext>>& + BackendProfilingContexts; + public: ConnectionAcknowledgedCommandHandler(uint32_t familyId, uint32_t packetId, @@ -27,12 +32,14 @@ public: ICounterDirectory& counterDirectory, ISendCounterPacket& sendCounterPacket, ISendTimelinePacket& sendTimelinePacket, - ProfilingStateMachine& profilingStateMachine) + ProfilingStateMachine& profilingStateMachine, + Optional<BackendProfilingContexts> backendProfilingContexts = EmptyOptional()) : CommandHandlerFunctor(familyId, packetId, version) , m_CounterDirectory(counterDirectory) , m_SendCounterPacket(sendCounterPacket) , m_SendTimelinePacket(sendTimelinePacket) , m_StateMachine(profilingStateMachine) + , m_BackendProfilingContext(backendProfilingContexts) {} void operator()(const Packet& packet) override; @@ -42,7 +49,7 @@ private: ISendCounterPacket& m_SendCounterPacket; ISendTimelinePacket& m_SendTimelinePacket; ProfilingStateMachine& m_StateMachine; - + Optional<BackendProfilingContexts> m_BackendProfilingContext; }; } // namespace profiling diff --git a/src/profiling/CounterDirectory.cpp b/src/profiling/CounterDirectory.cpp index 415a66072f..ae1c49796c 100644 --- a/src/profiling/CounterDirectory.cpp +++ b/src/profiling/CounterDirectory.cpp @@ -498,7 +498,7 @@ CountersIt CounterDirectory::FindCounter(const std::string& counterName) const return std::find_if(m_Counters.begin(), m_Counters.end(), [&counterName](const auto& pair) { ARMNN_ASSERT(pair.second); - ARMNN_ASSERT(pair.second->m_Uid == pair.first); + ARMNN_ASSERT(pair.first >= pair.second->m_Uid && pair.first <= pair.second->m_MaxCounterUid); return pair.second->m_Name == counterName; }); diff --git a/src/profiling/PeriodicCounterCapture.cpp b/src/profiling/PeriodicCounterCapture.cpp index b143295bc1..4ad1d113b6 100644 --- a/src/profiling/PeriodicCounterCapture.cpp +++ b/src/profiling/PeriodicCounterCapture.cpp @@ -125,7 +125,7 @@ void PeriodicCounterCapture::Capture(const IReadCounterValues& readCounterValues for_each(activeBackends.begin(), activeBackends.end(), [&](const armnn::BackendId& backendId) { DispatchPeriodicCounterCapturePacket( - backendId, m_BackendProfilingContext.at(backendId)->ReportCounterValues()); + backendId, m_BackendProfilingContexts.at(backendId)->ReportCounterValues()); }); // Wait the indicated capture period (microseconds) diff --git a/src/profiling/PeriodicCounterCapture.hpp b/src/profiling/PeriodicCounterCapture.hpp index ff0562377c..51ac273860 100644 --- a/src/profiling/PeriodicCounterCapture.hpp +++ b/src/profiling/PeriodicCounterCapture.hpp @@ -39,7 +39,7 @@ public: , m_ReadCounterValues(readCounterValue) , m_SendCounterPacket(packet) , m_CounterIdMap(counterIdMap) - , m_BackendProfilingContext(backendProfilingContexts) + , m_BackendProfilingContexts(backendProfilingContexts) {} ~PeriodicCounterCapture() { Stop(); } @@ -61,7 +61,7 @@ private: ISendCounterPacket& m_SendCounterPacket; const ICounterMappings& m_CounterIdMap; const std::unordered_map<armnn::BackendId, - std::shared_ptr<armnn::profiling::IBackendProfilingContext>>& m_BackendProfilingContext; + std::shared_ptr<armnn::profiling::IBackendProfilingContext>>& m_BackendProfilingContexts; }; } // namespace profiling diff --git a/src/profiling/PeriodicCounterSelectionCommandHandler.cpp b/src/profiling/PeriodicCounterSelectionCommandHandler.cpp index d218433d93..4e3e6e554b 100644 --- a/src/profiling/PeriodicCounterSelectionCommandHandler.cpp +++ b/src/profiling/PeriodicCounterSelectionCommandHandler.cpp @@ -140,7 +140,6 @@ void PeriodicCounterSelectionCommandHandler::operator()(const Packet& packet) // save the new backend counter ids for next time m_PrevBackendCounterIds = backendCounterIds; - // Set the capture data with only the valid armnn counter UIDs m_CaptureDataHolder.SetCaptureData(capturePeriod, {validCounterIds.begin(), backendIdStart}, activeBackends); @@ -168,8 +167,8 @@ void PeriodicCounterSelectionCommandHandler::operator()(const Packet& packet) std::set<armnn::BackendId> PeriodicCounterSelectionCommandHandler::ProcessBackendCounterIds( const u_int32_t capturePeriod, - std::set<uint16_t> newCounterIds, - std::set<uint16_t> unusedCounterIds) + const std::set<uint16_t> newCounterIds, + const std::set<uint16_t> unusedCounterIds) { std::set<armnn::BackendId> changedBackends; std::set<armnn::BackendId> activeBackends = m_CaptureDataHolder.GetCaptureData().GetActiveBackends(); diff --git a/src/profiling/PeriodicCounterSelectionCommandHandler.hpp b/src/profiling/PeriodicCounterSelectionCommandHandler.hpp index 437d7128be..b59d84cffa 100644 --- a/src/profiling/PeriodicCounterSelectionCommandHandler.hpp +++ b/src/profiling/PeriodicCounterSelectionCommandHandler.hpp @@ -37,7 +37,7 @@ public: uint32_t version, const std::unordered_map<BackendId, std::shared_ptr<armnn::profiling::IBackendProfilingContext>>& - backendProfilingContext, + backendProfilingContexts, const ICounterMappings& counterIdMap, Holder& captureDataHolder, const uint16_t maxArmnnCounterId, @@ -46,7 +46,7 @@ public: ISendCounterPacket& sendCounterPacket, const ProfilingStateMachine& profilingStateMachine) : CommandHandlerFunctor(familyId, packetId, version) - , m_BackendProfilingContext(backendProfilingContext) + , m_BackendProfilingContexts(backendProfilingContexts) , m_CounterIdMap(counterIdMap) , m_CaptureDataHolder(captureDataHolder) , m_MaxArmCounterId(maxArmnnCounterId) @@ -66,7 +66,7 @@ private: std::unordered_map<armnn::BackendId, std::vector<uint16_t>> m_BackendCounterMap; const std::unordered_map<BackendId, - std::shared_ptr<armnn::profiling::IBackendProfilingContext>>& m_BackendProfilingContext; + std::shared_ptr<armnn::profiling::IBackendProfilingContext>>& m_BackendProfilingContexts; const ICounterMappings& m_CounterIdMap; Holder& m_CaptureDataHolder; const uint16_t m_MaxArmCounterId; @@ -82,7 +82,7 @@ private: const std::vector<uint16_t> counterIds) { Optional<std::string> errorMsg = - m_BackendProfilingContext.at(backendId)->ActivateCounters(capturePeriod, counterIds); + m_BackendProfilingContexts.at(backendId)->ActivateCounters(capturePeriod, counterIds); if(errorMsg.has_value()) { @@ -92,8 +92,8 @@ private: } void ParseData(const Packet& packet, CaptureData& captureData); std::set<armnn::BackendId> ProcessBackendCounterIds(const u_int32_t capturePeriod, - std::set<uint16_t> newCounterIds, - std::set<uint16_t> unusedCounterIds); + const std::set<uint16_t> newCounterIds, + const std::set<uint16_t> unusedCounterIds); }; diff --git a/src/profiling/ProfilingService.hpp b/src/profiling/ProfilingService.hpp index a6c5e29767..f3d10e711b 100644 --- a/src/profiling/ProfilingService.hpp +++ b/src/profiling/ProfilingService.hpp @@ -80,7 +80,8 @@ public: m_CounterDirectory, m_SendCounterPacket, m_SendTimelinePacket, - m_StateMachine) + m_StateMachine, + m_BackendProfilingContexts) , m_RequestCounterDirectoryCommandHandler(0, 3, m_PacketVersionResolver.ResolvePacketVersion(0, 3).GetEncodedValue(), |