nx_metadata_sdk  1.0
Metadata SDK
device_agent.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 <chrono>
7 
8 #include <nx/sdk/analytics/helpers/consuming_device_agent.h>
9 
10 #include "engine.h"
11 
12 namespace nx {
13 namespace vms_server_plugins {
14 namespace analytics {
15 namespace stub {
16 namespace motion_metadata {
17 
18 const std::string kMotionVisualizationObjectType{"nx.stub.motionVisualization"};
19 const std::string kAdditionalFrameProcessingDelayMsSetting{"additionalFrameProcessingDelayMs"};
20 
22 {
23 public:
24  DeviceAgent(Engine* engine, const nx::sdk::IDeviceInfo* deviceInfo);
25  virtual ~DeviceAgent() override;
26 
27 protected:
28  virtual void doSetNeededMetadataTypes(
29  nx::sdk::Result<void>* outValue,
30  const nx::sdk::analytics::IMetadataTypes* neededMetadataTypes) override;
31 
32  virtual std::string manifestString() const override;
33 
35 
36  virtual bool pushCompressedVideoFrame(
37  const nx::sdk::analytics::ICompressedVideoPacket* videoFrame) override;
38 
39 private:
40  void processVideoFrame(const nx::sdk::analytics::IDataPacket* videoFrame, const char* func);
41 
42  void processFrameMotion(
44 
45 private:
46  Engine* const m_engine;
47 
48  int m_frameCounter = 0;
49 
50  struct DeviceAgentSettings
51  {
52  std::atomic<std::chrono::milliseconds> additionalFrameProcessingDelayMs{
53  std::chrono::milliseconds::zero()};
54  };
55 
56  DeviceAgentSettings m_deviceAgentSettings;
57 };
58 
59 } // namespace motion_metadata
60 } // namespace stub
61 } // namespace analytics
62 } // namespace vms_server_plugins
63 } // namespace nx
Definition: i_compressed_video_packet.h:34
Definition: ptr.h:18
Definition: consuming_device_agent.h:38
Definition: i_metadata_types.h:13
Definition: result.h:81
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: device_agent.cpp:54
Definition: i_data_packet.h:17
virtual bool pushCompressedVideoFrame(const nx::sdk::analytics::ICompressedVideoPacket *videoFrame) override
Definition: device_agent.cpp:110
Definition: i_list.h:9