From 4504c4442f981e8a85623d1654198591c3ab6a45 Mon Sep 17 00:00:00 2001 From: ly0 Date: Fri, 13 Aug 2021 13:10:39 +0800 Subject: [PATCH] fix searray memory leak --- src/sql/dtl/ob_dtl_rpc_channel.cpp | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/sql/dtl/ob_dtl_rpc_channel.cpp b/src/sql/dtl/ob_dtl_rpc_channel.cpp index d08f97443..94d6025f9 100644 --- a/src/sql/dtl/ob_dtl_rpc_channel.cpp +++ b/src/sql/dtl/ob_dtl_rpc_channel.cpp @@ -88,6 +88,7 @@ void ObDtlRpcChannel::SendBCMsgCB::on_invalid() LOG_WARN("set finish failed", K(ret), K(resps.count()), K(responses_.count()), K(trace_id_)); } } + resps.reset(); } void ObDtlRpcChannel::SendBCMsgCB::on_timeout() @@ -102,6 +103,7 @@ void ObDtlRpcChannel::SendBCMsgCB::on_timeout() LOG_WARN("set finish failed", K(ret), K(resps.count()), K(responses_.count()), K(trace_id_)); } } + resps.reset(); } int ObDtlRpcChannel::SendBCMsgCB::process() @@ -125,6 +127,7 @@ int ObDtlRpcChannel::SendBCMsgCB::process() } LOG_TRACE("rpc clone sendbcmsg cb", K(responses_.at(i)), K(trace_id_)); } + resps.reset(); return ret; }