Commit305e4bd

committed

Expose global snapshot funcs for (user-defined) 2PC on coordinator.

1 parent1896708 commit305e4bdCopy full SHA for 305e4bd

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -2548,7 +2548,7 @@ PrepareRedoRemove(TransactionId xid, bool giveWarning)`
`2548`	`2548`	`* This function is a counterpart of GlobalSnapshotPrepareCurrent() for`
`2549`	`2549`	`* twophase transactions.`
`2550`	`2550`	`*/`
`2551`		`-staticGlobalCSN`
	`2551`	`+GlobalCSN`
`2552`	`2552`	`GlobalSnapshotPrepareTwophase(constchar*gid)`
`2553`	`2553`	`{`
`2554`	`2554`	`GlobalTransactiongxact;`
`@@ -2619,7 +2619,7 @@ pg_global_snapshot_prepare(PG_FUNCTION_ARGS)`
`2619`	`2619`	`* This function is a counterpart of GlobalSnapshotAssignCsnCurrent() for`
`2620`	`2620`	`* twophase transactions.`
`2621`	`2621`	`*/`
`2622`		`-staticvoid`
	`2622`	`+void`
`2623`	`2623`	`GlobalSnapshotAssignCsnTwoPhase(constchar*gid,GlobalCSNglobal_csn)`
`2624`	`2624`	`{`
`2625`	`2625`	`GlobalTransactiongxact;`

Lines changed: 5 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -61,4 +61,9 @@ extern void PrepareRedoAdd(char *buf, XLogRecPtr start_lsn,`
`61`	`61`	`XLogRecPtrend_lsn,RepOriginIdorigin_id);`
`62`	`62`	`externvoidPrepareRedoRemove(TransactionIdxid,boolgiveWarning);`
`63`	`63`	`externvoidrestoreTwoPhaseData(void);`
	`64`	`+`
	`65`	`+/* Global snapshots support for 2PC on coordinator */`
	`66`	`+externGlobalCSNGlobalSnapshotPrepareTwophase(constchar*gid);`
	`67`	`+externvoidGlobalSnapshotAssignCsnTwoPhase(constchar*gid,GlobalCSNglobal_csn);`
	`68`	`+`
`64`	`69`	`#endif/* TWOPHASE_H */`

Comments

(0)