diff --git a/remoting/exchange.go b/remoting/exchange.go index e85e2c8ad1eb7457fb3dfa74047ad490fa059d0d..892bd82013d72b6ec62f87e03143622517070185 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 f264652a407971a3a5dc0365ab7fa2f2a9b30648..aea1bceeb8379d5fc896606abc0ce0dabdd1e876 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) }