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

fix: fix msg disorder issue

This commit is contained in:
dapan1121 2022-07-15 14:40:42 +08:00
parent 5ed51e0010
commit c5675bc821
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/qworker/src/qwUtil.c
View File

@ -472,7 +472,7 @@ void qwDestroyImpl(void *pMgmt) {
QW_GET_QTID(key, qId, tId, eId); QW_GET_QTID(key, qId, tId, eId);
qwFreeTaskCtx(ctx); qwFreeTaskCtx(ctx);
QW_TASK_DLOG("task ctx freed"); QW_TASK_DLOG_E("task ctx freed");
pIter = taosHashIterate(mgmt->ctxHash, pIter); pIter = taosHashIterate(mgmt->ctxHash, pIter);
} }
taosHashCleanup(mgmt->ctxHash); taosHashCleanup(mgmt->ctxHash);

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

@ -1206,7 +1206,13 @@ SCliThrd* transGetWorkThrd(STrans* trans, int64_t handle, bool* validHandle) {
if (idx < 0) return NULL; if (idx < 0) return NULL;
return ((SCliObj*)trans->tcphandle)->pThreadObj[idx]; return ((SCliObj*)trans->tcphandle)->pThreadObj[idx];
} }
return transGetWorkThrdFromHandle(handle, validHandle); SCliThrd* pThrd = transGetWorkThrdFromHandle(handle, validHandle);
if (*validHandle == true && pThrd == NULL) {
int idx = cliRBChoseIdx(trans);
if (idx < 0) return NULL;
pThrd = ((SCliObj*)trans->tcphandle)->pThreadObj[idx];
}
return pThrd;
} }
void transReleaseCliHandle(void* handle) { void transReleaseCliHandle(void* handle) {
int idx = -1; int idx = -1;