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 <thread>
6 #include <atomic>
7 #include <memory>
8 #include <condition_variable>
9 #include <vector>
10 #include <string>
11 #include <deque>
12 
13 #include <nx/sdk/analytics/helpers/consuming_device_agent.h>
14 #include <nx/sdk/analytics/helpers/pixel_format.h>
15 #include <nx/sdk/analytics/helpers/object_metadata_packet.h>
16 
17 #include "engine.h"
18 #include "stub_analytics_plugin_video_frames_ini.h"
19 
20 namespace nx {
21 namespace vms_server_plugins {
22 namespace analytics {
23 namespace stub {
24 namespace video_frames {
25 
26 const std::string kMotionVisualizationObjectType = "nx.stub.motionVisualization";
27 const std::string kAdditionalFrameProcessingDelayMsSetting = "additionalFrameProcessingDelayMs";
28 const std::string kLeakFramesSetting = "leakFrames";
29 
31 {
32 public:
33  DeviceAgent(Engine* engine, const nx::sdk::IDeviceInfo* deviceInfo);
34  virtual ~DeviceAgent() override;
35 
36 protected:
37  virtual void doSetNeededMetadataTypes(
38  nx::sdk::Result<void>* outValue,
39  const nx::sdk::analytics::IMetadataTypes* neededMetadataTypes) override;
40 
41  virtual std::string manifestString() const override;
42 
44 
45  virtual bool pushCompressedVideoFrame(
46  const nx::sdk::analytics::ICompressedVideoPacket* videoFrame) override;
47 
48  virtual bool pushUncompressedVideoFrame(
49  const nx::sdk::analytics::IUncompressedVideoFrame* videoFrame) override;
50 
51 private:
52  void processVideoFrame(const nx::sdk::analytics::IDataPacket* videoFrame, const char* func);
53 
54  bool checkVideoFrame(const nx::sdk::analytics::IUncompressedVideoFrame* frame) const;
55 
56  bool checkVideoFramePlane(
58  const nx::sdk::analytics::PixelFormatDescriptor* pixelFormatDescriptor,
59  int plane) const;
60 
61  void dumpSomeFrameBytes(
63  int plane) const;
64 
65 private:
66  Engine* const m_engine;
67 
68  int m_frameCounter = 0;
69 
70  struct DeviceAgentSettings
71  {
72  std::atomic<bool> leakFrames{false};
73 
74  std::atomic<std::chrono::milliseconds> additionalFrameProcessingDelayMs{
75  std::chrono::milliseconds::zero()};
76  };
77 
78  DeviceAgentSettings m_deviceAgentSettings;
79 };
80 
81 } // namespace video_frames
82 } // namespace stub
83 } // namespace analytics
84 } // namespace vms_server_plugins
85 } // namespace nx
virtual bool pushCompressedVideoFrame(const nx::sdk::analytics::ICompressedVideoPacket *videoFrame) override
Definition: device_agent.cpp:131
virtual nx::sdk::Result< const nx::sdk::ISettingsResponse * > settingsReceived() override
Definition: device_agent.cpp:57
Definition: i_compressed_video_packet.h:32
Definition: consuming_device_agent.h:36
Definition: i_metadata_types.h:11
Definition: result.h:80
Definition: i_device_info.h:13
Definition: result.h:46
Definition: apple_utils.h:6
Definition: pixel_format.h:24
Definition: i_uncompressed_video_frame.h:71
virtual bool pushUncompressedVideoFrame(const nx::sdk::analytics::IUncompressedVideoFrame *videoFrame) override
Definition: device_agent.cpp:146
Definition: i_data_packet.h:15