obs retry param config error

Author: pansgg

src/drivers/devices/cpu/flowunit/data_source_parser/parser_plugin/obs_source_parser/obs_source_parser.cc

@@ -46,10 +46,10 @@ ObsSourceParser::~ObsSourceParser() = default;
 modelbox::Status ObsSourceParser::Init(
     const std::shared_ptr<modelbox::Configuration> &opts) {
   retry_enabled_ = opts->GetBool("retry_enable", DATASOURCE_PARSER_RETRY_ON);
-  retry_interval_ = opts->GetInt32(
-      "retry_interval_ms", DATASOURCE_PARSER_STREAM_DEFAULT_RETRY_TIMES);
+  retry_interval_ = opts->GetInt32("retry_interval_ms",
+                                   DATASOURCE_PARSER_DEFAULT_RETRY_INTERVAL);
   retry_max_times_ = opts->GetInt32("retry_count_limit",
-                                    DATASOURCE_PARSER_DEFAULT_RETRY_INTERVAL);
+                                    DATASOURCE_PARSER_FILE_DEFAULT_RETRY_TIMES);
 
   retry_enabled_ = opts->GetBool("obs_retry_enable", retry_enabled_);
   retry_interval_ = opts->GetInt32("obs_retry_interval_ms", retry_interval_);
@@ -66,6 +66,11 @@ modelbox::Status ObsSourceParser::Init(
   if (stream_memory_mode_ == "high") {
     max_read_size_ = OBS_STREAM_READ_SIZE_HIGH;
   }
+
+  MBLOG_INFO << "obs source parser config retry_enabled:" << retry_enabled_
+             << " retry_interval:" << retry_interval_
+             << " retry_max_times:" << retry_max_times_;
+
   return modelbox::STATUS_OK;
 }
 

src/drivers/devices/cpu/flowunit/data_source_parser/parser_plugin/url_source_parser/url_source_parser.cc

@@ -50,6 +50,13 @@ modelbox::Status UrlSourceParser::Init(
                      retry_max_times_ == RETRY_PARAMS_NOT_SET
                          ? DATASOURCE_PARSER_STREAM_DEFAULT_RETRY_TIMES
                          : retry_max_times_);
+
+  MBLOG_INFO << "url source parser config retry_enabled:" << retry_enabled_
+             << " stream_retry_interval:" << stream_retry_interval_
+             << " file_retry_interval:" << file_retry_interval_
+             << " keep_alive_interval:" << file_retry_times_
+             << " keep_alive_interval:" << stream_retry_times_;
+
   return modelbox::STATUS_OK;
 }
 

src/drivers/devices/cpu/flowunit/data_source_parser/parser_plugin/vcn_restful_source_parser/vcn_restful_source_parser.cc

@@ -28,6 +28,12 @@ modelbox::Status VcnRestfulSourceParser::Init(
 
   keep_alive_interval_ =
       opts->GetInt32("vcn_keep_alive_interval_sec", keep_alive_interval_);
+
+  MBLOG_INFO << "vcn restful source parser config retry_enabled:" << retry_enabled_
+             << " retry_interval:" << retry_interval_
+             << " retry_max_times:" << retry_max_times_
+             << " keep_alive_interval:" << keep_alive_interval_;
+
   return modelbox::STATUS_OK;
 }
 

src/drivers/devices/cpu/flowunit/data_source_parser/parser_plugin/vcn_source_parser/vcn_source_parser.cc

@@ -47,6 +47,10 @@ modelbox::Status VcnSourceParser::Init(
       "retry_count_limit", DATASOURCE_PARSER_STREAM_DEFAULT_RETRY_TIMES);
 
   ReadConfVcnCommon(opts, retry_enabled_, retry_interval_, retry_max_times_);
+
+  MBLOG_INFO << "vcn source parser config retry_enabled:" << retry_enabled_
+             << " retry_interval:" << retry_interval_
+             << " retry_max_times:" << retry_max_times_;
   return modelbox::STATUS_OK;
 }
 

src/drivers/devices/cpu/flowunit/data_source_parser/parser_plugin/vis_source_parser/vis_source_parser.cc

@@ -52,6 +52,10 @@ modelbox::Status VisSourceParser::Init(
   retry_enabled_ = opts->GetBool("vis_retry_enable", retry_enabled_);
   retry_interval_ = opts->GetInt32("vis_retry_interval_ms", retry_interval_);
   retry_max_times_ = opts->GetInt32("vis_retry_count_limit", retry_max_times_);
+
+  MBLOG_INFO << "vis source parser config retry_enabled:" << retry_enabled_
+             << " retry_interval:" << retry_interval_
+             << " retry_max_times:" << retry_max_times_;
   return modelbox::STATUS_OK;
 }