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

fix: semphore leak

This commit is contained in:
xsren 2024-09-29 23:40:19 +08:00
parent 6d0d2ae039
commit 5a85303c37
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
source/libs/catalog/src/ctgCache.c
View File

@ -906,7 +906,7 @@ int32_t ctgEnqueue(SCatalog *pCtg, SCtgCacheOperation *operation) {
if (gCtgMgmt.queue.stopQueue) { if (gCtgMgmt.queue.stopQueue) {
ctgFreeQNode(node); ctgFreeQNode(node);
CTG_UNLOCK(CTG_WRITE, &gCtgMgmt.queue.qlock); CTG_UNLOCK(CTG_WRITE, &gCtgMgmt.queue.qlock);
CTG_RET(TSDB_CODE_CTG_EXIT); CTG_ERR_JRET(TSDB_CODE_CTG_EXIT);
} }
gCtgMgmt.queue.tail->next = node; gCtgMgmt.queue.tail->next = node;
@ -924,7 +924,7 @@ int32_t ctgEnqueue(SCatalog *pCtg, SCtgCacheOperation *operation) {
code = tsem_post(&gCtgMgmt.queue.reqSem); code = tsem_post(&gCtgMgmt.queue.reqSem);
if (TSDB_CODE_SUCCESS != code) { if (TSDB_CODE_SUCCESS != code) {
qError("tsem_post failed, code:%x", code); qError("tsem_post failed, code:%x", code);
CTG_RET(code); CTG_ERR_JRET(code);
} }
if (syncOp) { if (syncOp) {
@ -935,9 +935,14 @@ int32_t ctgEnqueue(SCatalog *pCtg, SCtgCacheOperation *operation) {
if (!operation->unLocked) { if (!operation->unLocked) {
CTG_LOCK(CTG_READ, &gCtgMgmt.lock); CTG_LOCK(CTG_READ, &gCtgMgmt.lock);
} }
tsem_destroy(&operation->rspSem);
taosMemoryFree(operation); taosMemoryFree(operation);
} }
_return:
if (syncOp) {
tsem_destroy(&operation->rspSem);
}
return code; return code;
} }