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

add rpc update interface

This commit is contained in:
yihaoDeng 2023-09-01 20:10:59 +08:00
parent 44dcee0ca4
commit bf41ee6bc8
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -190,7 +190,10 @@ static void uvHandleActivityTimeout(uv_timer_t* handle) {
} }
static bool uvHandleReq(SSvrConn* pConn) { static bool uvHandleReq(SSvrConn* pConn) {
STrans* pTransInst = pConn->pTransInst; STrans* pTransInst = pConn->pTransInst;
SWorkThrd* pThrd = pConn->hostThrd;
STransMsgHead* pHead = NULL; STransMsgHead* pHead = NULL;
@ -1219,6 +1222,11 @@ void destroyWorkThrd(SWorkThrd* pThrd) {
void* pIter = taosHashIterate(pThrd->pWhiteList, NULL); void* pIter = taosHashIterate(pThrd->pWhiteList, NULL);
while (pIter) { while (pIter) {
SArray* arr = *(SArray**)pIter;
for (int i = 0; i < taosArrayGetSize(arr); i++) {
char* p = taosArrayGetP(arr, i);
taosMemoryFree(p);
}
pIter = taosHashIterate(pThrd->pWhiteList, pIter); pIter = taosHashIterate(pThrd->pWhiteList, pIter);
} }
taosHashCleanup(pThrd->pWhiteList); taosHashCleanup(pThrd->pWhiteList);