36 #define PGPROC_MAX_CACHED_SUBXIDS 64
54 #define PROC_IS_AUTOVACUUM 0x01
55 #define PROC_IN_VACUUM 0x02
56 #define PROC_IN_SAFE_IC 0x04
60 #define PROC_VACUUM_FOR_WRAPAROUND 0x08
61 #define PROC_IN_LOGICAL_DECODING 0x10
63 #define PROC_AFFECTS_ALL_HORIZONS 0x20
68 #define PROC_VACUUM_STATE_MASK \
69 (PROC_IN_VACUUM | PROC_IN_SAFE_IC | PROC_VACUUM_FOR_WRAPAROUND)
75 #define PROC_XMIN_FLAGS (PROC_IN_VACUUM | PROC_IN_SAFE_IC)
83 #define FP_LOCK_SLOTS_PER_BACKEND 16
89 #define INVALID_PGPROCNO PG_INT32_MAX
123 #define DELAY_CHKPT_START (1<<0)
124 #define DELAY_CHKPT_COMPLETE (1<<1)
408 #define GetPGProcByNumber(n) (&ProcGlobal->allProcs[(n)])
418 #define NUM_AUXILIARY_PROCS 5
uint32 LocalTransactionId
#define NUM_LOCK_PARTITIONS
PGDLLIMPORT int IdleInTransactionSessionTimeout
void ProcSendSignal(int pgprocno)
Size ProcGlobalShmemSize(void)
bool IsWaitingForLock(void)
PGDLLIMPORT int IdleSessionTimeout
void InitAuxiliaryProcess(void)
PGDLLIMPORT PROC_HDR * ProcGlobal
#define FP_LOCK_SLOTS_PER_BACKEND
int GetStartupBufferPinWaitBufId(void)
PGPROC * ProcWakeup(PGPROC *proc, ProcWaitStatus waitStatus)
PGDLLIMPORT PGPROC * MyProc
void ProcLockWakeup(LockMethod lockMethodTable, LOCK *lock)
#define PGPROC_MAX_CACHED_SUBXIDS
int ProcGlobalSemas(void)
void ProcReleaseLocks(bool isCommit)
void LockErrorCleanup(void)
bool BecomeLockGroupMember(PGPROC *leader, int pid)
PGDLLIMPORT int StatementTimeout
void BecomeLockGroupLeader(void)
PGDLLIMPORT int DeadlockTimeout
PGPROC * AuxiliaryPidGetProc(int pid)
PGDLLIMPORT int LockTimeout
void CheckDeadLockAlert(void)
void InitProcessPhase2(void)
void InitProcGlobal(void)
ProcWaitStatus ProcSleep(LOCALLOCK *locallock, LockMethod lockMethodTable)
PGDLLIMPORT bool log_lock_waits
@ PROC_WAIT_STATUS_WAITING
void ProcQueueInit(PROC_QUEUE *queue)
PGDLLIMPORT PGPROC * PreparedXactProcs
struct XidCacheStatus XidCacheStatus
bool HaveNFreeProcs(int n)
void SetStartupBufferPinWaitBufId(int bufid)
void ProcWaitForSignal(uint32 wait_event_info)
Oid fpRelId[FP_LOCK_SLOTS_PER_BACKEND]
bool procArrayGroupMember
XLogRecPtr clogGroupMemberLsn
pg_atomic_uint32 procArrayGroupNext
dlist_head lockGroupMembers
bool recoveryConflictPending
TransactionId clogGroupMemberXid
pg_atomic_uint64 waitStart
pg_atomic_uint32 clogGroupNext
XidStatus clogGroupMemberXidStatus
XidCacheStatus subxidStatus
LocalTransactionId fpLocalTransactionId
TransactionId procArrayGroupMemberXid
ProcWaitStatus waitStatus
SHM_QUEUE myProcLocks[NUM_LOCK_PARTITIONS]
XidCacheStatus * subxidStates
PGPROC * walsenderFreeProcs
PGPROC * autovacFreeProcs
PGPROC * bgworkerFreeProcs
int startupBufferPinWaitBufId
pg_atomic_uint32 clogGroupFirst
Latch * checkpointerLatch
pg_atomic_uint32 procArrayGroupFirst
TransactionId xids[PGPROC_MAX_CACHED_SUBXIDS]