twophase.h 1.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  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. #include "access/xlogdefs.h"
  17. #include "datatype/timestamp.h"
  18. #include "storage/lock.h"
  19. /*
  20. * GlobalTransactionData is defined in twophase.c; other places have no
  21. * business knowing the internal definition.
  22. */
  23. typedef struct GlobalTransactionData *GlobalTransaction;
  24. /* GUC variable */
  25. extern int max_prepared_xacts;
  26. extern Size TwoPhaseShmemSize(void);
  27. extern void TwoPhaseShmemInit(void);
  28. extern void AtAbort_Twophase(void);
  29. extern void PostPrepare_Twophase(void);
  30. extern PGPROC *TwoPhaseGetDummyProc(TransactionId xid);
  31. extern BackendId TwoPhaseGetDummyBackendId(TransactionId xid);
  32. extern GlobalTransaction MarkAsPreparing(TransactionId xid, const char *gid,
  33. TimestampTz prepared_at,
  34. Oid owner, Oid databaseid);
  35. extern void StartPrepare(GlobalTransaction gxact);
  36. extern void EndPrepare(GlobalTransaction gxact);
  37. extern bool StandbyTransactionIdIsPrepared(TransactionId xid);
  38. extern TransactionId PrescanPreparedTransactions(TransactionId **xids_p,
  39. int *nxids_p);
  40. extern void StandbyRecoverPreparedTransactions(bool overwriteOK);
  41. extern void RecoverPreparedTransactions(void);
  42. extern void RecreateTwoPhaseFile(TransactionId xid, void *content, int len);
  43. extern void RemoveTwoPhaseFile(TransactionId xid, bool giveWarning);
  44. extern void CheckPointTwoPhase(XLogRecPtr redo_horizon);
  45. extern void FinishPreparedTransaction(const char *gid, bool isCommit);
  46. #endif /* TWOPHASE_H */