You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by if...@apache.org on 2022/06/30 23:40:03 UTC

[rocketmq-client-cpp] branch master updated: fix memory leak

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

ifplusor 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 d1881a5  fix memory leak
d1881a5 is described below

commit d1881a5df0b848f73e5f35a7cdcb795887a54705
Author: SRC-xiaojin <zt...@163.com>
AuthorDate: Tue Jun 28 00:56:27 2022 +0800

    fix memory leak
---
 src/transport/ClientRemotingProcessor.cpp | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/transport/ClientRemotingProcessor.cpp b/src/transport/ClientRemotingProcessor.cpp
index 6303684..a98d9ab 100644
--- a/src/transport/ClientRemotingProcessor.cpp
+++ b/src/transport/ClientRemotingProcessor.cpp
@@ -61,6 +61,8 @@ RemotingCommand* ClientRemotingProcessor::resetOffset(RemotingCommand* request)
     ResetOffsetRequestHeader* offsetHeader = (ResetOffsetRequestHeader*)request->getCommandHeader();
     if (offsetBody) {
       m_mqClientFactory->resetOffset(offsetHeader->getGroup(), offsetHeader->getTopic(), offsetBody->getOffsetTable());
+      delete offsetBody;
+      offsetBody = nullptr;
     } else {
       LOG_ERROR("resetOffset failed as received data could not be unserialized");
     }