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

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


The following commit(s) were added to refs/heads/1.3 by this push:
     new a0a21d0  Fix: do not release conn when can not get response
     new 0b9ba3f  Merge pull request #360 from divebomb/1.3
a0a21d0 is described below

commit a0a21d0a08fcacf582baadb38866f2267ca6328f
Author: AlexStocks <alexsto...@foxmail.com>
AuthorDate: Sun Feb 16 23:47:29 2020 +0800

    Fix: do not release conn when can not get response
---
 protocol/dubbo/client.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/protocol/dubbo/client.go b/protocol/dubbo/client.go
index 3e2a243..d40f98d 100644
--- a/protocol/dubbo/client.go
+++ b/protocol/dubbo/client.go
@@ -258,8 +258,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