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

fix/TD-32863-add-creating-hash-fix-case

This commit is contained in:
dmchen 2024-11-13 13:53:55 +08:00
parent b141e0e2ba
commit 156421f8a0
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/dnode/mgmt/mgmt_vnode/src/vmHandle.c
View File

@ -381,6 +381,7 @@ int32_t vmProcessCreateVnodeReq(SVnodeMgmt *pMgmt, SRpcMsg *pMsg) {
if (vnodeCreate(path, &vnodeCfg, diskPrimary, pMgmt->pTfs) < 0) { if (vnodeCreate(path, &vnodeCfg, diskPrimary, pMgmt->pTfs) < 0) {
dError("vgId:%d, failed to create vnode since %s", req.vgId, terrstr()); dError("vgId:%d, failed to create vnode since %s", req.vgId, terrstr());
vmReleaseVnode(pMgmt, pVnode); vmReleaseVnode(pMgmt, pVnode);
vmRemoveFromCreatingHash(pMgmt, req.vgId);
(void)tFreeSCreateVnodeReq(&req); (void)tFreeSCreateVnodeReq(&req);
code = terrno != 0 ? terrno : -1; code = terrno != 0 ? terrno : -1;
return code; return code;
@ -421,9 +422,9 @@ int32_t vmProcessCreateVnodeReq(SVnodeMgmt *pMgmt, SRpcMsg *pMsg) {
goto _OVER; goto _OVER;
} }
_OVER:
vmRemoveFromCreatingHash(pMgmt, req.vgId); vmRemoveFromCreatingHash(pMgmt, req.vgId);
_OVER:
if (code != 0) { if (code != 0) {
int32_t r = 0; int32_t r = 0;
r = taosThreadRwlockWrlock(&pMgmt->lock); r = taosThreadRwlockWrlock(&pMgmt->lock);