fix(api): add setDuplicate(enable)

src/mynteye/api/api.cc

@@ -560,6 +560,10 @@ void API::EnablePlugin(const std::string &path) {
   synthetic_->SetPlugin(plugin);
 }
 
+void API::setDuplicate(bool isEnable) {
+  synthetic_->setDuplicate(isEnable);
+}
+
 void API::SetDisparityComputingMethodType(
       const DisparityComputingMethod &MethodType) {
   synthetic_->SetDisparityComputingMethodType(MethodType);

src/mynteye/api/processor.cc

@@ -26,6 +26,7 @@ MYNTEYE_BEGIN_NAMESPACE
 Processor::Processor(std::int32_t proc_period)
     : last_frame_id_cd(0),
       last_frame_id_cd_vice(0),
+      is_enable_cd(false),
       proc_period_(std::move(proc_period)),
       activated_(false),
       input_ready_(false),
@@ -282,7 +283,8 @@ api::StreamData Processor::GetStreamData(const Stream &stream) {
       if (out != nullptr) {
         auto output = Object::Cast<ObjMat>(out);
         if (output != nullptr) {
-          if (last_frame_id_cd == output->data->frame_id) {
+          if (!is_enable_cd &&
+              last_frame_id_cd == output->data->frame_id) {
             // cut the duplicate frame.
             return {};
           }
@@ -302,7 +304,8 @@ api::StreamData Processor::GetStreamData(const Stream &stream) {
         for (auto it : streams) {
           if (it.stream == stream) {
             if (num == 1) {
-              if (last_frame_id_cd == output->first_data->frame_id) {
+              if (!is_enable_cd &&
+                  last_frame_id_cd == output->first_data->frame_id) {
                 // cut the duplicate frame.
                 return {};
               }
@@ -310,7 +313,8 @@ api::StreamData Processor::GetStreamData(const Stream &stream) {
               return obj_data_first(output);
             } else {
               // last_frame_id_cd = output->second_data->frame_id;
-              if (last_frame_id_cd_vice == output->second_data->frame_id) {
+              if (!is_enable_cd &&
+                  last_frame_id_cd_vice == output->second_data->frame_id) {
                 // cut the duplicate frame.
                 return {};
               }

src/mynteye/api/processor.h

@@ -77,6 +77,9 @@ class Processor :
   std::shared_ptr<Object> GetOutput();
 
   std::uint64_t GetDroppedCount();
+  inline void setDupEnable(bool isEnable) {
+    is_enable_cd = isEnable;
+  }
 
  protected:
   virtual Object *OnCreateOutput() = 0;
@@ -92,6 +95,7 @@ class Processor :
   virtual process_type ProcessInputConnection();
   std::uint16_t last_frame_id_cd;
   std::uint16_t last_frame_id_cd_vice;
+  bool is_enable_cd;
  private:
   /** Run in standalone thread. */
   void Run();

src/mynteye/api/synthetic.cc

@@ -174,6 +174,12 @@ bool Synthetic::Supports(const Stream &stream) const {
   return checkControlDateWithStream(stream);
 }
 
+void Synthetic::setDuplicate(bool isEnable) {
+  for (auto it : processors_) {
+    it->setDupEnable(isEnable);
+  }
+}
+
 void Synthetic::EnableStreamData(
     const Stream &stream, stream_switch_callback_t callback,
     bool try_tag) {

src/mynteye/api/synthetic.h

@@ -83,6 +83,8 @@ class Synthetic {
   void SetPlugin(std::shared_ptr<Plugin> plugin);
   bool HasPlugin() const;
 
+  void setDuplicate(bool isEnable);
+
   const struct stream_control_t getControlDateWithStream(
       const Stream& stream) const;
   void setControlDateCallbackWithStream(