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 65 #define PROC_VACUUM_STATE_MASK \ 66 (PROC_IN_VACUUM | PROC_IN_SAFE_IC | PROC_VACUUM_FOR_WRAPAROUND) 74 #define FP_LOCK_SLOTS_PER_BACKEND 16 80 #define INVALID_PGPROCNO PG_INT32_MAX 367 #define GetPGProcByNumber(n) (&ProcGlobal->allProcs[(n)]) 377 #define NUM_AUXILIARY_PROCS 5 PGDLLIMPORT PGPROC * MyProc
bool procArrayGroupMember
XidStatus clogGroupMemberXidStatus
PGDLLIMPORT int StatementTimeout
XLogRecPtr clogGroupMemberLsn
dlist_head lockGroupMembers
XidCacheStatus * subxidStates
PGDLLIMPORT int LockTimeout
PGPROC * bgworkerFreeProcs
int GetStartupBufferPinWaitBufId(void)
void LockErrorCleanup(void)
pg_atomic_uint32 clogGroupNext
ProcWaitStatus waitStatus
PGPROC * autovacFreeProcs
void ProcSendSignal(int pid)
XidCacheStatus subxidStatus
PGPROC * walsenderFreeProcs
void SetStartupBufferPinWaitBufId(int bufid)
void InitProcessPhase2(void)
PGPROC * AuxiliaryPidGetProc(int pid)
PGDLLIMPORT int DeadlockTimeout
PGDLLIMPORT int IdleInTransactionSessionTimeout
bool BecomeLockGroupMember(PGPROC *leader, int pid)
int ProcGlobalSemas(void)
void ProcWaitForSignal(uint32 wait_event_info)
#define FP_LOCK_SLOTS_PER_BACKEND
bool recoveryConflictPending
bool HaveNFreeProcs(int n)
TransactionId clogGroupMemberXid
uint32 LocalTransactionId
void ProcReleaseLocks(bool isCommit)
PGDLLIMPORT int IdleSessionTimeout
void BecomeLockGroupLeader(void)
void ProcLockWakeup(LockMethod lockMethodTable, LOCK *lock)
pg_atomic_uint32 procArrayGroupNext
PGPROC * PreparedXactProcs
struct XidCacheStatus XidCacheStatus
PGPROC * ProcWakeup(PGPROC *proc, ProcWaitStatus waitStatus)
#define PGPROC_MAX_CACHED_SUBXIDS
ProcWaitStatus ProcSleep(LOCALLOCK *locallock, LockMethod lockMethodTable)
Latch * checkpointerLatch
PGDLLIMPORT PROC_HDR * ProcGlobal
void InitProcGlobal(void)
void ProcQueueInit(PROC_QUEUE *queue)
void CheckDeadLockAlert(void)
void InitAuxiliaryProcess(void)
pg_atomic_uint32 clogGroupFirst
void PublishStartupProcessInformation(void)
pg_atomic_uint32 procArrayGroupFirst
bool IsWaitingForLock(void)
int startupBufferPinWaitBufId
pg_atomic_uint64 waitStart
Size ProcGlobalShmemSize(void)
LocalTransactionId fpLocalTransactionId
TransactionId procArrayGroupMemberXid
#define NUM_LOCK_PARTITIONS