diff --git a/source/dnode/mnode/impl/src/mndUser.c b/source/dnode/mnode/impl/src/mndUser.c index 65c1cfbea2240d2347eafd79add3bcc740621e85..c59d23d252163dd964018b4ba0b31af024a8acde 100644 --- a/source/dnode/mnode/impl/src/mndUser.c +++ b/source/dnode/mnode/impl/src/mndUser.c @@ -863,6 +863,7 @@ static int32_t mndProcessAlterUserReq(SRpcMsg *pReq) { mndReleaseDb(pMnode, pDb); goto _OVER; } + mndReleaseDb(pMnode, pDb); } else { while (1) { SDbObj *pDb = NULL; @@ -887,6 +888,7 @@ static int32_t mndProcessAlterUserReq(SRpcMsg *pReq) { mndReleaseDb(pMnode, pDb); goto _OVER; } + mndReleaseDb(pMnode, pDb); } else { while (1) { SDbObj *pDb = NULL; @@ -908,6 +910,7 @@ static int32_t mndProcessAlterUserReq(SRpcMsg *pReq) { goto _OVER; } taosHashRemove(newUser.readDbs, alterReq.objname, len); + mndReleaseDb(pMnode, pDb); } else { taosHashClear(newUser.readDbs); } @@ -922,6 +925,7 @@ static int32_t mndProcessAlterUserReq(SRpcMsg *pReq) { goto _OVER; } taosHashRemove(newUser.writeDbs, alterReq.objname, len); + mndReleaseDb(pMnode, pDb); } else { taosHashClear(newUser.writeDbs); }