@@ -1469,6 +1469,7 @@ static void MtmStartRecovery()
14691469{
14701470MtmLock (LW_EXCLUSIVE );
14711471BIT_SET (Mtm -> disabledNodeMask ,MtmNodeId - 1 );
1472+ Mtm -> nConfigChanges += 1 ;
14721473MtmSwitchClusterMode (MTM_RECOVERY );
14731474Mtm -> recoveredLSN = InvalidXLogRecPtr ;
14741475MtmUnlock ();
@@ -1724,6 +1725,7 @@ static void MtmDisableNode(int nodeId)
17241725elog (WARNING ,"Disable node %d at xlog position %lx, last status change time %d msec ago" ,nodeId ,GetXLogInsertRecPtr (),
17251726 (int )USEC_TO_MSEC (now - Mtm -> nodes [nodeId - 1 ].lastStatusChangeTime ));
17261727BIT_SET (Mtm -> disabledNodeMask ,nodeId - 1 );
1728+ Mtm -> nConfigChanges += 1 ;
17271729Mtm -> nodes [nodeId - 1 ].timeline += 1 ;
17281730Mtm -> nodes [nodeId - 1 ].lastStatusChangeTime = now ;
17291731Mtm -> nodes [nodeId - 1 ].lastHeartbeat = 0 ;/* defuse watchdog until first heartbeat is received */
@@ -1744,6 +1746,7 @@ static void MtmEnableNode(int nodeId)
17441746{
17451747BIT_CLEAR (Mtm -> disabledNodeMask ,nodeId - 1 );
17461748BIT_CLEAR (Mtm -> reconnectMask ,nodeId - 1 );
1749+ Mtm -> nConfigChanges += 1 ;
17471750Mtm -> nodes [nodeId - 1 ].lastStatusChangeTime = MtmGetSystemTime ();
17481751Mtm -> nodes [nodeId - 1 ].lastHeartbeat = 0 ;/* defuse watchdog until first heartbeat is received */
17491752if (nodeId != MtmNodeId ) {
@@ -1765,6 +1768,7 @@ void MtmRecoveryCompleted(void)
17651768Mtm -> recoverySlot = 0 ;
17661769Mtm -> recoveredLSN = GetXLogInsertRecPtr ();
17671770BIT_CLEAR (Mtm -> disabledNodeMask ,MtmNodeId - 1 );
1771+ Mtm -> nConfigChanges += 1 ;
17681772Mtm -> reconnectMask |=SELF_CONNECTIVITY_MASK ;/* try to reestablish all connections */
17691773Mtm -> nodes [MtmNodeId - 1 ].lastStatusChangeTime = MtmGetSystemTime ();
17701774for (i = 0 ;i < Mtm -> nAllNodes ;i ++ ) {
@@ -1868,7 +1872,6 @@ bool MtmRecoveryCaughtUp(int nodeId, XLogRecPtr slotLSN)
18681872/* We are lucky: caught-up without locking cluster! */
18691873}
18701874MtmEnableNode (nodeId );
1871- Mtm -> nConfigChanges += 1 ;
18721875caughtUp = true;
18731876}else if (!BIT_CHECK (Mtm -> nodeLockerMask ,nodeId - 1 )
18741877&& slotLSN + MtmMinRecoveryLag > walLSN )
@@ -1953,6 +1956,7 @@ MtmCheckClusterLock()
19531956Assert (Mtm -> walSenderLockerMask == 0 );
19541957Assert ((Mtm -> nodeLockerMask & Mtm -> disabledNodeMask )== Mtm -> nodeLockerMask );
19551958Mtm -> disabledNodeMask &= ~Mtm -> nodeLockerMask ;
1959+ Mtm -> nConfigChanges += 1 ;
19561960Mtm -> nLiveNodes += Mtm -> nLockers ;
19571961Mtm -> nLockers = 0 ;
19581962Mtm -> nodeLockerMask = 0 ;
@@ -2098,7 +2102,6 @@ void MtmRefreshClusterStatus()
20982102 */
20992103void MtmCheckQuorum (void )
21002104{
2101- Mtm -> nConfigChanges += 1 ;
21022105if (Mtm -> nLiveNodes < Mtm -> nAllNodes /2 + 1 ) {
21032106if (Mtm -> status == MTM_ONLINE ) {/* out of quorum */
21042107elog (WARNING ,"Node is in minority: disabled mask %lx" , (long )Mtm -> disabledNodeMask );
@@ -3655,6 +3658,7 @@ mtm_add_node(PG_FUNCTION_ARGS)
36553658Mtm -> nodes [nodeId ].oldestSnapshot = 0 ;
36563659
36573660BIT_SET (Mtm -> disabledNodeMask ,nodeId );
3661+ Mtm -> nConfigChanges += 1 ;
36583662Mtm -> nAllNodes += 1 ;
36593663MtmUnlock ();
36603664