Startsida Utforska Hjälp
Logga in
BlitzNG
/
database.mod
spegling av https://github.com/bmx-ng/database.mod.git
2
0
Fork 0
Filer Ärenden 0 Wiki
Gren: task/add-postgresql
Grenar Taggar
database.mod
/
postgresql.mod
/
include
/
storage
/
procarray.h

procarray.h 4.0 KB
Permalänk Historik Rå

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899 
  1. /*-------------------------------------------------------------------------
    2. 

  2.  *
    3. 

  3.  * procarray.h
    4. 

  4.  *	  POSTGRES process array definitions.
    5. 

  5.  *
    6. 

  6.  *
    7. 

  7.  * Portions Copyright (c) 1996-2022, PostgreSQL Global Development Group
    8. 

  8.  * Portions Copyright (c) 1994, Regents of the University of California
    9. 

  9.  *
    10. 

  10.  * src/include/storage/procarray.h
    11. 

  11.  *
    12. 

  12.  *-------------------------------------------------------------------------
    13. 

  13.  */
    14. 

  14. #ifndef PROCARRAY_H
    15. 

  15. #define PROCARRAY_H
    16. 

  16. 

  17. #include "storage/lock.h"
    18. 

  18. #include "storage/standby.h"
    19. 

  19. #include "utils/relcache.h"
    20. 

  20. #include "utils/snapshot.h"
    21. 

  21. 

  22. 

  23. extern Size ProcArrayShmemSize(void);
    24. 

  24. extern void CreateSharedProcArray(void);
    25. 

  25. extern void ProcArrayAdd(PGPROC *proc);
    26. 

  26. extern void ProcArrayRemove(PGPROC *proc, TransactionId latestXid);
    27. 

  27. 

  28. extern void ProcArrayEndTransaction(PGPROC *proc, TransactionId latestXid);
    29. 

  29. extern void ProcArrayClearTransaction(PGPROC *proc);
    30. 

  30. 

  31. extern void ProcArrayInitRecovery(TransactionId initializedUptoXID);
    32. 

  32. extern void ProcArrayApplyRecoveryInfo(RunningTransactions running);
    33. 

  33. extern void ProcArrayApplyXidAssignment(TransactionId topxid,
    34. 

  34. 										int nsubxids, TransactionId *subxids);
    35. 

  35. 

  36. extern void RecordKnownAssignedTransactionIds(TransactionId xid);
    37. 

  37. extern void ExpireTreeKnownAssignedTransactionIds(TransactionId xid,
    38. 

  38. 												  int nsubxids, TransactionId *subxids,
    39. 

  39. 												  TransactionId max_xid);
    40. 

  40. extern void ExpireAllKnownAssignedTransactionIds(void);
    41. 

  41. extern void ExpireOldKnownAssignedTransactionIds(TransactionId xid);
    42. 

  42. extern void KnownAssignedTransactionIdsIdleMaintenance(void);
    43. 

  43. 

  44. extern int	GetMaxSnapshotXidCount(void);
    45. 

  45. extern int	GetMaxSnapshotSubxidCount(void);
    46. 

  46. 

  47. extern Snapshot GetSnapshotData(Snapshot snapshot);
    48. 

  48. 

  49. extern bool ProcArrayInstallImportedXmin(TransactionId xmin,
    50. 

  50. 										 VirtualTransactionId *sourcevxid);
    51. 

  51. extern bool ProcArrayInstallRestoredXmin(TransactionId xmin, PGPROC *proc);
    52. 

  52. 

  53. extern RunningTransactions GetRunningTransactionData(void);
    54. 

  54. 

  55. extern bool TransactionIdIsInProgress(TransactionId xid);
    56. 

  56. extern bool TransactionIdIsActive(TransactionId xid);
    57. 

  57. extern TransactionId GetOldestNonRemovableTransactionId(Relation rel);
    58. 

  58. extern TransactionId GetOldestTransactionIdConsideredRunning(void);
    59. 

  59. extern TransactionId GetOldestActiveTransactionId(void);
    60. 

  60. extern TransactionId GetOldestSafeDecodingTransactionId(bool catalogOnly);
    61. 

  61. extern void GetReplicationHorizons(TransactionId *slot_xmin, TransactionId *catalog_xmin);
    62. 

  62. 

  63. extern VirtualTransactionId *GetVirtualXIDsDelayingChkpt(int *nvxids, int type);
    64. 

  64. extern bool HaveVirtualXIDsDelayingChkpt(VirtualTransactionId *vxids,
    65. 

  65. 										 int nvxids, int type);
    66. 

  66. 

  67. extern PGPROC *BackendPidGetProc(int pid);
    68. 

  68. extern PGPROC *BackendPidGetProcWithLock(int pid);
    69. 

  69. extern int	BackendXidGetPid(TransactionId xid);
    70. 

  70. extern bool IsBackendPid(int pid);
    71. 

  71. 

  72. extern VirtualTransactionId *GetCurrentVirtualXIDs(TransactionId limitXmin,
    73. 

  73. 												   bool excludeXmin0, bool allDbs, int excludeVacuum,
    74. 

  74. 												   int *nvxids);
    75. 

  75. extern VirtualTransactionId *GetConflictingVirtualXIDs(TransactionId limitXmin, Oid dbOid);
    76. 

  76. extern pid_t CancelVirtualTransaction(VirtualTransactionId vxid, ProcSignalReason sigmode);
    77. 

  77. extern pid_t SignalVirtualTransaction(VirtualTransactionId vxid, ProcSignalReason sigmode,
    78. 

  78. 									  bool conflictPending);
    79. 

  79. 

  80. extern bool MinimumActiveBackends(int min);
    81. 

  81. extern int	CountDBBackends(Oid databaseid);
    82. 

  82. extern int	CountDBConnections(Oid databaseid);
    83. 

  83. extern void CancelDBBackends(Oid databaseid, ProcSignalReason sigmode, bool conflictPending);
    84. 

  84. extern int	CountUserBackends(Oid roleid);
    85. 

  85. extern bool CountOtherDBBackends(Oid databaseId,
    86. 

  86. 								 int *nbackends, int *nprepared);
    87. 

  87. extern void TerminateOtherDBBackends(Oid databaseId);
    88. 

  88. 

  89. extern void XidCacheRemoveRunningXids(TransactionId xid,
    90. 

  90. 									  int nxids, const TransactionId *xids,
    91. 

  91. 									  TransactionId latestXid);
    92. 

  92. 

  93. extern void ProcArraySetReplicationSlotXmin(TransactionId xmin,
    94. 

  94. 											TransactionId catalog_xmin, bool already_locked);
    95. 

  95. 

  96. extern void ProcArrayGetReplicationSlotXmin(TransactionId *xmin,
    97. 

  97. 											TransactionId *catalog_xmin);
    98. 

  98. 

  99. #endif							/* PROCARRAY_H */
    100.