From c60c3b238e216712f92f3b8553c4a912dc0f6465 Mon Sep 17 00:00:00 2001 From: dmchen Date: Thu, 17 Oct 2024 06:36:20 +0000 Subject: [PATCH] feat/TS-4785-redo-multi-create-db-fix-check --- source/dnode/mgmt/mgmt_vnode/src/vmHandle.c | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) diff --git a/source/dnode/mgmt/mgmt_vnode/src/vmHandle.c b/source/dnode/mgmt/mgmt_vnode/src/vmHandle.c index 834b43c380..7e950ef1be 100644 --- a/source/dnode/mgmt/mgmt_vnode/src/vmHandle.c +++ b/source/dnode/mgmt/mgmt_vnode/src/vmHandle.c @@ -415,14 +415,24 @@ int32_t vmProcessCreateVnodeReq(SVnodeMgmt *pMgmt, SRpcMsg *pMsg) { goto _OVER; } - taosThreadMutexLock(&pMgmt->createLock); + code = taosThreadMutexLock(&pMgmt->createLock); + if (code != 0) { + dError("vgId:%d, failed to lock since %s", req.vgId, tstrerror(code)); + goto _OVER; + } code = vmWriteVnodeListToFile(pMgmt); if (code != 0) { code = terrno != 0 ? terrno : code; - taosThreadMutexUnlock(&pMgmt->createLock); + int32_t ret = taosThreadMutexUnlock(&pMgmt->createLock); + if (ret != 0) { + dError("vgId:%d, failed to unlock since %s", req.vgId, tstrerror(ret)); + } goto _OVER; } - taosThreadMutexUnlock(&pMgmt->createLock); + int32_t ret = taosThreadMutexUnlock(&pMgmt->createLock); + if (ret != 0) { + dError("vgId:%d, failed to unlock since %s", req.vgId, tstrerror(ret)); + } _OVER: if (code != 0) {