1 /*------------------------------------------------------------------------- 2 * 3 * twophase.h 4 * Two-phase-commit related declarations. 5 * 6 * 7 * Portions Copyright (c) 1996-2016, 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(bool overwriteOK); 52 extern void RecoverPreparedTransactions(void); 53 54 extern void RecreateTwoPhaseFile(TransactionId xid, void *content, int len); 55 extern void RemoveTwoPhaseFile(TransactionId xid, bool giveWarning); 56 57 extern void CheckPointTwoPhase(XLogRecPtr redo_horizon); 58 59 extern void FinishPreparedTransaction(const char *gid, bool isCommit); 60 61 #endif /* TWOPHASE_H */ 62