rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jianha...@apache.org
Subject [rocketmq-client-go] branch master updated: fix(remote_client):avoid goroutine leak
Date Thu, 26 Nov 2020 06:19:39 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/master by this push:
     new 06ef9b6  fix(remote_client):avoid goroutine leak
     new 99c88b4  Merge pull request #535 from murDDock/dev
06ef9b6 is described below

commit 06ef9b6fdacc47ff73926719a9e63269e682241f
Author: huangxingning <huangxingning@bytedance.com>
AuthorDate: Mon Sep 14 20:44:42 2020 +0800

    fix(remote_client):avoid goroutine leak
    
    Change-Id: I0b839dc76427ba2d278f3670d339e79ba2c380fb
---
 internal/remote/remote_client.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/internal/remote/remote_client.go b/internal/remote/remote_client.go
index 7b5b1ea..dae364e 100644
--- a/internal/remote/remote_client.go
+++ b/internal/remote/remote_client.go
@@ -194,7 +194,7 @@ func (c *remotingClient) processCMD(cmd *RemotingCommand, r *tcpConnWrapper)
{
 				responseFuture.ResponseCommand = cmd
 				responseFuture.executeInvokeCallback()
 				if responseFuture.Done != nil {
-					responseFuture.Done <- true
+					close(responseFuture.Done)
 				}
 			})
 		}


Mime
View raw message