This is an automated email from the ASF dual-hosted git repository.

fangyc pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git


The following commit(s) were added to refs/heads/develop by this push:
     new d71ca0b  Fix: do not release conn when can not get response
     new 26238d4  Merge pull request #361 from divebomb/develop
d71ca0b is described below

commit d71ca0b30744903bba001ea5297d78956e3a2616
Author: AlexStocks <alexsto...@foxmail.com>
AuthorDate: Sun Feb 16 23:52:13 2020 +0800

    Fix: do not release conn when can not get response
---
 protocol/dubbo/client.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/protocol/dubbo/client.go b/protocol/dubbo/client.go
index 3923b7e..0765a33 100644
--- a/protocol/dubbo/client.go
+++ b/protocol/dubbo/client.go
@@ -24,9 +24,9 @@ import (
 )
 
 import (
-       "github.com/apache/dubbo-go-hessian2"
+       hessian "github.com/apache/dubbo-go-hessian2"
        "github.com/dubbogo/getty"
-       "github.com/dubbogo/gost/sync"
+       gxsync "github.com/dubbogo/gost/sync"
        perrors "github.com/pkg/errors"
        "go.uber.org/atomic"
        "gopkg.in/yaml.v2"
@@ -274,8 +274,8 @@ func (c *Client) call(ct CallType, request *Request, 
response *Response, callbac
 
        select {
        case <-getty.GetTimeWheel().After(c.opts.RequestTimeout):
-               err = errClientReadTimeout
                c.removePendingResponse(SequenceType(rsp.seq))
+               return perrors.WithStack(errClientReadTimeout)
        case <-rsp.done:
                err = rsp.err
        }

Reply via email to