From 1c1ffc8b3209b1590bece9c8b59c099e3db9c187 Mon Sep 17 00:00:00 2001 From: godchen Date: Tue, 29 Jun 2021 14:30:17 +0800 Subject: [PATCH] Add connect err log (#6186) Signed-off-by: godchen --- internal/distributed/datacoord/client/client.go | 3 ++- internal/distributed/datanode/client/client.go | 3 ++- internal/distributed/indexcoord/client/client.go | 3 ++- internal/distributed/indexnode/client/client.go | 3 ++- internal/distributed/proxy/client/client.go | 3 ++- internal/distributed/querycoord/client/client.go | 3 ++- internal/distributed/querynode/client/client.go | 3 ++- internal/distributed/rootcoord/client/client.go | 3 ++- 8 files changed, 16 insertions(+), 8 deletions(-) diff --git a/internal/distributed/datacoord/client/client.go b/internal/distributed/datacoord/client/client.go index 8167cd974a..cc52ae3010 100644 --- a/internal/distributed/datacoord/client/client.go +++ b/internal/distributed/datacoord/client/client.go @@ -13,6 +13,7 @@ package grpcdatacoordclient import ( "context" + "errors" "fmt" "time" @@ -124,7 +125,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error) } err = c.connect() if err != nil { - return ret, err + return ret, errors.New("Connect to datacoord failed with error:\n" + err.Error()) } ret, err = caller() if err == nil { diff --git a/internal/distributed/datanode/client/client.go b/internal/distributed/datanode/client/client.go index 73b90d5e78..1f29c758c4 100644 --- a/internal/distributed/datanode/client/client.go +++ b/internal/distributed/datanode/client/client.go @@ -13,6 +13,7 @@ package grpcdatanodeclient import ( "context" + "errors" "fmt" "time" @@ -104,7 +105,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error) } err = c.connect() if err != nil { - return ret, err + return ret, errors.New("Connect to datanode failed with error:\n" + err.Error()) } ret, err = caller() if err == nil { diff --git a/internal/distributed/indexcoord/client/client.go b/internal/distributed/indexcoord/client/client.go index 6c8a03f8ed..fad3f9c565 100644 --- a/internal/distributed/indexcoord/client/client.go +++ b/internal/distributed/indexcoord/client/client.go @@ -13,6 +13,7 @@ package grpcindexcoordclient import ( "context" + "errors" "fmt" "time" @@ -127,7 +128,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error) } err = c.connect() if err != nil { - return ret, err + return ret, errors.New("Connect to indexcoord failed with error:\n" + err.Error()) } ret, err = caller() if err == nil { diff --git a/internal/distributed/indexnode/client/client.go b/internal/distributed/indexnode/client/client.go index 67fa96ee28..6ce843b983 100644 --- a/internal/distributed/indexnode/client/client.go +++ b/internal/distributed/indexnode/client/client.go @@ -13,6 +13,7 @@ package grpcindexnodeclient import ( "context" + "errors" "fmt" "time" @@ -99,7 +100,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error) } err = c.connect() if err != nil { - return ret, err + return ret, errors.New("Connect to indexnode failed with error:\n" + err.Error()) } ret, err = caller() if err == nil { diff --git a/internal/distributed/proxy/client/client.go b/internal/distributed/proxy/client/client.go index db2a0cc17e..a48ea14d61 100644 --- a/internal/distributed/proxy/client/client.go +++ b/internal/distributed/proxy/client/client.go @@ -13,6 +13,7 @@ package grpcproxyclient import ( "context" + "errors" "fmt" "time" @@ -98,7 +99,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error) } err = c.connect() if err != nil { - return ret, err + return ret, errors.New("Connect to proxy failed with error:\n" + err.Error()) } ret, err = caller() if err == nil { diff --git a/internal/distributed/querycoord/client/client.go b/internal/distributed/querycoord/client/client.go index 18640d0163..c9ab3a2b2f 100644 --- a/internal/distributed/querycoord/client/client.go +++ b/internal/distributed/querycoord/client/client.go @@ -13,6 +13,7 @@ package grpcquerycoordclient import ( "context" + "errors" "fmt" "time" @@ -126,7 +127,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error) } err = c.connect() if err != nil { - return ret, err + return ret, errors.New("Connect to querycoord failed with error:\n" + err.Error()) } ret, err = caller() if err == nil { diff --git a/internal/distributed/querynode/client/client.go b/internal/distributed/querynode/client/client.go index c2803bd3eb..a9cb8189ee 100644 --- a/internal/distributed/querynode/client/client.go +++ b/internal/distributed/querynode/client/client.go @@ -13,6 +13,7 @@ package grpcquerynodeclient import ( "context" + "errors" "fmt" "time" @@ -99,7 +100,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error) } err = c.connect() if err != nil { - return ret, err + return ret, errors.New("Connect to querynode failed with error:\n" + err.Error()) } ret, err = caller() if err == nil { diff --git a/internal/distributed/rootcoord/client/client.go b/internal/distributed/rootcoord/client/client.go index 8fcebc57f6..2ab8518847 100644 --- a/internal/distributed/rootcoord/client/client.go +++ b/internal/distributed/rootcoord/client/client.go @@ -13,6 +13,7 @@ package grpcrootcoordclient import ( "context" + "errors" "fmt" "time" @@ -147,7 +148,7 @@ func (c *GrpcClient) recall(caller func() (interface{}, error)) (interface{}, er } err = c.connect() if err != nil { - return ret, err + return ret, errors.New("Connect to rootcoord failed with error:\n" + err.Error()) } ret, err = caller() if err == nil {