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

update default epset

This commit is contained in:
yihaoDeng 2022-05-25 15:47:52 +08:00
parent 8acbb20fb2
commit 5f84203456
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -695,7 +695,7 @@ static void cliHandleUpdate(SCliMsg* pMsg, SCliThrdObj* pThrd) {
pThrd->useDefaultEpSet = true;
pThrd->defaultEpSet = pCtx->epSet;
tsem_post(pCtx->pSem);
// tsem_post(pCtx->pSem);
destroyCmsg(pMsg);
}
@ -1092,8 +1092,8 @@ void transSetDefaultEpSet(void* ahandle, const SEpSet* dst) {
STransConnCtx* pCtx = taosMemoryCalloc(1, sizeof(STransConnCtx));
pCtx->hThrdIdx = i;
pCtx->epSet = *dst;
pCtx->pSem = taosMemoryCalloc(1, sizeof(tsem_t));
tsem_init(pCtx->pSem, 0, 0);
// pCtx->pSem = taosMemoryCalloc(1, sizeof(tsem_t));
// tsem_init(pCtx->pSem, 0, 0);
SCliMsg* cliMsg = taosMemoryCalloc(1, sizeof(SCliMsg));
cliMsg->ctx = pCtx;
@ -1104,10 +1104,10 @@ void transSetDefaultEpSet(void* ahandle, const SEpSet* dst) {
tsem_t* pSem = pCtx->pSem;
transSendAsync(thrd->asyncPool, &(cliMsg->q));
// tsem_wait(pSem);
tsem_wait(pSem);
tsem_destroy(pSem);
taosMemoryFree(pSem);
// tsem_destroy(pSem);
// taosMemoryFree(pSem);
}
}
#endif