[TD-3657]<fix>: sdbUpdateMnodeRoles before check mnodeAllOnline
This commit is contained in:
parent
0ebd1a9855
commit
65f01a454a
|
@ -628,6 +628,11 @@ static int32_t mnodeProcessDnodeStatusMsg(SMnodeMsg *pMsg) {
|
||||||
bnNotify();
|
bnNotify();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (!tsEnableBalance) {
|
||||||
|
int32_t numOfMnodes = mnodeGetMnodesNum();
|
||||||
|
if (numOfMnodes < tsNumOfMnodes) bnNotify();
|
||||||
|
}
|
||||||
|
|
||||||
if (openVnodes != pDnode->openVnodes) {
|
if (openVnodes != pDnode->openVnodes) {
|
||||||
mnodeCheckUnCreatedVgroup(pDnode, pStatus->load, openVnodes);
|
mnodeCheckUnCreatedVgroup(pDnode, pStatus->load, openVnodes);
|
||||||
}
|
}
|
||||||
|
|
|
@ -381,6 +381,8 @@ static bool mnodeAllOnline() {
|
||||||
void *pIter = NULL;
|
void *pIter = NULL;
|
||||||
bool allOnline = true;
|
bool allOnline = true;
|
||||||
|
|
||||||
|
sdbUpdateMnodeRoles();
|
||||||
|
|
||||||
while (1) {
|
while (1) {
|
||||||
SMnodeObj *pMnode = NULL;
|
SMnodeObj *pMnode = NULL;
|
||||||
pIter = mnodeGetNextMnode(pIter, &pMnode);
|
pIter = mnodeGetNextMnode(pIter, &pMnode);
|
||||||
|
|
Loading…
Reference in New Issue