change parameters name

alibaba · Sep 26, 2024 · 121b468 · 121b468
1 parent 8f6e7fe
commit 121b468
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 13 deletions.
diff --git a/core/file_server/ConfigManager.cpp b/core/file_server/ConfigManager.cpp
@@ -933,7 +933,7 @@ bool ConfigManager::IsUpdateContainerPaths() {
  // return false if s_lastUpdateCount >= INT32_FLAG(max_docker_config_update_times) and last update time is in same
  // window
  return false;
- /********************************************************************************/
+ /************************************************************************************************************************/
 }
 
 bool ConfigManager::UpdateContainerStopped(ConfigContainerInfoUpdateCmd* cmd) {

diff --git a/core/pipeline/plugin/instance/ProcessorInstance.cpp b/core/pipeline/plugin/instance/ProcessorInstance.cpp
@@ -40,7 +40,7 @@ bool ProcessorInstance::Init(const Json::Value& config, PipelineContext& context
  mOutEventGroupsTotal = mPlugin->GetMetricsRecordRef().CreateCounter(METRIC_PLUGIN_OUT_EVENT_GROUPS_TOTAL);
  mInSizeBytes = mPlugin->GetMetricsRecordRef().CreateCounter(METRIC_PLUGIN_IN_SIZE_BYTES);
  mOutSizeBytes = mPlugin->GetMetricsRecordRef().CreateCounter(METRIC_PLUGIN_OUT_SIZE_BYTES);
- mCostTimeMS = mPlugin->GetMetricsRecordRef().CreateCounter(METRIC_PLUGIN_TOTAL_PROCESS_TIME_MS);
+ mTotalProcessTimeMs = mPlugin->GetMetricsRecordRef().CreateCounter(METRIC_PLUGIN_TOTAL_PROCESS_TIME_MS);
 
  return true;
 }
@@ -57,7 +57,7 @@ void ProcessorInstance::Process(vector<PipelineEventGroup>& logGroupList) {
 
  auto before = chrono::system_clock::now();
  mPlugin->Process(logGroupList);
- mCostTimeMS->Add(chrono::duration_cast<chrono::milliseconds>(chrono::system_clock::now() - before).count());
+ mTotalProcessTimeMs->Add(chrono::duration_cast<chrono::milliseconds>(chrono::system_clock::now() - before).count());
 
  for (const auto& logGroup : logGroupList) {
  mOutEventsTotal->Add(logGroup.GetEvents().size());

diff --git a/core/pipeline/plugin/instance/ProcessorInstance.h b/core/pipeline/plugin/instance/ProcessorInstance.h
@@ -46,7 +46,7 @@ class ProcessorInstance : public PluginInstance {
  CounterPtr mOutEventGroupsTotal;
  CounterPtr mInSizeBytes;
  CounterPtr mOutSizeBytes;
- CounterPtr mCostTimeMS;
+ CounterPtr mTotalProcessTimeMs;
 
 #ifdef APSARA_UNIT_TEST_MAIN
  friend class ProcessorInstanceUnittest;

diff --git a/core/unittest/processor/ProcessorParseJsonNativeUnittest.cpp b/core/unittest/processor/ProcessorParseJsonNativeUnittest.cpp
@@ -314,7 +314,7 @@ void ProcessorParseJsonNativeUnittest::TestProcessJsonEscapedNullByte() {
  })";
  std::string outJson = eventGroupList[0].ToJsonString();
  APSARA_TEST_STREQ_FATAL(CompactJson(expectJson).c_str(), CompactJson(outJson).c_str());
- APSARA_TEST_GE_FATAL(processorInstance.mCostTimeMS->GetValue(), uint64_t(0));
+ APSARA_TEST_GE_FATAL(processorInstance.mTotalProcessTimeMs->GetValue(), uint64_t(0));
 }
 
 void ProcessorParseJsonNativeUnittest::TestProcessJson() {
@@ -394,7 +394,7 @@ void ProcessorParseJsonNativeUnittest::TestProcessJson() {
  })";
  std::string outJson = eventGroupList[0].ToJsonString();
  APSARA_TEST_STREQ_FATAL(CompactJson(expectJson).c_str(), CompactJson(outJson).c_str());
- APSARA_TEST_GE_FATAL(processorInstance.mCostTimeMS->GetValue(), uint64_t(0));
+ APSARA_TEST_GE_FATAL(processorInstance.mTotalProcessTimeMs->GetValue(), uint64_t(0));
 }
 
 void ProcessorParseJsonNativeUnittest::TestProcessJsonContent() {
@@ -485,7 +485,7 @@ void ProcessorParseJsonNativeUnittest::TestProcessJsonContent() {
  })";
  std::string outJson = eventGroupList[0].ToJsonString();
  APSARA_TEST_STREQ_FATAL(CompactJson(expectJson).c_str(), CompactJson(outJson).c_str());
- APSARA_TEST_GE_FATAL(processorInstance.mCostTimeMS->GetValue(), uint64_t(0));
+ APSARA_TEST_GE_FATAL(processorInstance.mTotalProcessTimeMs->GetValue(), uint64_t(0));
 }
 
 void ProcessorParseJsonNativeUnittest::TestProcessJsonRaw() {
@@ -574,7 +574,7 @@ void ProcessorParseJsonNativeUnittest::TestProcessJsonRaw() {
  })";
  std::string outJson = eventGroupList[0].ToJsonString();
  APSARA_TEST_STREQ_FATAL(CompactJson(expectJson).c_str(), CompactJson(outJson).c_str());
