18 #error "lock.h may not be included from frontend code" 40 extern int Trace_lock_oidmin;
41 extern bool Trace_locks;
42 extern bool Trace_userlocks;
43 extern int Trace_lock_table;
44 extern bool Debug_deadlocks;
69 #define InvalidLocalTransactionId 0 70 #define LocalTransactionIdIsValid(lxid) ((lxid) != InvalidLocalTransactionId) 71 #define VirtualTransactionIdIsValid(vxid) \ 72 (LocalTransactionIdIsValid((vxid).localTransactionId)) 73 #define VirtualTransactionIdIsPreparedXact(vxid) \ 74 ((vxid).backendId == InvalidBackendId) 75 #define VirtualTransactionIdEquals(vxid1, vxid2) \ 76 ((vxid1).backendId == (vxid2).backendId && \ 77 (vxid1).localTransactionId == (vxid2).localTransactionId) 78 #define SetInvalidVirtualTransactionId(vxid) \ 79 ((vxid).backendId = InvalidBackendId, \ 80 (vxid).localTransactionId = InvalidLocalTransactionId) 81 #define GET_VXID_FROM_PGPROC(vxid, proc) \ 82 ((vxid).backendId = (proc).backendId, \ 83 (vxid).localTransactionId = (proc).lxid) 86 #define MAX_LOCKMODES 10 88 #define LOCKBIT_ON(lockmode) (1 << (lockmode)) 89 #define LOCKBIT_OFF(lockmode) (~(1 << (lockmode))) 129 #define DEFAULT_LOCKMETHOD 1 130 #define USER_LOCKMETHOD 2 154 #define LOCKTAG_LAST_TYPE LOCKTAG_ADVISORY 183 #define SET_LOCKTAG_RELATION(locktag,dboid,reloid) \ 184 ((locktag).locktag_field1 = (dboid), \ 185 (locktag).locktag_field2 = (reloid), \ 186 (locktag).locktag_field3 = 0, \ 187 (locktag).locktag_field4 = 0, \ 188 (locktag).locktag_type = LOCKTAG_RELATION, \ 189 (locktag).locktag_lockmethodid = DEFAULT_LOCKMETHOD) 192 #define SET_LOCKTAG_RELATION_EXTEND(locktag,dboid,reloid) \ 193 ((locktag).locktag_field1 = (dboid), \ 194 (locktag).locktag_field2 = (reloid), \ 195 (locktag).locktag_field3 = 0, \ 196 (locktag).locktag_field4 = 0, \ 197 (locktag).locktag_type = LOCKTAG_RELATION_EXTEND, \ 198 (locktag).locktag_lockmethodid = DEFAULT_LOCKMETHOD) 201 #define SET_LOCKTAG_DATABASE_FROZEN_IDS(locktag,dboid) \ 202 ((locktag).locktag_field1 = (dboid), \ 203 (locktag).locktag_field2 = 0, \ 204 (locktag).locktag_field3 = 0, \ 205 (locktag).locktag_field4 = 0, \ 206 (locktag).locktag_type = LOCKTAG_DATABASE_FROZEN_IDS, \ 207 (locktag).locktag_lockmethodid = DEFAULT_LOCKMETHOD) 210 #define SET_LOCKTAG_PAGE(locktag,dboid,reloid,blocknum) \ 211 ((locktag).locktag_field1 = (dboid), \ 212 (locktag).locktag_field2 = (reloid), \ 213 (locktag).locktag_field3 = (blocknum), \ 214 (locktag).locktag_field4 = 0, \ 215 (locktag).locktag_type = LOCKTAG_PAGE, \ 216 (locktag).locktag_lockmethodid = DEFAULT_LOCKMETHOD) 219 #define SET_LOCKTAG_TUPLE(locktag,dboid,reloid,blocknum,offnum) \ 220 ((locktag).locktag_field1 = (dboid), \ 221 (locktag).locktag_field2 = (reloid), \ 222 (locktag).locktag_field3 = (blocknum), \ 223 (locktag).locktag_field4 = (offnum), \ 224 (locktag).locktag_type = LOCKTAG_TUPLE, \ 225 (locktag).locktag_lockmethodid = DEFAULT_LOCKMETHOD) 228 #define SET_LOCKTAG_TRANSACTION(locktag,xid) \ 229 ((locktag).locktag_field1 = (xid), \ 230 (locktag).locktag_field2 = 0, \ 231 (locktag).locktag_field3 = 0, \ 232 (locktag).locktag_field4 = 0, \ 233 (locktag).locktag_type = LOCKTAG_TRANSACTION, \ 234 (locktag).locktag_lockmethodid = DEFAULT_LOCKMETHOD) 237 #define SET_LOCKTAG_VIRTUALTRANSACTION(locktag,vxid) \ 238 ((locktag).locktag_field1 = (vxid).backendId, \ 239 (locktag).locktag_field2 = (vxid).localTransactionId, \ 240 (locktag).locktag_field3 = 0, \ 241 (locktag).locktag_field4 = 0, \ 242 (locktag).locktag_type = LOCKTAG_VIRTUALTRANSACTION, \ 243 (locktag).locktag_lockmethodid = DEFAULT_LOCKMETHOD) 249 #define SET_LOCKTAG_SPECULATIVE_INSERTION(locktag,xid,token) \ 250 ((locktag).locktag_field1 = (xid), \ 251 (locktag).locktag_field2 = (token), \ 252 (locktag).locktag_field3 = 0, \ 253 (locktag).locktag_field4 = 0, \ 254 (locktag).locktag_type = LOCKTAG_SPECULATIVE_TOKEN, \ 255 (locktag).locktag_lockmethodid = DEFAULT_LOCKMETHOD) 264 #define SET_LOCKTAG_OBJECT(locktag,dboid,classoid,objoid,objsubid) \ 265 ((locktag).locktag_field1 = (dboid), \ 266 (locktag).locktag_field2 = (classoid), \ 267 (locktag).locktag_field3 = (objoid), \ 268 (locktag).locktag_field4 = (objsubid), \ 269 (locktag).locktag_type = LOCKTAG_OBJECT, \ 270 (locktag).locktag_lockmethodid = DEFAULT_LOCKMETHOD) 272 #define SET_LOCKTAG_ADVISORY(locktag,id1,id2,id3,id4) \ 273 ((locktag).locktag_field1 = (id1), \ 274 (locktag).locktag_field2 = (id2), \ 275 (locktag).locktag_field3 = (id3), \ 276 (locktag).locktag_field4 = (id4), \ 277 (locktag).locktag_type = LOCKTAG_ADVISORY, \ 278 (locktag).locktag_lockmethodid = USER_LOCKMETHOD) 315 #define LOCK_LOCKMETHOD(lock) ((LOCKMETHODID) (lock).tag.locktag_lockmethodid) 316 #define LOCK_LOCKTAG(lock) ((LockTagType) (lock).tag.locktag_type) 373 #define PROCLOCK_LOCKMETHOD(proclock) \ 374 LOCK_LOCKMETHOD(*((proclock).tag.myLock)) 434 #define LOCALLOCK_LOCKMETHOD(llock) ((llock).tag.lock.locktag_lockmethodid) 435 #define LOCALLOCK_LOCKTAG(llock) ((LockTagType) (llock).tag.lock.locktag_type) 516 #define LockHashPartition(hashcode) \ 517 ((hashcode) % NUM_LOCK_PARTITIONS) 518 #define LockHashPartitionLock(hashcode) \ 519 (&MainLWLockArray[LOCK_MANAGER_LWLOCK_OFFSET + \ 520 LockHashPartition(hashcode)].lock) 521 #define LockHashPartitionLockByIndex(i) \ 522 (&MainLWLockArray[LOCK_MANAGER_LWLOCK_OFFSET + (i)].lock) 533 #define LockHashPartitionLockByProc(leader_pgproc) \ 534 LockHashPartitionLock((leader_pgproc)->pgprocno) 552 bool reportMemoryError,
557 LOCKMODE lockmode,
bool sessionLock);
563 #ifdef USE_ASSERT_CHECKING 564 extern HTAB *GetLockMethodLocalHash(
void);
567 LOCKMODE lockmode,
bool sessionLock);
586 void *recdata,
uint32 len);
588 void *recdata,
uint32 len);
590 void *recdata,
uint32 len);
592 void *recdata,
uint32 len);
606 extern void DumpLocks(
PGPROC *proc);
607 extern void DumpAllLocks(
void);
struct BlockedProcData BlockedProcData
const char *const LockTagTypeNames[]
static PgChecksumMode mode
#define pg_attribute_noreturn()
void MarkLockClear(LOCALLOCK *locallock)
void VirtualXactLockTableInsert(VirtualTransactionId vxid)
bool holdsStrongLockCount
void RemoveFromWaitQueue(PGPROC *proc, uint32 hashcode)
void AbortStrongLockAcquire(void)
void lock_twophase_postcommit(TransactionId xid, uint16 info, void *recdata, uint32 len)
void LockReleaseCurrentOwner(LOCALLOCK **locallocks, int nlocks)
LockAcquireResult LockAcquireExtended(const LOCKTAG *locktag, LOCKMODE lockmode, bool sessionLock, bool dontWait, bool reportMemoryError, LOCALLOCK **locallockp)
LockMethod GetLocksMethodTable(const LOCK *lock)
struct LOCALLOCKOWNER LOCALLOCKOWNER
void PostPrepare_Locks(TransactionId xid)
const LOCKMASK * conflictTab
int LockWaiterCount(const LOCKTAG *locktag)
void LockReassignCurrentOwner(LOCALLOCK **locallocks, int nlocks)
LockMethod GetLockTagsMethodTable(const LOCKTAG *locktag)
LocalTransactionId localTransactionId
struct LOCALLOCKTAG LOCALLOCKTAG
void LockReleaseAll(LOCKMETHODID lockmethodid, bool allLocks)
void DeadLockReport(void) pg_attribute_noreturn()
BlockedProcsData * GetBlockerStatusData(int blocked_pid)
struct LOCALLOCK LOCALLOCK
struct BlockedProcsData BlockedProcsData
bool LockCheckConflicts(LockMethod lockMethodTable, LOCKMODE lockmode, LOCK *lock, PROCLOCK *proclock)
void lock_twophase_postabort(TransactionId xid, uint16 info, void *recdata, uint32 len)
LockAcquireResult LockAcquire(const LOCKTAG *locktag, LOCKMODE lockmode, bool sessionLock, bool dontWait)
void VirtualXactLockTableCleanup(void)
const char * GetLockmodeName(LOCKMETHODID lockmethodid, LOCKMODE mode)
bool LockHeldByMe(const LOCKTAG *locktag, LOCKMODE lockmode)
uint32 LocalTransactionId
xl_standby_lock * GetRunningTransactionLocks(int *nlocks)
struct PROCLOCKTAG PROCLOCKTAG
const LockMethodData * LockMethod
bool LockRelease(const LOCKTAG *locktag, LOCKMODE lockmode, bool sessionLock)
bool LockHasWaiters(const LOCKTAG *locktag, LOCKMODE lockmode, bool sessionLock)
void RememberSimpleDeadLock(PGPROC *proc1, LOCKMODE lockmode, LOCK *lock, PGPROC *proc2)
DeadLockState DeadLockCheck(PGPROC *proc)
void lock_twophase_recover(TransactionId xid, uint16 info, void *recdata, uint32 len)
void GrantAwaitedLock(void)
bool DoLockModesConflict(LOCKMODE mode1, LOCKMODE mode2)
bool VirtualXactLock(VirtualTransactionId vxid, bool wait)
LOCALLOCKOWNER * lockOwners
struct LockMethodData LockMethodData
uint8 locktag_lockmethodid
struct PROC_QUEUE PROC_QUEUE
void InitDeadLockChecking(void)
struct LockInstanceData LockInstanceData
LockData * GetLockStatusData(void)
struct ResourceOwnerData * owner
void lock_twophase_standby_recover(TransactionId xid, uint16 info, void *recdata, uint32 len)
VirtualTransactionId * GetLockConflicts(const LOCKTAG *locktag, LOCKMODE lockmode, int *countp)
PGPROC * GetBlockingAutoVacuumPgproc(void)
void GrantLock(LOCK *lock, PROCLOCK *proclock, LOCKMODE lockmode)
uint32 LockTagHashCode(const LOCKTAG *locktag)
void AtPrepare_Locks(void)
const char *const * lockModeNames
void LockReleaseSession(LOCKMETHODID lockmethodid)