Commit94f2024

authored and

committed

Fix calculation of recoveredLSN

1 parent8d58d05 commit94f2024Copy full SHA for 94f2024

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1535,6 +1535,7 @@ void MtmRecoveryCompleted(void)`
`1535`	`1535`	`MtmNodeId, (long long)Mtm->disabledNodeMask, (long long)Mtm->connectivityMask,Mtm->nLiveNodes);`
`1536`	`1536`	`MtmLock(LW_EXCLUSIVE);`
`1537`	`1537`	`Mtm->recoverySlot=0;`
	`1538`	`+Mtm->recoveredLSN=GetXLogInsertRecPtr();`
`1538`	`1539`	`BIT_CLEAR(Mtm->disabledNodeMask,MtmNodeId-1);`
`1539`	`1540`	`Mtm->reconnectMask \|=Mtm->connectivityMask;/* try to reestablish all connections */`
`1540`	`1541`	`Mtm->nodes[MtmNodeId-1].lastStatusChangeTime=MtmGetSystemTime();`
`@@ -1628,7 +1629,6 @@ bool MtmRecoveryCaughtUp(int nodeId, XLogRecPtr slotLSN)`
`1628`	`1629`	`MTM_LOG1("%d: node %d is caugth-up without locking cluster",MyProcPid,nodeId);`
`1629`	`1630`	`/* We are lucky: caugth-up without locking cluster! */`
`1630`	`1631`	`}`
`1631`		`-Mtm->recoveredLSN=walLSN;`
`1632`	`1632`	`MtmEnableNode(nodeId);`
`1633`	`1633`	`Mtm->nConfigChanges+=1;`
`1634`	`1634`	`caughtUp= true;`

Comments

(0)