OptiViewOutputGroup.h File

Runtime helpers for OptiView UDP video + JSON fan-out. More...

Included Headers

#include "nodes/io/OptiViewJsonOutput.h" #include "pipeline/SessionOptions.h" #include "pipeline/Run.h" #include <cstddef> #include <cstdint> #include <memory> #include <string> #include <vector>

Namespaces Index

namespace	simaai
namespace	neat
namespace	nodes
namespace	groups

Classes Index

struct	UdpOutputNodeGroupOptions
class	UdpOutputNodeGroup
struct	OptiViewOutputNodeGroupOptions
struct	OptiViewJsonInput
struct	OptiViewJsonResult
class	OptiViewOutputNodeGroup

Description

Runtime helpers for OptiView UDP video + JSON fan-out.

File Listing

The file content with the documentation metadata removed is:

1

6#pragma once

7

8#include "nodes/io/OptiViewJsonOutput.h"

9#include "pipeline/SessionOptions.h"

10#include "pipeline/Run.h"

11

12#include <cstddef>

13#include <cstdint>

14#include <memory>

15#include <string>

16#include <vector>

17

18namespace simaai::neat::nodes::groups {

19

20struct UdpOutputNodeGroupOptions {

21 std::string h264_caps;

22 int payload_type = 96;

23 int config_interval = 1;

24 bool enable_timings = false;

25 std::string host = "127.0.0.1";

26 int video_port_base = 9000;

27 bool udp_sync = false;

28 bool udp_async = false;

29};

30

31class UdpOutputNodeGroup {

32public:

33 bool init(const UdpOutputNodeGroupOptions& opt, size_t streams, std::string* err = nullptr);

34

35 bool push_video(size_t idx, const simaai::neat::Sample& sample) const;

36 bool try_push_video(size_t idx, const simaai::neat::Sample& sample) const;

37

38 void stop();

39 size_t size() const {

40 return runs_.size();

41 }

42

43 const std::vector<std::shared_ptr<simaai::neat::Run>>& runs() const {

44 return runs_;

45 }

46

47private:

48 UdpOutputNodeGroupOptions opt_{};

49 std::vector<std::shared_ptr<simaai::neat::Run>> runs_;

50};

51

52struct OptiViewOutputNodeGroupOptions {

53 UdpOutputNodeGroupOptions udp{};

54 bool send_json = true;

55 int json_port_base = 9100;

56 int frame_w = 0;

57 int frame_h = 0;

58 int topk = 100;

59 bool parse_debug = false;

60 int json_delay_ms = 0;

61 int video_delay_ms = 0;

62 std::vector<std::string> labels;

63};

64

65struct OptiViewJsonInput {

66 size_t stream_idx = 0;

67 std::string stream_id;

68 int64_t frame_id = -1;

69 int64_t capture_ms = -1;

70 int64_t yolo_ms = -1;

71 int output_frame_id = -1;

72 const simaai::neat::Sample* yolo_sample = nullptr;

73 const simaai::neat::Sample* decoded_sample = nullptr;

74};

75

76struct OptiViewJsonResult {

77 bool ok = false;

78 bool nonempty = false;

79 int boxes = 0;

80 std::string error;

81};

82

83class OptiViewOutputNodeGroup {

84public:

85 OptiViewOutputNodeGroup() = default;

86 ~OptiViewOutputNodeGroup() = default;

87 OptiViewOutputNodeGroup(const OptiViewOutputNodeGroup&) = delete;

88 OptiViewOutputNodeGroup& operator=(const OptiViewOutputNodeGroup&) = delete;

89 OptiViewOutputNodeGroup(OptiViewOutputNodeGroup&&) noexcept = default;

90 OptiViewOutputNodeGroup& operator=(OptiViewOutputNodeGroup&&) noexcept = default;

91

92 bool init(const OptiViewOutputNodeGroupOptions& opt, size_t streams, std::string* err = nullptr);

93

94 bool push_video(size_t idx, const simaai::neat::Sample& sample) const;

95 bool try_push_video(size_t idx, const simaai::neat::Sample& sample) const;

96 bool emit_json(const OptiViewJsonInput& in, OptiViewJsonResult* out = nullptr) const;

97

98 void stop();

99

100 const std::vector<std::shared_ptr<simaai::neat::Run>>& video_runs() const {

101 return udp_.runs();

102 }

103

104private:

105 int64_t pick_timestamp_ms_(const OptiViewJsonInput& in) const;

106

107 OptiViewOutputNodeGroupOptions opt_{};

108 UdpOutputNodeGroup udp_;

109 std::vector<std::unique_ptr<simaai::neat::OptiViewJsonOutput>> senders_;

110};

111

112} // namespace simaai::neat::nodes::groups

---

Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.1.