PostgreSQL Source Code  git master
Go to the documentation of this file.
1 /*-------------------------------------------------------------------------
2  *
3  * twophase.h
4  * Two-phase-commit related declarations.
5  *
6  *
7  * Portions Copyright (c) 1996-2023, 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
17 #include "access/xact.h"
18 #include "access/xlogdefs.h"
19 #include "datatype/timestamp.h"
20 #include "storage/lock.h"
22 /*
23  * GlobalTransactionData is defined in twophase.c; other places have no
24  * business knowing the internal definition.
25  */
28 /* GUC variable */
31 extern Size TwoPhaseShmemSize(void);
32 extern void TwoPhaseShmemInit(void);
34 extern void AtAbort_Twophase(void);
35 extern void PostPrepare_Twophase(void);
38  bool *have_more);
39 extern PGPROC *TwoPhaseGetDummyProc(TransactionId xid, bool lock_held);
44  Oid owner, Oid databaseid);
46 extern void StartPrepare(GlobalTransaction gxact);
47 extern void EndPrepare(GlobalTransaction gxact);
51  int *nxids_p);
52 extern void StandbyRecoverPreparedTransactions(void);
53 extern void RecoverPreparedTransactions(void);
55 extern void CheckPointTwoPhase(XLogRecPtr redo_horizon);
57 extern void FinishPreparedTransaction(const char *gid, bool isCommit);
59 extern void PrepareRedoAdd(char *buf, XLogRecPtr start_lsn,
60  XLogRecPtr end_lsn, RepOriginId origin_id);
61 extern void PrepareRedoRemove(TransactionId xid, bool giveWarning);
62 extern void restoreTwoPhaseData(void);
63 extern bool LookupGXact(const char *gid, XLogRecPtr prepare_end_lsn,
64  TimestampTz origin_prepare_timestamp);
65 #endif /* TWOPHASE_H */
int BackendId
Definition: backendid.h:21
Definition: c.h:1303
uint32 TransactionId
Definition: c.h:636
size_t Size
Definition: c.h:589
int64 TimestampTz
Definition: timestamp.h:39
static char * buf
Definition: pg_test_fsync.c:67
unsigned int Oid
Definition: postgres_ext.h:31
TimestampTz prepared_at
Definition: twophase.c:154
TransactionId xid
Definition: twophase.c:165
XLogRecPtr prepare_end_lsn
Definition: twophase.c:164
char gid[GIDSIZE]
Definition: twophase.c:172
Definition: proc.h:162
void RecoverPreparedTransactions(void)
Definition: twophase.c:2059
struct GlobalTransactionData * GlobalTransaction
Definition: twophase.h:26
void restoreTwoPhaseData(void)
Definition: twophase.c:1875
bool LookupGXact(const char *gid, XLogRecPtr prepare_end_lsn, TimestampTz origin_prepare_timestamp)
Definition: twophase.c:2577
Size TwoPhaseShmemSize(void)
Definition: twophase.c:240
void AtAbort_Twophase(void)
Definition: twophase.c:321
BackendId TwoPhaseGetDummyBackendId(TransactionId xid, bool lock_held)
Definition: twophase.c:918
void FinishPreparedTransaction(const char *gid, bool isCommit)
Definition: twophase.c:1480
TransactionId TwoPhaseGetXidByVirtualXID(VirtualTransactionId vxid, bool *have_more)
Definition: twophase.c:870
void PrepareRedoRemove(TransactionId xid, bool giveWarning)
Definition: twophase.c:2525
void EndPrepare(GlobalTransaction gxact)
Definition: twophase.c:1135
TransactionId PrescanPreparedTransactions(TransactionId **xids_p, int *nxids_p)
Definition: twophase.c:1937
void StartPrepare(GlobalTransaction gxact)
Definition: twophase.c:1042
PGPROC * TwoPhaseGetDummyProc(TransactionId xid, bool lock_held)
Definition: twophase.c:933
void TwoPhaseShmemInit(void)
Definition: twophase.c:256
void PrepareRedoAdd(char *buf, XLogRecPtr start_lsn, XLogRecPtr end_lsn, RepOriginId origin_id)
Definition: twophase.c:2455
void StandbyRecoverPreparedTransactions(void)
Definition: twophase.c:2018
void PostPrepare_Twophase(void)
Definition: twophase.c:361
void CheckPointTwoPhase(XLogRecPtr redo_horizon)
Definition: twophase.c:1793
bool StandbyTransactionIdIsPrepared(TransactionId xid)
Definition: twophase.c:1452
GlobalTransaction MarkAsPreparing(TransactionId xid, const char *gid, TimestampTz prepared_at, Oid owner, Oid databaseid)
Definition: twophase.c:376
PGDLLIMPORT int max_prepared_xacts
Definition: twophase.c:117
uint16 RepOriginId
Definition: xlogdefs.h:65
uint64 XLogRecPtr
Definition: xlogdefs.h:21