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

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new c894d41a fix bug in rpc_client.go (#510)
c894d41a is described below

commit c894d41a24b8d2f44b1a049c960f3b402e0c026e
Author: guyinyou <[email protected]>
AuthorDate: Wed May 10 16:07:09 2023 +0800

    fix bug in rpc_client.go (#510)
    
    Co-authored-by: guyinyou <[email protected]>
---
 golang/rpc_client.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/golang/rpc_client.go b/golang/rpc_client.go
index 12a78e4f..a499a761 100644
--- a/golang/rpc_client.go
+++ b/golang/rpc_client.go
@@ -102,7 +102,7 @@ func (rc *rpcClient) GracefulStop() error {
        rc.mux.Lock()
        sugarBaseLogger.Warnf("close rpc client, target=%s", rc.target)
        closeResult := rc.conn.Close()
-       rc.mux.Lock()
+       rc.mux.Unlock()
        return closeResult
 }
 

Reply via email to