From 1bbe0b492ef490d1c1c9166678507576a3a33aa0 Mon Sep 17 00:00:00 2001
From: cvictory <shenglicao2@gmail.com>
Date: Mon, 18 May 2020 17:20:39 +0800
Subject: [PATCH] modify log
---
remoting/exchange.go | 2 +-
remoting/getty/getty_client.go | 6 ++++--
2 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/remoting/exchange.go b/remoting/exchange.go
index e85e2c8ad..892bd8201 100644
--- a/remoting/exchange.go
+++ b/remoting/exchange.go
@@ -48,7 +48,7 @@ type Request struct {
ID int64
// protocol version
Version string
- // serial ID
+ // serial ID (ignore)
SerialID byte
// Data
Data interface{}
diff --git a/remoting/getty/getty_client.go b/remoting/getty/getty_client.go
index f264652a4..aea1bceeb 100644
--- a/remoting/getty/getty_client.go
+++ b/remoting/getty/getty_client.go
@@ -154,7 +154,9 @@ func (c *Client) Connect(url common.URL) error {
c.codec = remoting.GetCodec(url.Protocol)
c.addr = url.Location
_, _, err := c.selectSession(c.addr)
- logger.Errorf("try to connect server %v failed for : %v", url.Location, err)
+ if err != nil {
+ logger.Errorf("try to connect server %v failed for : %v", url.Location, err)
+ }
return err
}
@@ -174,7 +176,7 @@ func (c *Client) Request(request *remoting.Request, timeout time.Duration, respo
// session getty.Session
// conn *gettyRPCClient
//)
- conn, session, err := c.selectSession(c.addr)
+ _, session, err := c.selectSession(c.addr)
if err != nil {
return perrors.WithStack(err)
}
--
GitLab