Use DoubleBuffer and if there is no valid instance_identity file, request ecsmeta once at startup.

core/app_config/AppConfig.cpp

@@ -318,6 +318,32 @@ std::string GetAgentGoLogConfDir() {
     return dir;
 }
 
+std::string GetBufferFileDir() {
+    static std::string dir;
+    if (!dir.empty()) {
+        return dir;
+    }
+    if (BOOL_FLAG(logtail_mode)) {
+        dir = GetProcessExecutionDir();
+    } else {
+        dir = GetAgentDataDir();
+    }
+    return dir;
+}
+
+std::string GetHistoryDataPath() {
+    static std::string dir;
+    if (!dir.empty()) {
+        return dir;
+    }
+    if (BOOL_FLAG(logtail_mode)) {
+        dir = GetProcessExecutionDir();
+    } else {
+        dir = GetAgentDataDir();
+    }
+    return dir;
+}
+
 std::string GetAgentGoCheckpointDir() {
     static std::string dir;
     if (!dir.empty()) {
@@ -344,11 +370,18 @@ std::string GetAgentDataDir() {
     dir = GetProcessExecutionDir();
 #else
     if (BOOL_FLAG(logtail_mode)) {
-        dir = GetProcessExecutionDir();
+        dir = AppConfig::GetInstance()->GetLoongcollectorConfDir() + PATH_SEPARATOR + "checkpoint";
     } else {
         dir = STRING_FLAG(loongcollector_data_dir) + PATH_SEPARATOR;
     }
 #endif
+    if (!CheckExistance(dir)) {
+        if (Mkdirs(dir)) {
+            LOG_INFO(sLogger, ("create data dir success", dir));
+        } else {
+            LOG_ERROR(sLogger, ("create data dir failed", dir));
+        }
+    }
     return dir;
 }
 
@@ -392,7 +425,7 @@ std::string GetAgentDockerPathConfig() {
         return file_path;
     }
     if (BOOL_FLAG(logtail_mode)) {
-        file_path = GetAgentDataDir() + STRING_FLAG(ilogtail_docker_file_path_config);
+        file_path = GetProcessExecutionDir() + STRING_FLAG(ilogtail_docker_file_path_config);
     } else {
         file_path = GetAgentDataDir() + "docker_path_config.json";
     }

core/app_config/AppConfig.h

@@ -47,6 +47,8 @@ std::string GetAgentConfDir();
 std::string GetAgentRunDir();
 std::string GetAgentThirdPartyDir();
 
+std::string GetBufferFileDir();
+std::string GetHistoryDataPath();
 std::string GetAgentGoCheckpointDir();
 std::string GetAgentGoLogConfDir();
 std::string GetAgentPrometheusAuthorizationPath();

core/application/Application.cpp

@@ -106,7 +106,13 @@ void Application::Init() {
     }
 
     AppConfig::GetInstance()->LoadAppConfig(GetAgentConfigFile());
-
+#ifdef __ENTERPRISE__
+    InstanceIdentity::Instance()->InitFromFile();
+    if (InstanceIdentity::Instance()->NeedFetchECSMeta()) {
+        InstanceIdentity::Instance()->InitFromNetwork();
+        InstanceIdentity::Instance()->DumpInstanceIdentity();
+    }
+#endif
     // Initialize basic information: IP, hostname, etc.
     LoongCollectorMonitor::GetInstance();
 #ifdef __ENTERPRISE__
@@ -168,7 +174,7 @@ void Application::Init() {
     appInfoJson["UUID"] = Json::Value(Application::GetInstance()->GetUUID());
     appInfoJson["instance_id"] = Json::Value(Application::GetInstance()->GetInstanceId());
 #ifdef __ENTERPRISE__
-    appInfoJson["host_id"] = Json::Value(HostIdentifier::Instance()->GetHostId().id);
+    appInfoJson["host_id"] = Json::Value(InstanceIdentity::Instance()->GetEntity()->GetHostID().to_string());
     appInfoJson[GetVersionTag()] = Json::Value(ILOGTAIL_VERSION);
 #else
     appInfoJson[GetVersionTag()] = Json::Value(string(ILOGTAIL_VERSION) + " Community Edition");