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

Merge pull request #11080 from taosdata/index/fix_no_resp 

handle execept
This commit is contained in:
Yihao Deng 2022-03-29 13:54:14 +08:00 committed by GitHub
parent 43d8df0781 fbf15d45c0
commit a47e097238
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/stream/src/tstream.c
View File

@ -74,7 +74,7 @@ static int32_t streamBuildDispatchMsg(SStreamTask* pTask, SArray* data, SRpcMsg*
pMsg->contLen = tlen; pMsg->contLen = tlen;
pMsg->code = 0; pMsg->code = 0;
pMsg->msgType = pTask->dispatchMsgType; pMsg->msgType = pTask->dispatchMsgType;
/*pMsg->noResp = 1;*/ pMsg->noResp = 1;
return 0; return 0;
} }

8
source/libs/transport/src/transSrv.c
View File

@ -214,9 +214,11 @@ static void uvHandleReq(SSrvConn* pConn) {
// no ref here // no ref here
} }
if (pHead->noResp == 0) { // if pHead->noResp = 1,
transMsg.handle = pConn; // 1. server application should not send resp on handle
} // 2. once send out data, cli conn released to conn pool immediately
// 3. not mixed with persist
transMsg.handle = pConn;
STrans* pTransInst = pConn->pTransInst; STrans* pTransInst = pConn->pTransInst;
(*pTransInst->cfp)(pTransInst->parent, &transMsg, NULL); (*pTransInst->cfp)(pTransInst->parent, &transMsg, NULL);