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

opt transport

This commit is contained in:
Yihao Deng 2024-07-12 11:35:14 +00:00
parent 0a138a5078
commit 6e004abc7d
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/libs/transport/src/transCli.c
View File

@ -1182,7 +1182,8 @@ void cliSendBatch_shareConn(SCliConn* pConn) {
int32_t totalLen = 0; int32_t totalLen = 0;
if (size == 0) { if (size == 0) {
tError("%s conn %p not msg to send", pTransInst->label, pConn); tError("%s conn %p not msg to send", pTransInst->label, pConn);
cliHandleExcept(pConn); ASSERT(0);
// cliHandleExcept(pConn);
return; return;
} }
uv_buf_t* wb = taosMemoryCalloc(size, sizeof(uv_buf_t)); uv_buf_t* wb = taosMemoryCalloc(size, sizeof(uv_buf_t));

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

@ -427,6 +427,9 @@ static bool uvHandleReq(SSvrConn* pConn) {
transMsg.msgType = pHead->msgType; transMsg.msgType = pHead->msgType;
transMsg.code = pHead->code; transMsg.code = pHead->code;
if (pHead->seqNum != 0) {
ASSERT(0);
}
// pHead->noResp = 1, // pHead->noResp = 1,
// 1. server application should not send resp on handle // 1. server application should not send resp on handle
// 2. once send out data, cli conn released to conn pool immediately // 2. once send out data, cli conn released to conn pool immediately