blob: 95fb8a3abbcbab4a9602486e58cfa5d490f357e7 [file] [log] [blame]
Laurent Carlier749294b2020-06-01 09:03:17 +01001//
Jim Flynn6398a982020-05-27 17:05:21 +01002// Copyright © 2017 Arm Ltd and Contributors. All rights reserved.
David Beckecb56cd2018-09-05 12:52:57 +01003// SPDX-License-Identifier: MIT
telsoa014fcda012018-03-09 14:13:49 +00004//
5#include "Runtime.hpp"
6
David Beck056be3c2018-10-22 13:16:00 +01007#include <armnn/Version.hpp>
Matteo Martincighc601aa62019-10-29 15:03:22 +00008#include <armnn/BackendRegistry.hpp>
Jan Eilers15fcc7e2021-07-14 13:50:15 +01009#include <armnn/BackendHelper.hpp>
Matthew Benthamf48afc62020-01-15 17:55:08 +000010#include <armnn/Logging.hpp>
alered01a7227ac2020-05-07 14:58:29 +010011#include <armnn/utility/Timer.hpp>
Matteo Martincighe54aa062019-08-05 14:12:11 +010012
Matteo Martincighe5b8eb92019-11-28 15:45:42 +000013#include <armnn/backends/IBackendContext.hpp>
Matteo Martincighe54aa062019-08-05 14:12:11 +010014#include <backendsCommon/DynamicBackendUtils.hpp>
Jim Flynne1fdd282021-10-26 21:26:10 +010015#include <backendsCommon/memoryOptimizerStrategyLibrary/MemoryOptimizerStrategyLibrary.hpp>
Jan Eilersbb446e52020-04-02 13:56:54 +010016#include <armnn/utility/PolymorphicDowncast.hpp>
telsoa014fcda012018-03-09 14:13:49 +000017
Nikhil Raj77fe76b2021-06-09 14:55:32 +010018#include <common/include/LabelsAndEventClasses.hpp>
19
surmeh013537c2c2018-05-18 16:31:43 +010020#include <iostream>
21
Colm Donelan1aff3932020-02-05 17:48:59 +000022#include <backends/BackendProfiling.hpp>
telsoa014fcda012018-03-09 14:13:49 +000023
24using namespace armnn;
25using namespace std;
26
27namespace armnn
28{
Kevin Mayd92a6e42021-02-04 10:27:41 +000029IRuntime::IRuntime() : pRuntimeImpl( new RuntimeImpl(armnn::IRuntime::CreationOptions())) {}
30
31IRuntime::IRuntime(const IRuntime::CreationOptions& options) : pRuntimeImpl(new RuntimeImpl(options)) {}
32
33IRuntime::~IRuntime() = default;
telsoa014fcda012018-03-09 14:13:49 +000034
35IRuntime* IRuntime::CreateRaw(const CreationOptions& options)
36{
Kevin Mayd92a6e42021-02-04 10:27:41 +000037 return new IRuntime(options);
telsoa014fcda012018-03-09 14:13:49 +000038}
39
40IRuntimePtr IRuntime::Create(const CreationOptions& options)
41{
42 return IRuntimePtr(CreateRaw(options), &IRuntime::Destroy);
43}
44
45void IRuntime::Destroy(IRuntime* runtime)
46{
Kevin Mayd92a6e42021-02-04 10:27:41 +000047 delete runtime;
telsoa014fcda012018-03-09 14:13:49 +000048}
49
Kevin Mayd92a6e42021-02-04 10:27:41 +000050Status IRuntime::LoadNetwork(NetworkId& networkIdOut, IOptimizedNetworkPtr network)
51{
52 return pRuntimeImpl->LoadNetwork(networkIdOut, std::move(network));
53}
54
55Status IRuntime::LoadNetwork(NetworkId& networkIdOut,
56 IOptimizedNetworkPtr network,
57 std::string& errorMessage)
58{
59 return pRuntimeImpl->LoadNetwork(networkIdOut, std::move(network), errorMessage);
60}
61
62Status IRuntime::LoadNetwork(NetworkId& networkIdOut,
63 IOptimizedNetworkPtr network,
64 std::string& errorMessage,
65 const INetworkProperties& networkProperties)
66{
67 return pRuntimeImpl->LoadNetwork(networkIdOut, std::move(network), errorMessage, networkProperties);
68}
69
Cathal Corbett5b8093c2021-10-22 11:12:07 +010070armnn::TensorInfo IRuntime::GetInputTensorInfo(NetworkId networkId, LayerBindingId layerId) const
Kevin Mayd92a6e42021-02-04 10:27:41 +000071{
72 return pRuntimeImpl->GetInputTensorInfo(networkId, layerId);
73}
74
Cathal Corbett5b8093c2021-10-22 11:12:07 +010075armnn::TensorInfo IRuntime::GetOutputTensorInfo(NetworkId networkId, LayerBindingId layerId) const
Kevin Mayd92a6e42021-02-04 10:27:41 +000076{
77 return pRuntimeImpl->GetOutputTensorInfo(networkId, layerId);
78}
79
Narumol Prangnawarate2af6f42022-01-28 17:59:18 +000080std::vector<ImportedInputId> IRuntime::ImportInputs(NetworkId networkId, const InputTensors& inputTensors,
81 MemorySource forceImportMemorySource)
Finn Williamsf37b9702021-09-01 18:06:04 +010082{
Narumol Prangnawarate2af6f42022-01-28 17:59:18 +000083 return pRuntimeImpl->ImportInputs(networkId, inputTensors, forceImportMemorySource);
Finn Williamsf37b9702021-09-01 18:06:04 +010084}
85
Narumol Prangnawarate2af6f42022-01-28 17:59:18 +000086std::vector<ImportedOutputId> IRuntime::ImportOutputs(NetworkId networkId, const OutputTensors& outputTensors,
87 MemorySource forceImportMemorySource)
Finn Williams8636bc72021-10-02 15:06:39 +010088{
Narumol Prangnawarate2af6f42022-01-28 17:59:18 +000089 return pRuntimeImpl->ImportOutputs(networkId, outputTensors, forceImportMemorySource);
Finn Williams8636bc72021-10-02 15:06:39 +010090}
91
92void IRuntime::ClearImportedInputs(NetworkId networkId, const std::vector<ImportedInputId> inputIds)
93{
94 return pRuntimeImpl->ClearImportedInputs(networkId, inputIds);
95}
96void IRuntime::ClearImportedOutputs(NetworkId networkId, const std::vector<ImportedOutputId> outputIds)
97{
98 return pRuntimeImpl->ClearImportedOutputs(networkId, outputIds);
99}
Finn Williamsf37b9702021-09-01 18:06:04 +0100100
Kevin Mayd92a6e42021-02-04 10:27:41 +0000101Status IRuntime::EnqueueWorkload(NetworkId networkId,
102 const InputTensors& inputTensors,
Narumol Prangnawarate2af6f42022-01-28 17:59:18 +0000103 const OutputTensors& outputTensors,
104 std::vector<ImportedInputId> preImportedInputIds,
105 std::vector<ImportedOutputId> preImportedOutputIds)
Kevin Mayd92a6e42021-02-04 10:27:41 +0000106{
Narumol Prangnawarate2af6f42022-01-28 17:59:18 +0000107 return pRuntimeImpl->EnqueueWorkload(networkId, inputTensors, outputTensors,
108 preImportedInputIds, preImportedOutputIds);
Kevin Mayd92a6e42021-02-04 10:27:41 +0000109}
110
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100111Status IRuntime::Execute(IWorkingMemHandle& workingMemHandle,
112 const InputTensors& inputTensors,
Finn Williamsf37b9702021-09-01 18:06:04 +0100113 const OutputTensors& outputTensors,
Finn Williams8636bc72021-10-02 15:06:39 +0100114 std::vector<ImportedInputId> preImportedInputs,
115 std::vector<ImportedOutputId> preImportedOutputs)
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100116{
Finn Williams8636bc72021-10-02 15:06:39 +0100117 return pRuntimeImpl->Execute(workingMemHandle, inputTensors, outputTensors, preImportedInputs, preImportedOutputs);
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100118}
119
Kevin Mayd92a6e42021-02-04 10:27:41 +0000120Status IRuntime::UnloadNetwork(NetworkId networkId)
121{
122 return pRuntimeImpl->UnloadNetwork(networkId);
123}
124
125const IDeviceSpec& IRuntime::GetDeviceSpec() const
126{
127 return pRuntimeImpl->GetDeviceSpec();
128}
129
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100130std::unique_ptr<IWorkingMemHandle> IRuntime::CreateWorkingMemHandle(NetworkId networkId)
131{
132 return pRuntimeImpl->CreateWorkingMemHandle(networkId);
133}
134
Kevin Mayd92a6e42021-02-04 10:27:41 +0000135const std::shared_ptr<IProfiler> IRuntime::GetProfiler(NetworkId networkId) const
136{
137 return pRuntimeImpl->GetProfiler(networkId);
138}
139
140void IRuntime::RegisterDebugCallback(NetworkId networkId, const DebugCallbackFunction& func)
141{
142 return pRuntimeImpl->RegisterDebugCallback(networkId, func);
143}
144
145int RuntimeImpl::GenerateNetworkId()
telsoa014fcda012018-03-09 14:13:49 +0000146{
147 return m_NetworkIdCounter++;
148}
149
Kevin Mayd92a6e42021-02-04 10:27:41 +0000150Status RuntimeImpl::LoadNetwork(NetworkId& networkIdOut, IOptimizedNetworkPtr inNetwork)
telsoa014fcda012018-03-09 14:13:49 +0000151{
telsoa01c577f2c2018-08-31 09:22:23 +0100152 std::string ignoredErrorMessage;
153 return LoadNetwork(networkIdOut, std::move(inNetwork), ignoredErrorMessage);
154}
155
Kevin Mayd92a6e42021-02-04 10:27:41 +0000156Status RuntimeImpl::LoadNetwork(NetworkId& networkIdOut,
157 IOptimizedNetworkPtr inNetwork,
158 std::string& errorMessage)
David Monahan4f1e8e42019-09-04 09:22:10 +0100159{
Jan Eilersc1c872f2021-07-22 13:17:04 +0100160 INetworkProperties networkProperties(
161 false, MemorySource::Undefined, MemorySource::Undefined);
David Monahan4f1e8e42019-09-04 09:22:10 +0100162 return LoadNetwork(networkIdOut, std::move(inNetwork), errorMessage, networkProperties);
163}
164
Kevin Mayd92a6e42021-02-04 10:27:41 +0000165Status RuntimeImpl::LoadNetwork(NetworkId& networkIdOut,
166 IOptimizedNetworkPtr inNetwork,
167 std::string& errorMessage,
168 const INetworkProperties& networkProperties)
telsoa01c577f2c2018-08-31 09:22:23 +0100169{
Derek Lambertie155bbf2021-10-13 14:32:12 +0100170 // Register the profiler
171 auto profiler = inNetwork->GetProfiler();
172 ProfilerManager::GetInstance().RegisterProfiler(profiler.get());
173
telsoa014fcda012018-03-09 14:13:49 +0000174 IOptimizedNetwork* rawNetwork = inNetwork.release();
David Beck1b61be52018-11-08 09:19:14 +0000175
176 networkIdOut = GenerateNetworkId();
177
178 for (auto&& context : m_BackendContexts)
179 {
180 context.second->BeforeLoadNetwork(networkIdOut);
181 }
182
telsoa014fcda012018-03-09 14:13:49 +0000183 unique_ptr<LoadedNetwork> loadedNetwork = LoadedNetwork::MakeLoadedNetwork(
Francis Murtagh3d2b4b22021-02-15 18:23:17 +0000184 std::unique_ptr<IOptimizedNetwork>(rawNetwork),
David Monahan4f1e8e42019-09-04 09:22:10 +0100185 errorMessage,
Sadik Armagan3184c902020-03-18 10:57:30 +0000186 networkProperties,
Finn Williamsf364d532021-06-09 17:07:33 +0100187 m_ProfilingService);
telsoa014fcda012018-03-09 14:13:49 +0000188
189 if (!loadedNetwork)
190 {
191 return Status::Failure;
192 }
193
telsoa01c577f2c2018-08-31 09:22:23 +0100194 {
195 std::lock_guard<std::mutex> lockGuard(m_Mutex);
196
197 // Stores the network
198 m_LoadedNetworks[networkIdOut] = std::move(loadedNetwork);
199 }
telsoa014fcda012018-03-09 14:13:49 +0000200
David Beck1b61be52018-11-08 09:19:14 +0000201 for (auto&& context : m_BackendContexts)
202 {
203 context.second->AfterLoadNetwork(networkIdOut);
204 }
205
Sadik Armagan3184c902020-03-18 10:57:30 +0000206 if (m_ProfilingService.IsProfilingEnabled())
Keith Davise394bd92019-12-02 15:12:19 +0000207 {
Sadik Armagan3184c902020-03-18 10:57:30 +0000208 m_ProfilingService.IncrementCounterValue(armnn::profiling::NETWORK_LOADS);
Keith Davise394bd92019-12-02 15:12:19 +0000209 }
210
telsoa014fcda012018-03-09 14:13:49 +0000211 return Status::Success;
telsoa014fcda012018-03-09 14:13:49 +0000212}
213
Kevin Mayd92a6e42021-02-04 10:27:41 +0000214Status RuntimeImpl::UnloadNetwork(NetworkId networkId)
telsoa014fcda012018-03-09 14:13:49 +0000215{
David Beck1b61be52018-11-08 09:19:14 +0000216 bool unloadOk = true;
217 for (auto&& context : m_BackendContexts)
David Beck9efb57d2018-11-05 13:40:33 +0000218 {
David Beck1b61be52018-11-08 09:19:14 +0000219 unloadOk &= context.second->BeforeUnloadNetwork(networkId);
David Beck9efb57d2018-11-05 13:40:33 +0000220 }
David Beck1b61be52018-11-08 09:19:14 +0000221
222 if (!unloadOk)
223 {
Kevin Mayd92a6e42021-02-04 10:27:41 +0000224 ARMNN_LOG(warning) << "RuntimeImpl::UnloadNetwork(): failed to unload "
Derek Lamberti08446972019-11-26 16:38:31 +0000225 "network with ID:" << networkId << " because BeforeUnloadNetwork failed";
David Beck1b61be52018-11-08 09:19:14 +0000226 return Status::Failure;
227 }
David Beck9efb57d2018-11-05 13:40:33 +0000228
Jim Flynnf7713212020-07-14 09:50:59 +0100229 std::unique_ptr<profiling::TimelineUtilityMethods> timelineUtils =
230 profiling::TimelineUtilityMethods::GetTimelineUtils(m_ProfilingService);
telsoa014fcda012018-03-09 14:13:49 +0000231 {
telsoa01c577f2c2018-08-31 09:22:23 +0100232 std::lock_guard<std::mutex> lockGuard(m_Mutex);
233
Jim Flynnf7713212020-07-14 09:50:59 +0100234 // If timeline recording is on mark the Network end of life
235 if (timelineUtils)
236 {
237 auto search = m_LoadedNetworks.find(networkId);
238 if (search != m_LoadedNetworks.end())
239 {
240 profiling::ProfilingGuid networkGuid = search->second->GetNetworkGuid();
241 timelineUtils->RecordEvent(networkGuid,
242 profiling::LabelsAndEventClasses::ARMNN_PROFILING_EOL_EVENT_CLASS);
243 }
244 }
telsoa01c577f2c2018-08-31 09:22:23 +0100245 if (m_LoadedNetworks.erase(networkId) == 0)
246 {
Kevin Mayd92a6e42021-02-04 10:27:41 +0000247 ARMNN_LOG(warning) << "WARNING: RuntimeImpl::UnloadNetwork(): " << networkId << " not found!";
telsoa01c577f2c2018-08-31 09:22:23 +0100248 return Status::Failure;
249 }
Sadik Armagan3184c902020-03-18 10:57:30 +0000250
251 if (m_ProfilingService.IsProfilingEnabled())
Keith Davise394bd92019-12-02 15:12:19 +0000252 {
Sadik Armagan3184c902020-03-18 10:57:30 +0000253 m_ProfilingService.IncrementCounterValue(armnn::profiling::NETWORK_UNLOADS);
Keith Davise394bd92019-12-02 15:12:19 +0000254 }
David Beck1b61be52018-11-08 09:19:14 +0000255 }
David Beck9efb57d2018-11-05 13:40:33 +0000256
David Beck1b61be52018-11-08 09:19:14 +0000257 for (auto&& context : m_BackendContexts)
258 {
259 context.second->AfterUnloadNetwork(networkId);
telsoa01c577f2c2018-08-31 09:22:23 +0100260 }
261
Derek Lambertie155bbf2021-10-13 14:32:12 +0100262 // Unregister the profiler
263 ProfilerManager::GetInstance().RegisterProfiler(nullptr);
264
Kevin Mayd92a6e42021-02-04 10:27:41 +0000265 ARMNN_LOG(debug) << "RuntimeImpl::UnloadNetwork(): Unloaded network with ID: " << networkId;
telsoa014fcda012018-03-09 14:13:49 +0000266 return Status::Success;
267}
268
Kevin Mayd92a6e42021-02-04 10:27:41 +0000269const std::shared_ptr<IProfiler> RuntimeImpl::GetProfiler(NetworkId networkId) const
telsoa01c577f2c2018-08-31 09:22:23 +0100270{
271 auto it = m_LoadedNetworks.find(networkId);
272 if (it != m_LoadedNetworks.end())
273 {
274 auto& loadedNetwork = it->second;
275 return loadedNetwork->GetProfiler();
276 }
277
278 return nullptr;
279}
280
Kevin Mayd92a6e42021-02-04 10:27:41 +0000281void RuntimeImpl::ReportStructure() // armnn::profiling::IProfilingService& profilingService as param
Keith Davis33ed2212020-03-30 10:43:41 +0100282{
283 // No-op for the time being, but this may be useful in future to have the profilingService available
284 // if (profilingService.IsProfilingEnabled()){}
285
286 LoadedNetworks::iterator it = m_LoadedNetworks.begin();
287 while (it != m_LoadedNetworks.end())
288 {
289 auto& loadedNetwork = it->second;
290 loadedNetwork->SendNetworkStructure();
291 // Increment the Iterator to point to next entry
292 it++;
293 }
294}
295
Kevin Mayd92a6e42021-02-04 10:27:41 +0000296RuntimeImpl::RuntimeImpl(const IRuntime::CreationOptions& options)
Keith Davis33ed2212020-03-30 10:43:41 +0100297 : m_NetworkIdCounter(0),
298 m_ProfilingService(*this)
telsoa014fcda012018-03-09 14:13:49 +0000299{
alered01a7227ac2020-05-07 14:58:29 +0100300 const auto start_time = armnn::GetTimeNow();
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000301 ARMNN_LOG(info) << "ArmNN v" << ARMNN_VERSION;
Keith Davis33ed2212020-03-30 10:43:41 +0100302 if ( options.m_ProfilingOptions.m_TimelineEnabled && !options.m_ProfilingOptions.m_EnableProfiling )
303 {
Jan Eilersc1c872f2021-07-22 13:17:04 +0100304 throw RuntimeException(
305 "It is not possible to enable timeline reporting without profiling being enabled");
Keith Davis33ed2212020-03-30 10:43:41 +0100306 }
307
Matteo Martincighe54aa062019-08-05 14:12:11 +0100308 // Load any available/compatible dynamic backend before the runtime
309 // goes through the backend registry
310 LoadDynamicBackends(options.m_DynamicBackendsPath);
311
Matthew Bentham9a61fa62020-02-04 10:03:55 +0000312 BackendIdSet supportedBackends;
David Beck1b61be52018-11-08 09:19:14 +0000313 for (const auto& id : BackendRegistryInstance().GetBackendIds())
314 {
315 // Store backend contexts for the supported ones
Matthew Bentham9a61fa62020-02-04 10:03:55 +0000316 try {
David Beck1b61be52018-11-08 09:19:14 +0000317 auto factoryFun = BackendRegistryInstance().GetFactory(id);
Colm Donelan380c1a02021-08-17 00:52:23 +0100318 ARMNN_ASSERT(factoryFun != nullptr);
David Beck1b61be52018-11-08 09:19:14 +0000319 auto backend = factoryFun();
Colm Donelan380c1a02021-08-17 00:52:23 +0100320 ARMNN_ASSERT(backend != nullptr);
Narumol Prangnawaratac2770a2020-04-01 16:51:23 +0100321 ARMNN_ASSERT(backend.get() != nullptr);
David Beck1b61be52018-11-08 09:19:14 +0000322
Jan Eilersc1c872f2021-07-22 13:17:04 +0100323 auto customAllocatorMapIterator = options.m_CustomAllocatorMap.find(id);
Francis Murtagh62573b62021-08-12 11:55:21 +0100324 if (customAllocatorMapIterator != options.m_CustomAllocatorMap.end() &&
325 customAllocatorMapIterator->second == nullptr)
326 {
Colm Donelan380c1a02021-08-17 00:52:23 +0100327 // We need to manually clean up the dynamic backends before throwing an exception.
328 DynamicBackendUtils::DeregisterDynamicBackends(m_DeviceSpec.GetDynamicBackends());
329 m_DeviceSpec.ClearDynamicBackends();
Francis Murtagh62573b62021-08-12 11:55:21 +0100330 throw armnn::Exception("Allocator associated with id " + id.Get() + " is null");
331 }
Jan Eilersc1c872f2021-07-22 13:17:04 +0100332
Jan Eilers15fcc7e2021-07-14 13:50:15 +0100333 // If the runtime is created in protected mode only add backends that support this mode
334 if (options.m_ProtectedMode)
335 {
336 // check if backend supports ProtectedMode
337 using BackendCapability = BackendOptions::BackendOption;
338 BackendCapability protectedContentCapability {"ProtectedContentAllocation", true};
339 if (!HasCapability(protectedContentCapability, id))
340 {
341 // Protected Content Allocation is not supported by the backend
342 // backend should not be registered
343 ARMNN_LOG(warning) << "Backend "
344 << id
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000345 << " is not registered as does not support protected content allocation.";
Jan Eilers15fcc7e2021-07-14 13:50:15 +0100346 continue;
347 }
Jan Eilersc1c872f2021-07-22 13:17:04 +0100348 // The user is responsible to provide a custom memory allocator which allows to allocate
349 // protected memory
350 if (customAllocatorMapIterator != options.m_CustomAllocatorMap.end())
Jan Eilers15fcc7e2021-07-14 13:50:15 +0100351 {
Jan Eilersc1c872f2021-07-22 13:17:04 +0100352 std::string err;
353 if (customAllocatorMapIterator->second->GetMemorySourceType()
354 == armnn::MemorySource::DmaBufProtected)
355 {
356 if (!backend->UseCustomMemoryAllocator(customAllocatorMapIterator->second, err))
357 {
358 ARMNN_LOG(error) << "The backend "
359 << id
360 << " reported an error when entering protected mode. Backend won't be"
361 << " used. ErrorMsg: " << err;
362 continue;
363 }
364 // No errors so register the Custom Allocator with the BackendRegistry
365 BackendRegistryInstance().RegisterAllocator(id, customAllocatorMapIterator->second);
366 }
367 else
368 {
369 ARMNN_LOG(error) << "The CustomAllocator provided with the runtime options doesn't support "
370 "protected memory. Protected mode can't be activated. The backend "
Jan Eilers15fcc7e2021-07-14 13:50:15 +0100371 << id
Jan Eilersc1c872f2021-07-22 13:17:04 +0100372 << " is not going to be used. MemorySource must be MemorySource::DmaBufProtected";
373 continue;
374 }
375 }
376 else
377 {
378 ARMNN_LOG(error) << "Protected mode can't be activated for backend: "
379 << id
380 << " no custom allocator was provided to the runtime options.";
Jan Eilers15fcc7e2021-07-14 13:50:15 +0100381 continue;
382 }
383 }
Jan Eilersc1c872f2021-07-22 13:17:04 +0100384 else
385 {
386 // If a custom memory allocator is provided make the backend use that instead of the default
387 if (customAllocatorMapIterator != options.m_CustomAllocatorMap.end())
388 {
389 std::string err;
390 if (!backend->UseCustomMemoryAllocator(customAllocatorMapIterator->second, err))
391 {
392 ARMNN_LOG(error) << "The backend "
393 << id
394 << " reported an error when trying to use the provided custom allocator."
395 " Backend won't be used."
396 << " ErrorMsg: " << err;
397 continue;
398 }
399 // No errors so register the Custom Allocator with the BackendRegistry
400 BackendRegistryInstance().RegisterAllocator(id, customAllocatorMapIterator->second);
401 }
402 }
Sadik Armaganb8a26d82021-10-04 15:13:11 +0100403
404 // check if custom memory optimizer strategy map is set
405 if (!options.m_MemoryOptimizerStrategyMap.empty())
406 {
407 auto customMemoryOptimizerStrategyMapIterator = options.m_MemoryOptimizerStrategyMap.find(id);
408 // if a memory optimizer strategy is provided make the backend use that instead of the default
409 if (customMemoryOptimizerStrategyMapIterator != options.m_MemoryOptimizerStrategyMap.end())
410 {
411 // no errors.. register the memory optimizer strategy with the BackendRegistry
412 BackendRegistryInstance().RegisterMemoryOptimizerStrategy(
413 id, customMemoryOptimizerStrategyMapIterator->second);
414
415 ARMNN_LOG(info) << "MemoryOptimizerStrategy "
416 << customMemoryOptimizerStrategyMapIterator->second->GetName()
417 << " set for the backend " << id << ".";
418 }
419 }
420 else
421 {
422 // check if to use one of the existing memory optimizer strategies is set
423 std::string memoryOptimizerStrategyName = "";
424 ParseOptions(options.m_BackendOptions, id, [&](std::string name, const BackendOptions::Var& value)
425 {
426 if (name == "MemoryOptimizerStrategy")
427 {
428 memoryOptimizerStrategyName = ParseStringBackendOption(value, "");
429 }
430 });
431 if (memoryOptimizerStrategyName != "")
432 {
Jim Flynne1fdd282021-10-26 21:26:10 +0100433 std::shared_ptr<IMemoryOptimizerStrategy> strategy =
434 GetMemoryOptimizerStrategy(memoryOptimizerStrategyName);
435
436 if (!strategy)
Sadik Armaganb8a26d82021-10-04 15:13:11 +0100437 {
Jim Flynne1fdd282021-10-26 21:26:10 +0100438 ARMNN_LOG(warning) << "MemoryOptimizerStrategy: " << memoryOptimizerStrategyName
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000439 << " was not found.";
Jim Flynne1fdd282021-10-26 21:26:10 +0100440 }
441 else
442 {
443 using BackendCapability = BackendOptions::BackendOption;
444 auto strategyType = GetMemBlockStrategyTypeName(strategy->GetMemBlockStrategyType());
445 BackendCapability memOptimizeStrategyCapability {strategyType, true};
446 if (HasCapability(memOptimizeStrategyCapability, id))
447 {
448 BackendRegistryInstance().RegisterMemoryOptimizerStrategy(id, strategy);
449
450 ARMNN_LOG(info) << "MemoryOptimizerStrategy: "
451 << memoryOptimizerStrategyName << " set for the backend " << id << ".";
452 }
453 else
454 {
455 ARMNN_LOG(warning) << "Backend "
456 << id
457 << " does not have multi-axis packing capability and cannot support"
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000458 << "MemoryOptimizerStrategy: " << memoryOptimizerStrategyName << ".";
Jim Flynne1fdd282021-10-26 21:26:10 +0100459 }
Sadik Armaganb8a26d82021-10-04 15:13:11 +0100460 }
461 }
462 }
463
David Beck1b61be52018-11-08 09:19:14 +0000464 auto context = backend->CreateBackendContext(options);
465
466 // backends are allowed to return nullptrs if they
467 // don't wish to create a backend specific context
468 if (context)
469 {
470 m_BackendContexts.emplace(std::make_pair(id, std::move(context)));
471 }
Matthew Bentham9a61fa62020-02-04 10:03:55 +0000472 supportedBackends.emplace(id);
Colm Donelan1aff3932020-02-05 17:48:59 +0000473
474 unique_ptr<armnn::profiling::IBackendProfiling> profilingIface =
475 std::make_unique<armnn::profiling::BackendProfiling>(armnn::profiling::BackendProfiling(
Sadik Armagan3184c902020-03-18 10:57:30 +0000476 options, m_ProfilingService, id));
Colm Donelan1aff3932020-02-05 17:48:59 +0000477
478 // Backends may also provide a profiling context. Ask for it now.
479 auto profilingContext = backend->CreateBackendProfilingContext(options, profilingIface);
480 // Backends that don't support profiling will return a null profiling context.
481 if (profilingContext)
482 {
Finn Williamsfe5a24b2020-04-09 16:05:28 +0100483 // Pass the context onto the profiling service.
484 m_ProfilingService.AddBackendProfilingContext(id, profilingContext);
Colm Donelan1aff3932020-02-05 17:48:59 +0000485 }
David Beck1b61be52018-11-08 09:19:14 +0000486 }
Matthew Bentham9a61fa62020-02-04 10:03:55 +0000487 catch (const BackendUnavailableException&)
488 {
489 // Ignore backends which are unavailable
490 }
David Beck1b61be52018-11-08 09:19:14 +0000491 }
Finn Williamsfe5a24b2020-04-09 16:05:28 +0100492
Finn Williams45a73622020-05-15 18:41:05 +0100493 BackendRegistryInstance().SetProfilingService(m_ProfilingService);
Finn Williamsfe5a24b2020-04-09 16:05:28 +0100494 // pass configuration info to the profiling service
495 m_ProfilingService.ConfigureProfilingService(options.m_ProfilingOptions);
Jim Flynn6398a982020-05-27 17:05:21 +0100496 if (options.m_ProfilingOptions.m_EnableProfiling)
497 {
498 // try to wait for the profiling service to initialise
499 m_ProfilingService.WaitForProfilingServiceActivation(3000);
500 }
Finn Williamsfe5a24b2020-04-09 16:05:28 +0100501
Matthew Bentham9a61fa62020-02-04 10:03:55 +0000502 m_DeviceSpec.AddSupportedBackends(supportedBackends);
alered01a7227ac2020-05-07 14:58:29 +0100503
504 ARMNN_LOG(info) << "Initialization time: " << std::setprecision(2)
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000505 << std::fixed << armnn::GetTimeDuration(start_time).count() << " ms.";
surmeh01bceff2f2018-03-29 16:29:27 +0100506}
507
Kevin Mayd92a6e42021-02-04 10:27:41 +0000508RuntimeImpl::~RuntimeImpl()
surmeh01bceff2f2018-03-29 16:29:27 +0100509{
Jan Eilers17d34da2021-12-08 16:15:12 +0000510 const auto startTime = armnn::GetTimeNow();
surmeh01bceff2f2018-03-29 16:29:27 +0100511 std::vector<int> networkIDs;
surmeh013537c2c2018-05-18 16:31:43 +0100512 try
513 {
514 // Coverity fix: The following code may throw an exception of type std::length_error.
515 std::transform(m_LoadedNetworks.begin(), m_LoadedNetworks.end(),
516 std::back_inserter(networkIDs),
517 [](const auto &pair) { return pair.first; });
518 }
519 catch (const std::exception& e)
520 {
521 // Coverity fix: BOOST_LOG_TRIVIAL (typically used to report errors) may throw an
522 // exception of type std::length_error.
523 // Using stderr instead in this context as there is no point in nesting try-catch blocks here.
524 std::cerr << "WARNING: An error has occurred when getting the IDs of the networks to unload: " << e.what()
525 << "\nSome of the loaded networks may not be unloaded" << std::endl;
526 }
527 // We then proceed to unload all the networks which IDs have been appended to the list
528 // up to the point the exception was thrown (if any).
surmeh01bceff2f2018-03-29 16:29:27 +0100529
530 for (auto networkID : networkIDs)
531 {
surmeh013537c2c2018-05-18 16:31:43 +0100532 try
533 {
534 // Coverity fix: UnloadNetwork() may throw an exception of type std::length_error,
535 // boost::log::v2s_mt_posix::odr_violation or boost::log::v2s_mt_posix::system_error
536 UnloadNetwork(networkID);
537 }
538 catch (const std::exception& e)
539 {
540 // Coverity fix: BOOST_LOG_TRIVIAL (typically used to report errors) may throw an
541 // exception of type std::length_error.
542 // Using stderr instead in this context as there is no point in nesting try-catch blocks here.
543 std::cerr << "WARNING: An error has occurred when unloading network " << networkID << ": " << e.what()
544 << std::endl;
545 }
telsoa014fcda012018-03-09 14:13:49 +0000546 }
Narumol Prangnawarat60a20fb2019-12-09 17:24:41 +0000547
548 // Clear all dynamic backends.
549 DynamicBackendUtils::DeregisterDynamicBackends(m_DeviceSpec.GetDynamicBackends());
550 m_DeviceSpec.ClearDynamicBackends();
Colm Donelan1aff3932020-02-05 17:48:59 +0000551 m_BackendContexts.clear();
Finn Williams45a73622020-05-15 18:41:05 +0100552
553 BackendRegistryInstance().SetProfilingService(armnn::EmptyOptional());
alered01a7227ac2020-05-07 14:58:29 +0100554 ARMNN_LOG(info) << "Shutdown time: " << std::setprecision(2)
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000555 << std::fixed << armnn::GetTimeDuration(startTime).count() << " ms.";
telsoa014fcda012018-03-09 14:13:49 +0000556}
557
Kevin Mayd92a6e42021-02-04 10:27:41 +0000558LoadedNetwork* RuntimeImpl::GetLoadedNetworkPtr(NetworkId networkId) const
surmeh013537c2c2018-05-18 16:31:43 +0100559{
560 std::lock_guard<std::mutex> lockGuard(m_Mutex);
561 return m_LoadedNetworks.at(networkId).get();
562}
563
Kevin Mayd92a6e42021-02-04 10:27:41 +0000564TensorInfo RuntimeImpl::GetInputTensorInfo(NetworkId networkId, LayerBindingId layerId) const
telsoa014fcda012018-03-09 14:13:49 +0000565{
surmeh013537c2c2018-05-18 16:31:43 +0100566 return GetLoadedNetworkPtr(networkId)->GetInputTensorInfo(layerId);
telsoa014fcda012018-03-09 14:13:49 +0000567}
568
Kevin Mayd92a6e42021-02-04 10:27:41 +0000569TensorInfo RuntimeImpl::GetOutputTensorInfo(NetworkId networkId, LayerBindingId layerId) const
telsoa014fcda012018-03-09 14:13:49 +0000570{
surmeh013537c2c2018-05-18 16:31:43 +0100571 return GetLoadedNetworkPtr(networkId)->GetOutputTensorInfo(layerId);
telsoa014fcda012018-03-09 14:13:49 +0000572}
573
Narumol Prangnawarate2af6f42022-01-28 17:59:18 +0000574std::vector<ImportedInputId> RuntimeImpl::ImportInputs(NetworkId networkId, const InputTensors& inputTensors,
575 MemorySource forceImportMemorySource)
Finn Williamsf37b9702021-09-01 18:06:04 +0100576{
Narumol Prangnawarate2af6f42022-01-28 17:59:18 +0000577 return GetLoadedNetworkPtr(networkId)->ImportInputs(inputTensors, forceImportMemorySource);
Finn Williamsf37b9702021-09-01 18:06:04 +0100578}
579
Narumol Prangnawarate2af6f42022-01-28 17:59:18 +0000580std::vector<ImportedOutputId> RuntimeImpl::ImportOutputs(NetworkId networkId, const OutputTensors& outputTensors,
581 MemorySource forceImportMemorySource)
Finn Williams8636bc72021-10-02 15:06:39 +0100582{
Narumol Prangnawarate2af6f42022-01-28 17:59:18 +0000583 return GetLoadedNetworkPtr(networkId)->ImportOutputs(outputTensors, forceImportMemorySource);
Finn Williams8636bc72021-10-02 15:06:39 +0100584}
Finn Williamsf37b9702021-09-01 18:06:04 +0100585
Finn Williams8636bc72021-10-02 15:06:39 +0100586void RuntimeImpl::ClearImportedInputs(NetworkId networkId, const std::vector<ImportedInputId> inputIds)
587{
588 return GetLoadedNetworkPtr(networkId)->ClearImportedInputs(inputIds);
589}
590void RuntimeImpl::ClearImportedOutputs(NetworkId networkId, const std::vector<ImportedOutputId> outputIds)
591{
592 return GetLoadedNetworkPtr(networkId)->ClearImportedOutputs(outputIds);
593}
Derek Lamberti03614f62018-10-02 15:52:46 +0100594
Kevin Mayd92a6e42021-02-04 10:27:41 +0000595Status RuntimeImpl::EnqueueWorkload(NetworkId networkId,
telsoa01c577f2c2018-08-31 09:22:23 +0100596 const InputTensors& inputTensors,
Narumol Prangnawarate2af6f42022-01-28 17:59:18 +0000597 const OutputTensors& outputTensors,
598 std::vector<ImportedInputId> preImportedInputIds,
599 std::vector<ImportedOutputId> preImportedOutputIds)
telsoa014fcda012018-03-09 14:13:49 +0000600{
Jan Eilers17d34da2021-12-08 16:15:12 +0000601 const auto startTime = armnn::GetTimeNow();
602
surmeh013537c2c2018-05-18 16:31:43 +0100603 LoadedNetwork* loadedNetwork = GetLoadedNetworkPtr(networkId);
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100604
605 if (!loadedNetwork)
606 {
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000607 ARMNN_LOG(error) << "A Network with an id of " << networkId << " does not exist.";
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100608 return Status::Failure;
609 }
610 if (loadedNetwork->IsAsyncEnabled())
611 {
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000612 ARMNN_LOG(error) << "Network " << networkId << " is async enabled.";
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100613 return Status::Failure;
614 }
Narumol Prangnawarat5b4d0d52020-06-23 11:45:56 +0100615 ProfilerManager::GetInstance().RegisterProfiler(loadedNetwork->GetProfiler().get());
616
617 ARMNN_SCOPED_PROFILING_EVENT(Compute::Undefined, "EnqueueWorkload");
Derek Lamberti03614f62018-10-02 15:52:46 +0100618
619 static thread_local NetworkId lastId = networkId;
620 if (lastId != networkId)
621 {
622 LoadedNetworkFuncSafe(lastId, [](LoadedNetwork* network)
623 {
624 network->FreeWorkingMemory();
625 });
626 }
627 lastId=networkId;
628
Narumol Prangnawarate2af6f42022-01-28 17:59:18 +0000629 auto status = loadedNetwork->EnqueueWorkload(inputTensors, outputTensors,
630 preImportedInputIds, preImportedOutputIds);
Jan Eilers17d34da2021-12-08 16:15:12 +0000631
632 ARMNN_LOG(info) << "Execution time: " << std::setprecision(2)
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000633 << std::fixed << armnn::GetTimeDuration(startTime).count() << " ms.";
Jan Eilers17d34da2021-12-08 16:15:12 +0000634
635 return status;
telsoa014fcda012018-03-09 14:13:49 +0000636}
637
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100638Status RuntimeImpl::Execute(IWorkingMemHandle& iWorkingMemHandle,
639 const InputTensors& inputTensors,
Finn Williamsf37b9702021-09-01 18:06:04 +0100640 const OutputTensors& outputTensors,
Finn Williams8636bc72021-10-02 15:06:39 +0100641 std::vector<ImportedInputId> preImportedInputs,
642 std::vector<ImportedOutputId> preImportedOutputs)
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100643{
Jan Eilers17d34da2021-12-08 16:15:12 +0000644 const auto startTime = armnn::GetTimeNow();
645
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100646 NetworkId networkId = iWorkingMemHandle.GetNetworkId();
647 LoadedNetwork* loadedNetwork = GetLoadedNetworkPtr(networkId);
648
649 if (!loadedNetwork)
650 {
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000651 ARMNN_LOG(error) << "A Network with an id of " << networkId << " does not exist.";
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100652 return Status::Failure;
653 }
654 if (!loadedNetwork->IsAsyncEnabled())
655 {
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000656 ARMNN_LOG(error) << "Attempting execute " << networkId << " when it is not async enabled.";
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100657 return Status::Failure;
658 }
659 ProfilerManager::GetInstance().RegisterProfiler(loadedNetwork->GetProfiler().get());
660
661 ARMNN_SCOPED_PROFILING_EVENT(Compute::Undefined, "Execute");
662
Jan Eilers17d34da2021-12-08 16:15:12 +0000663 auto status = loadedNetwork->Execute(inputTensors,
664 outputTensors,
665 iWorkingMemHandle,
666 preImportedInputs,
667 preImportedOutputs);
668
669 ARMNN_LOG(info) << "Execution time: " << std::setprecision(2)
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000670 << std::fixed << armnn::GetTimeDuration(startTime).count() << " ms.";
Jan Eilers17d34da2021-12-08 16:15:12 +0000671
672 return status;
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100673}
674
675/// Create a new unique WorkingMemHandle object. Create multiple handles if you wish to have
676/// overlapped Execution by calling this function from different threads.
677std::unique_ptr<IWorkingMemHandle> RuntimeImpl::CreateWorkingMemHandle(NetworkId networkId)
678{
679 LoadedNetwork* loadedNetwork = GetLoadedNetworkPtr(networkId);
680
681 if (!loadedNetwork)
682 {
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000683 ARMNN_LOG(error) << "A Network with an id of " << networkId << " does not exist.";
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100684 return nullptr;
685 }
686 if (!loadedNetwork->IsAsyncEnabled())
687 {
Sadik Armagan4a0844d2022-01-26 09:57:05 +0000688 ARMNN_LOG(error) << "Network " << networkId << " is not async enabled.";
Mike Kelly55a8ffd2021-04-07 20:10:49 +0100689 return nullptr;
690 }
691 ProfilerManager::GetInstance().RegisterProfiler(loadedNetwork->GetProfiler().get());
692
693 ARMNN_SCOPED_PROFILING_EVENT(Compute::Undefined, "CreateWorkingMemHandle");
694
695 static thread_local NetworkId lastId = networkId;
696 if (lastId != networkId)
697 {
698 LoadedNetworkFuncSafe(lastId, [](LoadedNetwork* network)
699 {
700 network->FreeWorkingMemory();
701 });
702 }
703 lastId=networkId;
704
705 return loadedNetwork->CreateWorkingMemHandle(networkId);
706}
707
Kevin Mayd92a6e42021-02-04 10:27:41 +0000708void RuntimeImpl::RegisterDebugCallback(NetworkId networkId, const DebugCallbackFunction& func)
Nattapat Chaimanowong6e948202019-03-22 14:01:46 +0000709{
710 LoadedNetwork* loadedNetwork = GetLoadedNetworkPtr(networkId);
711 loadedNetwork->RegisterDebugCallback(func);
712}
713
Kevin Mayd92a6e42021-02-04 10:27:41 +0000714void RuntimeImpl::LoadDynamicBackends(const std::string& overrideBackendPath)
Matteo Martincighe54aa062019-08-05 14:12:11 +0100715{
716 // Get the paths where to load the dynamic backends from
717 std::vector<std::string> backendPaths = DynamicBackendUtils::GetBackendPaths(overrideBackendPath);
718
719 // Get the shared objects to try to load as dynamic backends
720 std::vector<std::string> sharedObjects = DynamicBackendUtils::GetSharedObjects(backendPaths);
721
722 // Create a list of dynamic backends
Matteo Martincigh0c2b2892019-08-05 14:12:11 +0100723 m_DynamicBackends = DynamicBackendUtils::CreateDynamicBackends(sharedObjects);
724
725 // Register the dynamic backends in the backend registry
Matteo Martincigh89533902019-08-15 12:08:06 +0100726 BackendIdSet registeredBackendIds = DynamicBackendUtils::RegisterDynamicBackends(m_DynamicBackends);
727
728 // Add the registered dynamic backend ids to the list of supported backends
Narumol Prangnawarat60a20fb2019-12-09 17:24:41 +0000729 m_DeviceSpec.AddSupportedBackends(registeredBackendIds, true);
telsoa014fcda012018-03-09 14:13:49 +0000730}
Matteo Martincighe54aa062019-08-05 14:12:11 +0100731
732} // namespace armnn