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

Commit d531bb5

Browse files
committed
Fix calculation of recoveredLSN
1 parent 1ae54f5 commit d531bb5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

contrib/mmts/multimaster.c

+1-1
Original file line numberDiff line numberDiff line change
@@ -1535,6 +1535,7 @@ void MtmRecoveryCompleted(void)
15351535
MtmNodeId, (long long) Mtm->disabledNodeMask, (long long) Mtm->connectivityMask, Mtm->nLiveNodes);
15361536
MtmLock(LW_EXCLUSIVE);
15371537
Mtm->recoverySlot = 0;
1538+
Mtm->recoveredLSN = GetXLogInsertRecPtr();
15381539
BIT_CLEAR(Mtm->disabledNodeMask, MtmNodeId-1);
15391540
Mtm->reconnectMask |= Mtm->connectivityMask; /* try to reestablish all connections */
15401541
Mtm->nodes[MtmNodeId-1].lastStatusChangeTime = MtmGetSystemTime();
@@ -1628,7 +1629,6 @@ bool MtmRecoveryCaughtUp(int nodeId, XLogRecPtr slotLSN)
16281629
MTM_LOG1("%d: node %d is caugth-up without locking cluster", MyProcPid, nodeId);
16291630
/* We are lucky: caugth-up without locking cluster! */
16301631
}
1631-
Mtm->recoveredLSN = walLSN;
16321632
MtmEnableNode(nodeId);
16331633
Mtm->nConfigChanges += 1;
16341634
caughtUp = true;

0 commit comments

Comments
 (0)