1 /*------------------------------------------------------------------------- 2 * 3 * twophase.h 4 * Two-phase-commit related declarations. 5 * 6 * 7 * Portions Copyright (c) 1996-2017, PostgreSQL Global Development Group 8 * Portions Copyright (c) 1994, Regents of the University of California 9 * 10 * src/include/access/twophase.h 11 * 12 *------------------------------------------------------------------------- 13 */ 14 #ifndef TWOPHASE_H 15 #define TWOPHASE_H 16 17 #include "access/xlogdefs.h" 18 #include "datatype/timestamp.h" 19 #include "storage/lock.h" 20 21 /* 22 * GlobalTransactionData is defined in twophase.c; other places have no 23 * business knowing the internal definition. 24 */ 25 typedef struct GlobalTransactionData *GlobalTransaction; 26 27 /* GUC variable */ 28 extern PGDLLIMPORT int max_prepared_xacts; 29 30 extern Size TwoPhaseShmemSize(void); 31 extern void TwoPhaseShmemInit(void); 32 33 extern void AtAbort_Twophase(void); 34 extern void PostPrepare_Twophase(void); 35 36 extern TransactionId TwoPhaseGetXidByVirtualXID(VirtualTransactionId vxid, 37 bool *have_more); 38 extern PGPROC *TwoPhaseGetDummyProc(TransactionId xid); 39 extern BackendId TwoPhaseGetDummyBackendId(TransactionId xid); 40 41 extern GlobalTransaction MarkAsPreparing(TransactionId xid, const char *gid, 42 TimestampTz prepared_at, 43 Oid owner, Oid databaseid); 44 45 extern void StartPrepare(GlobalTransaction gxact); 46 extern void EndPrepare(GlobalTransaction gxact); 47 extern bool StandbyTransactionIdIsPrepared(TransactionId xid); 48 49 extern TransactionId PrescanPreparedTransactions(TransactionId **xids_p, 50 int *nxids_p); 51 extern void StandbyRecoverPreparedTransactions(void); 52 extern void RecoverPreparedTransactions(void); 53 54 extern void CheckPointTwoPhase(XLogRecPtr redo_horizon); 55 56 extern void FinishPreparedTransaction(const char *gid, bool isCommit); 57 58 extern void PrepareRedoAdd(char *buf, XLogRecPtr start_lsn, 59 XLogRecPtr end_lsn); 60 extern void PrepareRedoRemove(TransactionId xid, bool giveWarning); 61 extern void restoreTwoPhaseData(void); 62 #endif /* TWOPHASE_H */ 63