From 3cac22eaaed016ee6913a0e3341e6057f04a46c4 Mon Sep 17 00:00:00 2001 From: root Date: Mon, 29 Oct 2018 17:47:19 +0800 Subject: [PATCH] justify register-agent response when server not working --- pilot/pkg/registeragent/exporter/dubbo/export.go | 6 +++--- pilot/pkg/registeragent/exporter/sofa/export.go | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/pilot/pkg/registeragent/exporter/dubbo/export.go b/pilot/pkg/registeragent/exporter/dubbo/export.go index 7c8b427b159..403873985fa 100644 --- a/pilot/pkg/registeragent/exporter/dubbo/export.go +++ b/pilot/pkg/registeragent/exporter/dubbo/export.go @@ -55,12 +55,12 @@ func (r *SimpleRpcInfoExporter) GetRpcServiceInfo(c *gin.Context) { req, err := http.NewRequest("GET", url, nil) if err != nil { log.Errf("new local rpc request failed: ", err) - return + c.JSON(http.StatusOK, gin.H{"success": false, "data": nil}) } resp, err := client.Do(req) if err != nil { log.Errf("get local rpc info failed: ", err) - return + c.JSON(http.StatusOK, gin.H{"success": false, "data": nil}) } defer resp.Body.Close() log.Infof("status: %v", string(resp.StatusCode)) @@ -71,7 +71,7 @@ func (r *SimpleRpcInfoExporter) GetRpcServiceInfo(c *gin.Context) { err := json.Unmarshal(body, &info) if err != nil { log.Errf("Unmarshal rpc info failed: ", err) - return + c.JSON(http.StatusOK, gin.H{"success": false, "data": nil}) } interfacesDTO := InterfacesDTO{} interfacesDTO.Protocol = "DUBBO" diff --git a/pilot/pkg/registeragent/exporter/sofa/export.go b/pilot/pkg/registeragent/exporter/sofa/export.go index acfe892db85..b89fbcbcef4 100644 --- a/pilot/pkg/registeragent/exporter/sofa/export.go +++ b/pilot/pkg/registeragent/exporter/sofa/export.go @@ -68,12 +68,12 @@ func (r *SimpleRpcInfoExporter) GetRpcServiceInfo(c *gin.Context) { req, err := http.NewRequest("GET", url, nil) if err != nil { log.Errf("new local rpc request failed: ", err) - return + c.JSON(http.StatusOK, gin.H{"success": false, "data": nil}) } resp, err := client.Do(req) if err != nil { log.Errf("get local rpc info failed: ", err) - return + c.JSON(http.StatusOK, gin.H{"success": false, "data": nil}) } defer resp.Body.Close() log.Infof("status: %v", string(resp.StatusCode)) @@ -84,7 +84,7 @@ func (r *SimpleRpcInfoExporter) GetRpcServiceInfo(c *gin.Context) { err := json.Unmarshal(body, &info) if err != nil { log.Errf("Unmarshal rpc info failed: ", err) - return + c.JSON(http.StatusOK, gin.H{"success": false, "data": nil}) } interfacesDTO := InterfacesDTO{} interfacesDTO.Protocol = "BOLT"