polish

Author: Takuka0311

core/monitor/AlarmManager.cpp

@@ -15,17 +15,12 @@
 #include "monitor/AlarmManager.h"
 
 #include "app_config/AppConfig.h"
-#include "collection_pipeline/queue/QueueKeyManager.h"
-#include "collection_pipeline/queue/SenderQueueManager.h"
 #include "common/LogtailCommonFlags.h"
 #include "common/StringTools.h"
-#include "common/Thread.h"
 #include "common/TimeUtil.h"
 #include "common/version.h"
 #include "constants/Constants.h"
-#include "go_pipeline/LogtailPlugin.h"
 #include "monitor/SelfMonitorServer.h"
-#include "protobuf/sls/sls_logs.pb.h"
 #include "provider/Provider.h"
 
 DEFINE_FLAG_INT32(logtail_alarm_interval, "the interval of two same type alarm message", 30);
@@ -116,10 +111,6 @@ AlarmManager::AlarmManager() {
 }
 
 void AlarmManager::FlushAllRegionAlarm(vector<PipelineEventGroup>& pipelineEventGroupList) {
-    // 发送前同步一次go的alarm
-    if (LogtailPlugin::GetInstance()->IsPluginOpened()) {
-        LogtailPlugin::GetInstance()->GetGoAlarms();
-    }
     int32_t currentTime = time(nullptr);
     size_t sendRegionIndex = 0;
     size_t sendAlarmTypeIndex = 0;

core/monitor/SelfMonitorServer.cpp

@@ -18,6 +18,7 @@
 
 #include "MetricConstants.h"
 #include "Monitor.h"
+#include "go_pipeline/LogtailPlugin.h"
 #include "runner/ProcessorRunner.h"
 
 using namespace std;
@@ -194,6 +195,10 @@ void SelfMonitorServer::RemoveAlarmPipeline() {
 }
 
 void SelfMonitorServer::SendAlarms() {
+    // 发送前同步一次go的alarm
+    if (LogtailPlugin::GetInstance()->IsPluginOpened()) {
+        LogtailPlugin::GetInstance()->GetGoAlarms();
+    }
     // metadata:
     // INTERNAL_DATA_TARGET_REGION:${region}
     // INTERNAL_DATA_TYPE:__alarm__