From 622eb4912228137cbccdc0ab083916687e91cadd Mon Sep 17 00:00:00 2001 From: luohoufu Date: Fri, 17 Jan 2025 11:19:59 +0800 Subject: [PATCH] fix: the invalid ip --- modules/agent/api/elasticsearch.go | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/modules/agent/api/elasticsearch.go b/modules/agent/api/elasticsearch.go index 4fe062ef..9c69fd3a 100644 --- a/modules/agent/api/elasticsearch.go +++ b/modules/agent/api/elasticsearch.go @@ -31,6 +31,11 @@ import ( "context" "errors" "fmt" + "net/http" + "runtime" + "sync/atomic" + "time" + "github.com/buger/jsonparser" log "github.com/cihub/seelog" "infini.sh/console/plugin/managed/server" @@ -43,10 +48,6 @@ import ( "infini.sh/framework/modules/elastic/adapter" "infini.sh/framework/modules/elastic/common" "infini.sh/framework/modules/elastic/metadata" - "net/http" - "runtime" - "sync/atomic" - "time" ) // node -> binding item @@ -603,6 +604,11 @@ func (h *APIHandler) bindInstanceToCluster(clusterInfo ClusterInfo, nodes *elast if util.ContainStr(ip, "::") { ip = fmt.Sprintf("[%s]", ip) } + + if util.ContainStr(ip, "*") { + ip = "127.0.0.1" + } + nodeHost := fmt.Sprintf("%s:%d", ip, port) nodeInfo := h.internalProcessBind(clusterID, clusterUUID, instanceID, instanceEndpoint, pid, nodeHost, auth) if nodeInfo != nil {