From 259e051710d96ca096aefb68e962ae95a97c0791 Mon Sep 17 00:00:00 2001 From: zhangchunbao Date: Wed, 23 Mar 2022 01:41:51 +0000 Subject: [PATCH] update aw/cxx/distributed/distributed_agent.cpp. Signed-off-by: zhangchunbao --- aw/cxx/distributed/distributed_agent.cpp | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/aw/cxx/distributed/distributed_agent.cpp b/aw/cxx/distributed/distributed_agent.cpp index fc1d7af..9440674 100644 --- a/aw/cxx/distributed/distributed_agent.cpp +++ b/aw/cxx/distributed/distributed_agent.cpp @@ -103,12 +103,12 @@ int DistributedAgent::InitAgentServer() } if (listen(serverSockFd, 1) < 0) { - HiLog::Error(DistributedAgent::LABEL, "%s agent listen error.\n", agentIpAddr_.c_str()); + HiLog::Error(DistributedAgent::LABEL, "agent listen error.\n"); close(serverSockFd); serverSockFd = -1; return serverSockFd; } - HiLog::Info(DistributedAgent::LABEL, "listen %s .......", agentIpAddr_.c_str()); + mpthCmdProcess_ = std::make_unique([=]() { DoCmdServer(serverSockFd); }); @@ -196,6 +196,8 @@ int DistributedAgent::DoCmdServer(int serverSockFd) int nresult = OnProcessCmd(pAlignmentCmd, cmdLen, pszEValue, eValueLen); ret = memset_s(returnValue, sizeof(returnValue), 0, MAX_BUFF_LEN); if (ret != EOK) { + delete []pAlignmentCmd; + delete []pszEValue; return -1; } auto pclinereturn = reinterpret_cast(returnValue); -- Gitee