commit 68b323ded2433a916f3c452be8ddecb0be38ab4b
author James <ywhjames@hotmail.com> Wed Apr 17 10:48:50 2019 +0800
committer dinglei <libya_003@163.com> Wed Apr 17 10:48:50 2019 +0800
tree abea80c9c1ca9f05d128ca19e2dd3e25525b7b99
parent 28c4cf0bd1e1b9d1f639fad6e59b7b62b243913a

[ISSUE #134]Fixed ResponseFuture leak when invokeHeartBeat is failed. (#135)

src/transport/TcpRemotingClient.cpp

diff --git a/src/transport/TcpRemotingClient.cpp b/src/transport/TcpRemotingClient.cpp
index e72af1d..8151379 100644
--- a/src/transport/TcpRemotingClient.cpp
+++ b/src/transport/TcpRemotingClient.cpp
@@ -142,12 +142,14 @@
       unique_ptr<RemotingCommand> pRsp(responseFuture->waitResponse(3000));
       if (pRsp == NULL) {
         LOG_ERROR("wait response timeout of heartbeat, so closeTransport of addr:%s", addr.c_str());
+        findAndDeleteResponseFuture(opaque);
         CloseTransport(addr, pTcp);
         return false;
       } else if (pRsp->getCode() == SUCCESS_VALUE) {
         return true;
       } else {
         LOG_WARN("get error response:%d of heartbeat to addr:%s", pRsp->getCode(), addr.c_str());
+        findAndDeleteResponseFuture(opaque);
         return false;
       }
     } else {