TD-1948
This commit is contained in:
parent
9fd8ed5239
commit
d5cd0ae9cb
|
@ -576,6 +576,7 @@ static void syncChooseMaster(SSyncNode *pNode) {
|
||||||
sInfo("vgId:%d, start to work as master", pNode->vgId);
|
sInfo("vgId:%d, start to work as master", pNode->vgId);
|
||||||
nodeRole = TAOS_SYNC_ROLE_MASTER;
|
nodeRole = TAOS_SYNC_ROLE_MASTER;
|
||||||
|
|
||||||
|
#if 0
|
||||||
for (int32_t i = 0; i < pNode->replica; ++i) {
|
for (int32_t i = 0; i < pNode->replica; ++i) {
|
||||||
pPeer = pNode->peerInfo[i];
|
pPeer = pNode->peerInfo[i];
|
||||||
if (pPeer->version == nodeVersion) {
|
if (pPeer->version == nodeVersion) {
|
||||||
|
@ -584,7 +585,7 @@ static void syncChooseMaster(SSyncNode *pNode) {
|
||||||
sInfo("%s, it shall work as slave", pPeer->id);
|
sInfo("%s, it shall work as slave", pPeer->id);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
#endif
|
||||||
syncResetFlowCtrl(pNode);
|
syncResetFlowCtrl(pNode);
|
||||||
(*pNode->notifyRole)(pNode->ahandle, nodeRole);
|
(*pNode->notifyRole)(pNode->ahandle, nodeRole);
|
||||||
} else {
|
} else {
|
||||||
|
|
Loading…
Reference in New Issue