fix: Fixed the issue of missing Profile data when the Pipeline contai…

…ns a Golang plugin. (#1521) * fix profile data * add comments
alibaba · Jun 7, 2024 · edb7ff0 · edb7ff0
1 parent 1ec0489
commit edb7ff0
Showing 1 changed file with 10 additions and 9 deletions.
diff --git a/core/processor/daemon/LogProcess.cpp b/core/processor/daemon/LogProcess.cpp
@@ -407,8 +407,10 @@ void* LogProcess::ProcessLoop(int32_t threadNo) {
                                       "project", projectName)("logstore", category)("filename", convertedPath));
                     }
                 }
+            }
 
-                LogFileProfiler::GetInstance()->AddProfilingData(pipeline->Name(),
+            // 统计信息需要放在最外面，确保Pipeline在各种条件下，都能统计到
+            LogFileProfiler::GetInstance()->AddProfilingData(pipeline->Name(),
                                                                  pipeline->GetContext().GetRegion(),
                                                                  projectName,
                                                                  category,
@@ -424,14 +426,13 @@ void* LogProcess::ProcessLoop(int32_t threadNo) {
                                                                  profile.historyFailures,
                                                                  0,
                                                                  ""); // TODO: I don't think errorLine is useful
-                LOG_DEBUG(
-                    sLogger,
-                    ("project", projectName)("logstore", category)("filename", convertedPath)("read_bytes", readBytes)(
-                        "split_lines", profile.splitLines)("parse_failures", profile.parseFailures)(
-                        "parse_time_failures", profile.parseTimeFailures)(
-                        "regex_match_failures", profile.regexMatchFailures)("history_failures",
-                                                                            profile.historyFailures));
-            }
+            LOG_DEBUG(
+                sLogger,
+                ("project", projectName)("logstore", category)("filename", convertedPath)("read_bytes", readBytes)(
+                    "split_lines", profile.splitLines)("parse_failures", profile.parseFailures)(
+                    "parse_time_failures", profile.parseTimeFailures)(
+                    "regex_match_failures", profile.regexMatchFailures)("history_failures",
+                                                                        profile.historyFailures));
             logGroupList.clear();
         }
     }