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
}