xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: [TD-19500] del duplicate msg

This commit is contained in:
yihaoDeng 2022-10-12 16:05:59 +08:00
parent 36fecb7e68
commit 2bd62bc586
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/libs/transport/src/transSvr.c
View File

@ -1171,6 +1171,11 @@ _return2:
return -1; return -1;
} }
int transSendResponse(const STransMsg* msg) { int transSendResponse(const STransMsg* msg) {
if (msg->info.noResp) {
rpcFreeCont(msg->pCont);
tTrace("no need send resp");
return 0;
}
SExHandle* exh = msg->info.handle; SExHandle* exh = msg->info.handle;
int64_t refId = msg->info.refId; int64_t refId = msg->info.refId;
ASYNC_CHECK_HANDLE(exh, refId); ASYNC_CHECK_HANDLE(exh, refId);
@ -1209,6 +1214,8 @@ int transRegisterMsg(const STransMsg* msg) {
ASYNC_CHECK_HANDLE(exh, refId); ASYNC_CHECK_HANDLE(exh, refId);
STransMsg tmsg = *msg; STransMsg tmsg = *msg;
tmsg.info.noResp = 1;
tmsg.info.refId = refId; tmsg.info.refId = refId;
SWorkThrd* pThrd = exh->pThrd; SWorkThrd* pThrd = exh->pThrd;