Commit5a72566

authored and

committed

Use origin LSN for recovery

1 parentd0d17dc commit5a72566Copy full SHA for 5a72566

File tree

-0

lines changed

-0

lines changed

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -2429,6 +2429,7 @@ void MtmReceiverStarted(int nodeId)`
`2429`	`2429`	`*/`
`2430`	`2430`	`MtmReplicationModeMtmGetReplicationMode(intnodeId,sig_atomic_tvolatile*shutdown)`
`2431`	`2431`	`{`
	`2432`	`+inti;`
`2432`	`2433`	`boolrecovery= false;`
`2433`	`2434`
`2434`	`2435`	`while (Mtm->status!=MTM_CONNECTED&&Mtm->status!=MTM_ONLINE)`
`@@ -2448,6 +2449,9 @@ MtmReplicationMode MtmGetReplicationMode(int nodeId, sig_atomic_t volatile* shut`
`2448`	`2449`	`Mtm->recoveryCount+=1;`
`2449`	`2450`	`Mtm->pglogicalNodeMask=0;`
`2450`	`2451`	`FinishAllPreparedTransactions(false);`
	`2452`	`+for (i=0;i<Mtm->nAllNodes;i++) {`
	`2453`	`+Mtm->nodes[i].restartLsn=0;`
	`2454`	`+}`
`2451`	`2455`	`returnREPLMODE_RECOVERY;`
`2452`	`2456`	`}`
`2453`	`2457`	`}`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -145,6 +145,7 @@ typedef struct`
`145`	`145`	`intreceiverPid;`
`146`	`146`	`XLogRecPtrflushPos;`
`147`	`147`	`csn_toldestSnapshot;/* Oldest snapshot used by active transactions at this node */`
	`148`	`+XLogRecPtrrestartLsn;`
`148`	`149`	`}MtmNodeInfo;`
`149`	`150`
`150`	`151`	`typedefstructMtmTransState`

Comments

(0)