nx_metadata_sdk  1.0
Metadata SDK
engine.h
1 // Copyright 2018-present Network Optix, Inc. Licensed under MPL 2.0: www.mozilla.org/MPL/2.0/
2 
3 #pragma once
4 
5 #include <atomic>
6 #include <thread>
7 #include <memory>
8 #include <mutex>
9 #include <condition_variable>
10 
11 #include <nx/sdk/uuid.h>
12 #include <nx/sdk/analytics/helpers/plugin.h>
13 #include <nx/sdk/analytics/helpers/engine.h>
14 #include <nx/sdk/analytics/i_uncompressed_video_frame.h>
15 
16 namespace nx {
17 namespace vms_server_plugins {
18 namespace analytics {
19 namespace stub {
20 namespace diagnostic_events {
21 
22 const std::string kThrowPluginDiagnosticEventsFromEngineSetting =
23  "throwPluginDiagnosticEventsFromEngine";
24 
26 {
27 public:
29  virtual ~Engine() override;
30 
31 protected:
32  virtual std::string manifestString() const override;
33 
35 
36 protected:
37  virtual void doObtainDeviceAgent(
39  const nx::sdk::IDeviceInfo* deviceInfo) override;
40 
41 private:
42  void generatePluginDiagnosticEvents();
43 
44 private:
45  nx::sdk::analytics::Plugin* const m_plugin;
46 
47  mutable std::mutex m_pluginDiagnosticEventGenerationLoopMutex;
48  mutable std::condition_variable m_pluginDiagnosticEventGenerationLoopCondition;
49  std::unique_ptr<std::thread> m_pluginDiagnosticEventThread;
50  std::atomic<bool> m_terminated{false};
51  std::atomic<bool> m_needToThrowPluginDiagnosticEvents{false};
52 };
53 
54 } // namespace diagnostic_events
55 } // namespace stub
56 } // namespace analytics
57 } // namespace vms_server_plugins
58 } // namespace nx
Definition: i_device_info.h:14
Definition: result.h:47
Definition: apple_utils.h:6
virtual nx::sdk::Result< const nx::sdk::ISettingsResponse * > settingsReceived() override
Definition: engine.cpp:122
Definition: engine.h:34
Definition: plugin.h:23