Fix wrong condition in DisableNode

knizhnik · knizhnik · commit 383d5ab8529f · 2016-08-31T15:41:15.000+03:00
diff --git a/contrib/mmts/multimaster.c b/contrib/mmts/multimaster.c
@@ -1602,8 +1602,9 @@ bool MtmRefreshClusterStatus(bool nowait, int testNodeId)
 			timestamp_t now = MtmGetSystemTime();
 			for (i = 0, mask = disabled; mask != 0; i++, mask >>= 1) {
 				if (mask & 1) { 
-					if (Mtm->nodes[i].lastStatusChangeTime + MSEC_TO_USEC(MtmNodeDisableDelay) > now) 
+					if (Mtm->nodes[i].lastStatusChangeTime + MSEC_TO_USEC(MtmNodeDisableDelay) < now) {
 						MtmDisableNode(i+1);
+					}
 				}
 			}
 		}		
@@ -2581,7 +2582,7 @@ MtmReplicationMode MtmGetReplicationMode(int nodeId, sig_atomic_t volatile* shut
 		MtmSleep(STATUS_POLL_DELAY);
 	}
 	if (recovery) { 
-		MTM_LOG1("%d: Restart replication frim node %d after end of recovery", MyProcPid, nodeId);
+		MTM_LOG1("%d: Restart replication from node %d after end of recovery", MyProcPid, nodeId);
 	} else { 
 		MTM_LOG1("%d: Continue replication from node %d", MyProcPid, nodeId);
 	}

Original file line number	Diff line number	Diff line change
`@@ -1602,8 +1602,9 @@ bool MtmRefreshClusterStatus(bool nowait, int testNodeId)`
`1602`	`1602`	`timestamp_t now = MtmGetSystemTime();`
`1603`	`1603`	`for (i = 0, mask = disabled; mask != 0; i++, mask >>= 1) {`
`1604`	`1604`	`if (mask & 1) {`
`1605`		`- if (Mtm->nodes[i].lastStatusChangeTime + MSEC_TO_USEC(MtmNodeDisableDelay) > now)`
	`1605`	`+ if (Mtm->nodes[i].lastStatusChangeTime + MSEC_TO_USEC(MtmNodeDisableDelay) < now) {`
`1606`	`1606`	`MtmDisableNode(i+1);`
	`1607`	`+ }`
`1607`	`1608`	`}`
`1608`	`1609`	`}`
`1609`	`1610`	`}`
`@@ -2581,7 +2582,7 @@ MtmReplicationMode MtmGetReplicationMode(int nodeId, sig_atomic_t volatile* shut`
`2581`	`2582`	`MtmSleep(STATUS_POLL_DELAY);`
`2582`	`2583`	`}`
`2583`	`2584`	`if (recovery) {`
`2584`		`- MTM_LOG1("%d: Restart replication frim node %d after end of recovery", MyProcPid, nodeId);`
	`2585`	`+ MTM_LOG1("%d: Restart replication from node %d after end of recovery", MyProcPid, nodeId);`
`2585`	`2586`	`} else {`
`2586`	`2587`	`MTM_LOG1("%d: Continue replication from node %d", MyProcPid, nodeId);`
`2587`	`2588`	`}`