Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit 337d429

Browse files
knizhnikkelvich
authored andcommitted
Fix wrong condition in DisableNode
1 parent 05d5395 commit 337d429

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

multimaster.c

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1601,8 +1601,9 @@ bool MtmRefreshClusterStatus(bool nowait, int testNodeId)
16011601
timestamp_t now = MtmGetSystemTime();
16021602
for (i = 0, mask = disabled; mask != 0; i++, mask >>= 1) {
16031603
if (mask & 1) {
1604-
if (Mtm->nodes[i].lastStatusChangeTime + MSEC_TO_USEC(MtmNodeDisableDelay) > now)
1604+
if (Mtm->nodes[i].lastStatusChangeTime + MSEC_TO_USEC(MtmNodeDisableDelay) < now) {
16051605
MtmDisableNode(i+1);
1606+
}
16061607
}
16071608
}
16081609
}
@@ -2580,7 +2581,7 @@ MtmReplicationMode MtmGetReplicationMode(int nodeId, sig_atomic_t volatile* shut
25802581
MtmSleep(STATUS_POLL_DELAY);
25812582
}
25822583
if (recovery) {
2583-
MTM_LOG1("%d: Restart replication frim node %d after end of recovery", MyProcPid, nodeId);
2584+
MTM_LOG1("%d: Restart replication from node %d after end of recovery", MyProcPid, nodeId);
25842585
} else {
25852586
MTM_LOG1("%d: Continue replication from node %d", MyProcPid, nodeId);
25862587
}

0 commit comments

Comments
 (0)