- APSARA_TEST_GE_FATAL(processorInstance.mCostTimeMS->GetValue(), uint64_t(0));
+ APSARA_TEST_GE_FATAL(processorInstance.mTotalProcessTimeMs->GetValue(), uint64_t(0));
 }
 
 void ProcessorParseJsonNativeUnittest::TestProcessEventKeepUnmatch() {
@@ -641,7 +641,7 @@ void ProcessorParseJsonNativeUnittest::TestProcessEventKeepUnmatch() {
  })";
  std::string outJson = eventGroupList[0].ToJsonString();
  APSARA_TEST_STREQ_FATAL(CompactJson(expectJson).c_str(), CompactJson(outJson).c_str());
- APSARA_TEST_GE_FATAL(processorInstance.mCostTimeMS->GetValue(), uint64_t(0));
+ APSARA_TEST_GE_FATAL(processorInstance.mTotalProcessTimeMs->GetValue(), uint64_t(0));
 }
 
 void ProcessorParseJsonNativeUnittest::TestProcessEventDiscardUnmatch() {
@@ -695,7 +695,7 @@ void ProcessorParseJsonNativeUnittest::TestProcessEventDiscardUnmatch() {
 
  std::string outJson = eventGroupList[0].ToJsonString();
  APSARA_TEST_STREQ_FATAL("null", CompactJson(outJson).c_str());
- APSARA_TEST_GE_FATAL(processorInstance.mCostTimeMS->GetValue(), uint64_t(0));
+ APSARA_TEST_GE_FATAL(processorInstance.mTotalProcessTimeMs->GetValue(), uint64_t(0));
 }
 
 } // namespace logtail

diff --git a/core/unittest/processor/ProcessorParseRegexNativeUnittest.cpp b/core/unittest/processor/ProcessorParseRegexNativeUnittest.cpp
@@ -223,7 +223,7 @@ void ProcessorParseRegexNativeUnittest::TestProcessRegex() {
  })";
  std::string outJson = eventGroupList[0].ToJsonString();
  APSARA_TEST_STREQ_FATAL(CompactJson(expectJson).c_str(), CompactJson(outJson).c_str());
- APSARA_TEST_GE_FATAL(processorInstance.mCostTimeMS->GetValue(), 0);
+ APSARA_TEST_GE_FATAL(processorInstance.mTotalProcessTimeMs->GetValue(), 0);
 }
 
 void ProcessorParseRegexNativeUnittest::TestProcessRegexRaw() {
@@ -297,7 +297,7 @@ void ProcessorParseRegexNativeUnittest::TestProcessRegexRaw() {
  })";
  std::string outJson = eventGroupList[0].ToJsonString();
  APSARA_TEST_STREQ_FATAL(CompactJson(expectJson).c_str(), CompactJson(outJson).c_str());
- APSARA_TEST_GE_FATAL(processorInstance.mCostTimeMS->GetValue(), 0);
+ APSARA_TEST_GE_FATAL(processorInstance.mTotalProcessTimeMs->GetValue(), 0);
 }
 
 void ProcessorParseRegexNativeUnittest::TestProcessRegexContent() {
@@ -373,7 +373,7 @@ void ProcessorParseRegexNativeUnittest::TestProcessRegexContent() {
  })";
  std::string outJson = eventGroupList[0].ToJsonString();
  APSARA_TEST_STREQ_FATAL(CompactJson(expectJson).c_str(), CompactJson(outJson).c_str());
- APSARA_TEST_GE_FATAL(processorInstance.mCostTimeMS->GetValue(), 0);
+ APSARA_TEST_GE_FATAL(processorInstance.mTotalProcessTimeMs->GetValue(), 0);
 }
 
 void ProcessorParseRegexNativeUnittest::TestAddLog() {