You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2019/04/17 03:17:12 UTC
[rocketmq-client-cpp] branch master updated: Update
TcpRemotingClient.cpp
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 <li...@163.com>
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);
}
}