PostgreSQL Source Code: src/include/access/twophase.h Source File

PostgreSQL Source Code git master
twophase.h
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-2025, 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/xact.h"
18#include "access/xlogdefs.h"
19#include "datatype/timestamp.h"
20#include "storage/lock.h"
21
22/*
23 * GlobalTransactionData is defined in twophase.c; other places have no
24 * business knowing the internal definition.
25 */
26 typedef struct GlobalTransactionData *GlobalTransaction;
27
28/* GUC variable */
29extern PGDLLIMPORT int max_prepared_xacts;
30
31extern Size TwoPhaseShmemSize(void);
32extern void TwoPhaseShmemInit(void);
33
34extern void AtAbort_Twophase(void);
35extern void PostPrepare_Twophase(void);
36
37extern TransactionId TwoPhaseGetXidByVirtualXID(VirtualTransactionId vxid,
38 bool *have_more);
39extern PGPROC *TwoPhaseGetDummyProc(FullTransactionId fxid, bool lock_held);
40extern int TwoPhaseGetDummyProcNumber(FullTransactionId fxid, bool lock_held);
41
42extern GlobalTransaction MarkAsPreparing(FullTransactionId fxid, const char *gid,
43 TimestampTz prepared_at,
44 Oid owner, Oid databaseid);
45
46extern void StartPrepare(GlobalTransaction gxact);
47extern void EndPrepare(GlobalTransaction gxact);
48extern bool StandbyTransactionIdIsPrepared(TransactionId xid);
49
50extern TransactionId PrescanPreparedTransactions(TransactionId **xids_p,
51 int *nxids_p);
52extern void StandbyRecoverPreparedTransactions(void);
53extern void RecoverPreparedTransactions(void);
54
55extern void CheckPointTwoPhase(XLogRecPtr redo_horizon);
56
57extern void FinishPreparedTransaction(const char *gid, bool isCommit);
58
59extern void PrepareRedoAdd(FullTransactionId fxid, char *buf,
60 XLogRecPtr start_lsn, XLogRecPtr end_lsn,
61 RepOriginId origin_id);
62extern void PrepareRedoRemove(TransactionId xid, bool giveWarning);
63extern void restoreTwoPhaseData(void);
64extern bool LookupGXact(const char *gid, XLogRecPtr prepare_end_lsn,
65 TimestampTz origin_prepare_timestamp);
66
67extern void TwoPhaseTransactionGid(Oid subid, TransactionId xid, char *gid_res,
68 int szgid);
69extern bool LookupGXactBySubid(Oid subid);
70
71extern TransactionId TwoPhaseGetOldestXidInCommit(void);
72
73#endif /* TWOPHASE_H */
#define PGDLLIMPORT
Definition: c.h:1319
uint32 TransactionId
Definition: c.h:657
size_t Size
Definition: c.h:610
int64 TimestampTz
Definition: timestamp.h:39
static char * buf
Definition: pg_test_fsync.c:72
unsigned int Oid
Definition: postgres_ext.h:32
TimestampTz prepared_at
Definition: twophase.c:152
XLogRecPtr prepare_end_lsn
Definition: twophase.c:162
FullTransactionId fxid
Definition: twophase.c:163
char gid[GIDSIZE]
Definition: twophase.c:170
Definition: proc.h:179
TransactionId TwoPhaseGetOldestXidInCommit(void)
Definition: twophase.c:2829
void TwoPhaseTransactionGid(Oid subid, TransactionId xid, char *gid_res, int szgid)
Definition: twophase.c:2747
void RecoverPreparedTransactions(void)
Definition: twophase.c:2083
struct GlobalTransactionData * GlobalTransaction
Definition: twophase.h:26
void restoreTwoPhaseData(void)
Definition: twophase.c:1904
bool LookupGXact(const char *gid, XLogRecPtr prepare_end_lsn, TimestampTz origin_prepare_timestamp)
Definition: twophase.c:2688
Size TwoPhaseShmemSize(void)
Definition: twophase.c:239
GlobalTransaction MarkAsPreparing(FullTransactionId fxid, const char *gid, TimestampTz prepared_at, Oid owner, Oid databaseid)
Definition: twophase.c:361
void AtAbort_Twophase(void)
Definition: twophase.c:306
int TwoPhaseGetDummyProcNumber(FullTransactionId fxid, bool lock_held)
Definition: twophase.c:908
void FinishPreparedTransaction(const char *gid, bool isCommit)
Definition: twophase.c:1497
TransactionId TwoPhaseGetXidByVirtualXID(VirtualTransactionId vxid, bool *have_more)
Definition: twophase.c:857
void PrepareRedoRemove(TransactionId xid, bool giveWarning)
Definition: twophase.c:2664
void EndPrepare(GlobalTransaction gxact)
Definition: twophase.c:1145
TransactionId PrescanPreparedTransactions(TransactionId **xids_p, int *nxids_p)
Definition: twophase.c:1966
void StartPrepare(GlobalTransaction gxact)
Definition: twophase.c:1052
void TwoPhaseShmemInit(void)
Definition: twophase.c:255
void StandbyRecoverPreparedTransactions(void)
Definition: twophase.c:2045
void PostPrepare_Twophase(void)
Definition: twophase.c:346
bool LookupGXactBySubid(Oid subid)
Definition: twophase.c:2797
PGPROC * TwoPhaseGetDummyProc(FullTransactionId fxid, bool lock_held)
Definition: twophase.c:923
void CheckPointTwoPhase(XLogRecPtr redo_horizon)
Definition: twophase.c:1822
bool StandbyTransactionIdIsPrepared(TransactionId xid)
Definition: twophase.c:1467
PGDLLIMPORT int max_prepared_xacts
Definition: twophase.c:116
void PrepareRedoAdd(FullTransactionId fxid, char *buf, XLogRecPtr start_lsn, XLogRecPtr end_lsn, RepOriginId origin_id)
Definition: twophase.c:2507
uint16 RepOriginId
Definition: xlogdefs.h:68
uint64 XLogRecPtr
Definition: xlogdefs.h:21

AltStyle によって変換されたページ (->オリジナル) /