diff --git a/src/mnode/src/mgmtDb.c b/src/mnode/src/mgmtDb.c index ae241f2320704e430a792d5c56db621a8115e31c..3e7577af0696ef591217224d3e08403f16fd5097 100644 --- a/src/mnode/src/mgmtDb.c +++ b/src/mnode/src/mgmtDb.c @@ -351,8 +351,27 @@ bool mgmtCheckIsMonitorDB(char *db, char *monitordb) { return (strncasecmp(dbName, monitordb, len) == 0 && len == strlen(monitordb)); } +#if 0 +void mgmtPrintVgroups(SDbObj *pDb, char *oper) { + mPrint("db:%s, vgroup link from head, oper:%s", pDb->name, oper); + SVgObj *pVgroup = pDb->pHead; + while (pVgroup != NULL) { + mPrint("vgId:%d", pVgroup->vgId); + pVgroup = pVgroup->next; + } + + mPrint("db:%s, vgroup link from tail", pDb->name, pDb->numOfVgroups); + pVgroup = pDb->pTail; + while (pVgroup != NULL) { + mPrint("vgId:%d", pVgroup->vgId); + pVgroup = pVgroup->prev; + } +} +#endif + void mgmtAddVgroupIntoDb(SVgObj *pVgroup) { SDbObj *pDb = pVgroup->pDb; + pVgroup->next = pDb->pHead; pVgroup->prev = NULL; diff --git a/src/mnode/src/mgmtVgroup.c b/src/mnode/src/mgmtVgroup.c index d2580fc4ca525704270e2f0bf439edd88fa72cc6..839dce5c38a65528e1ea3c0f8c691738476bce45 100644 --- a/src/mnode/src/mgmtVgroup.c +++ b/src/mnode/src/mgmtVgroup.c @@ -516,7 +516,7 @@ void mgmtAddTableIntoVgroup(SVgObj *pVgroup, SChildTableObj *pTable) { } if (pVgroup->numOfTables >= pVgroup->pDb->cfg.maxTables) { - mgmtAddVgroupIntoDbTail(pVgroup); + mgmtMoveVgroupToTail(pVgroup); } mgmtIncVgroupRef(pVgroup); @@ -529,10 +529,7 @@ void mgmtRemoveTableFromVgroup(SVgObj *pVgroup, SChildTableObj *pTable) { pVgroup->numOfTables--; } - if (pVgroup->numOfTables == 0) { - mgmtRemoveVgroupFromDb(pVgroup); - } - + mgmtMoveVgroupToHead(pVgroup); mgmtDecVgroupRef(pVgroup); }