1 /*------------------------------------------------------------------------- 2 * 3 * procarray.h 4 * POSTGRES process array definitions. 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/storage/procarray.h 11 * 12 *------------------------------------------------------------------------- 13 */ 14 #ifndef PROCARRAY_H 15 #define PROCARRAY_H 16 17 #include "storage/lock.h" 18 #include "storage/standby.h" 19 #include "utils/relcache.h" 20 #include "utils/snapshot.h" 21 22 23 extern Size ProcArrayShmemSize(void); 24 extern void CreateSharedProcArray(void); 25 extern void ProcArrayAdd(PGPROC *proc); 26 extern void ProcArrayRemove(PGPROC *proc, TransactionId latestXid); 27 28 extern void ProcArrayEndTransaction(PGPROC *proc, TransactionId latestXid); 29 extern void ProcArrayClearTransaction(PGPROC *proc); 30 31 extern void ProcArrayInitRecovery(TransactionId initializedUptoXID); 32 extern void ProcArrayApplyRecoveryInfo(RunningTransactions running); 33 extern void ProcArrayApplyXidAssignment(TransactionId topxid, 34 int nsubxids, TransactionId *subxids); 35 36 extern void RecordKnownAssignedTransactionIds(TransactionId xid); 37 extern void ExpireTreeKnownAssignedTransactionIds(TransactionId xid, 38 int nsubxids, TransactionId *subxids, 39 TransactionId max_xid); 40 extern void ExpireAllKnownAssignedTransactionIds(void); 41 extern void ExpireOldKnownAssignedTransactionIds(TransactionId xid); 42 43 extern int GetMaxSnapshotXidCount(void); 44 extern int GetMaxSnapshotSubxidCount(void); 45 46 extern Snapshot GetSnapshotData(Snapshot snapshot); 47 48 extern bool ProcArrayInstallImportedXmin(TransactionId xmin, 49 TransactionId sourcexid); 50 extern bool ProcArrayInstallRestoredXmin(TransactionId xmin, PGPROC *proc); 51 52 extern RunningTransactions GetRunningTransactionData(void); 53 54 extern bool TransactionIdIsInProgress(TransactionId xid); 55 extern bool TransactionIdIsActive(TransactionId xid); 56 extern TransactionId GetOldestXmin(Relation rel, bool ignoreVacuum); 57 extern TransactionId GetOldestActiveTransactionId(void); 58 extern TransactionId GetOldestSafeDecodingTransactionId(bool catalogOnly); 59 60 extern VirtualTransactionId *GetVirtualXIDsDelayingChkpt(int *nvxids); 61 extern bool HaveVirtualXIDsDelayingChkpt(VirtualTransactionId *vxids, int nvxids); 62 63 extern PGPROC *BackendPidGetProc(int pid); 64 extern PGPROC *BackendPidGetProcWithLock(int pid); 65 extern int BackendXidGetPid(TransactionId xid); 66 extern bool IsBackendPid(int pid); 67 68 extern VirtualTransactionId *GetCurrentVirtualXIDs(TransactionId limitXmin, 69 bool excludeXmin0, bool allDbs, int excludeVacuum, 70 int *nvxids); 71 extern VirtualTransactionId *GetConflictingVirtualXIDs(TransactionId limitXmin, Oid dbOid); 72 extern pid_t CancelVirtualTransaction(VirtualTransactionId vxid, ProcSignalReason sigmode); 73 extern pid_t SignalVirtualTransaction(VirtualTransactionId vxid, ProcSignalReason sigmode, 74 bool conflictPending); 75 76 extern bool MinimumActiveBackends(int min); 77 extern int CountDBBackends(Oid databaseid); 78 extern int CountDBConnections(Oid databaseid); 79 extern void CancelDBBackends(Oid databaseid, ProcSignalReason sigmode, bool conflictPending); 80 extern int CountUserBackends(Oid roleid); 81 extern bool CountOtherDBBackends(Oid databaseId, 82 int *nbackends, int *nprepared); 83 84 extern void XidCacheRemoveRunningXids(TransactionId xid, 85 int nxids, const TransactionId *xids, 86 TransactionId latestXid); 87 88 extern void ProcArraySetReplicationSlotXmin(TransactionId xmin, 89 TransactionId catalog_xmin, bool already_locked); 90 91 extern void ProcArrayGetReplicationSlotXmin(TransactionId *xmin, 92 TransactionId *catalog_xmin); 93 94 #endif /* PROCARRAY_H */ 95