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

opt parameter

This commit is contained in:
yihaoDeng 2024-09-13 16:08:20 +08:00
parent 68c4af0e8a
commit 290c6f89df
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -434,13 +434,14 @@ static int32_t uvMayHandleReleaseReq(SSvrConn* pConn, STransMsgHead* pHead) {
void* p = taosHashGet(pConn->pQTable, &qId, sizeof(qId)); void* p = taosHashGet(pConn->pQTable, &qId, sizeof(qId));
if (p == NULL) { if (p == NULL) {
code = TSDB_CODE_RPC_NO_STATE; code = TSDB_CODE_RPC_NO_STATE;
tTrace("conn %p recv release, and releady release by server qid%ld", pConn, qId); tTrace("conn %p recv release, and releady release by server qid:%ld", pConn, qId);
// notify cli already release, cli release resouce
} else { } else {
SSvrRegArg* arg = p; SSvrRegArg* arg = p;
(pInst->cfp)(pInst->parent, &(arg->msg), NULL); (pInst->cfp)(pInst->parent, &(arg->msg), NULL);
tTrace("conn %p recv release, notify server app, qid%ld", pConn, qId); tTrace("conn %p recv release, notify server app, qid:%ld", pConn, qId);
(void)taosHashRemove(pConn->pQTable, &qId, sizeof(qId)); (void)taosHashRemove(pConn->pQTable, &qId, sizeof(qId));
tTrace("conn %p clear state,qid:%ld", pConn, qId);
} }
STransMsg tmsg = {.code = code, STransMsg tmsg = {.code = code,
@ -458,7 +459,7 @@ static int32_t uvMayHandleReleaseReq(SSvrConn* pConn, STransMsgHead* pHead) {
uvStartSendRespImpl(srvMsg); uvStartSendRespImpl(srvMsg);
taosMemoryFree(pHead); taosMemoryFree(pHead);
return 1; return code;
} }
return 0; return 0;
} }
@ -501,6 +502,7 @@ static bool uvHandleReq(SSvrConn* pConn) {
return false; return false;
} }
if (uvConnMayGetUserInfo(pConn, &pHead, &msgLen) == true) { if (uvConnMayGetUserInfo(pConn, &pHead, &msgLen) == true) {
tDebug("%s conn %p get user info", transLabel(pInst), pConn);
} }
if (resetBuf == 0) { if (resetBuf == 0) {
@ -833,7 +835,7 @@ int32_t uvMayHandleReleaseResp(SSvrRespMsg* pMsg) {
if (pMsg->msg.msgType == TDMT_SCH_TASK_RELEASE && qid > 0) { if (pMsg->msg.msgType == TDMT_SCH_TASK_RELEASE && qid > 0) {
SSvrRegArg* p = taosHashGet(pConn->pQTable, &qid, sizeof(qid)); SSvrRegArg* p = taosHashGet(pConn->pQTable, &qid, sizeof(qid));
if (p == NULL) { if (p == NULL) {
tError("%s conn %p already release qid %ld", transLabel(pConn->pInst), pConn, qid); tError("%s conn %p already release qid:%ld", transLabel(pConn->pInst), pConn, qid);
return TSDB_CODE_RPC_NO_STATE; return TSDB_CODE_RPC_NO_STATE;
} else { } else {
transFreeMsg(p->msg.pCont); transFreeMsg(p->msg.pCont);