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

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


The following commit(s) were added to refs/heads/master by this push:
     new 7e9f70d  Update TcpRemotingClient.cpp
7e9f70d is described below

commit 7e9f70db57d083ff9379a0c47acf94997d2c648b
Author: dinglei <[email protected]>
AuthorDate: Wed Apr 17 11:17:08 2019 +0800

    Update TcpRemotingClient.cpp
---
 src/transport/TcpRemotingClient.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/transport/TcpRemotingClient.cpp 
b/src/transport/TcpRemotingClient.cpp
index 8151379..8256391 100644
--- a/src/transport/TcpRemotingClient.cpp
+++ b/src/transport/TcpRemotingClient.cpp
@@ -149,10 +149,10 @@ bool TcpRemotingClient::invokeHeartBeat(const string& 
addr, RemotingCommand& req
         return true;
       } else {
         LOG_WARN("get error response:%d of heartbeat to addr:%s", 
pRsp->getCode(), addr.c_str());
-        findAndDeleteResponseFuture(opaque);
         return false;
       }
     } else {
+      findAndDeleteResponseFuture(opaque);
       CloseTransport(addr, pTcp);
     }
   }

Reply via email to