From 2bd62bc586f005ed402b267476be86ae7e4a81f1 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 12 Oct 2022 16:05:59 +0800 Subject: [PATCH] fix: [TD-19500] del duplicate msg --- source/libs/transport/src/transSvr.c | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/source/libs/transport/src/transSvr.c b/source/libs/transport/src/transSvr.c index 683d488bbf..57bf8a34b3 100644 --- a/source/libs/transport/src/transSvr.c +++ b/source/libs/transport/src/transSvr.c @@ -1171,6 +1171,11 @@ _return2: return -1; } int transSendResponse(const STransMsg* msg) { + if (msg->info.noResp) { + rpcFreeCont(msg->pCont); + tTrace("no need send resp"); + return 0; + } SExHandle* exh = msg->info.handle; int64_t refId = msg->info.refId; ASYNC_CHECK_HANDLE(exh, refId); @@ -1209,6 +1214,8 @@ int transRegisterMsg(const STransMsg* msg) { ASYNC_CHECK_HANDLE(exh, refId); STransMsg tmsg = *msg; + tmsg.info.noResp = 1; + tmsg.info.refId = refId; SWorkThrd* pThrd = exh->pThrd;