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);
}
}