Lines Matching refs:ReplicationSlotControlLock

250 	LWLockAcquire(ReplicationSlotControlLock, LW_SHARED);  in ReplicationSlotCreate()
262 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotCreate()
309 LWLockAcquire(ReplicationSlotControlLock, LW_EXCLUSIVE); in ReplicationSlotCreate()
320 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotCreate()
353 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in SearchNamedReplicationSlot()
367 LWLockRelease(ReplicationSlotControlLock); in SearchNamedReplicationSlot()
389 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotAcquire()
398 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotAcquire()
428 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotAcquire()
531 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotCleanup()
544 LWLockRelease(ReplicationSlotControlLock); /* avoid deadlock */ in ReplicationSlotCleanup()
555 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotCleanup()
656 LWLockAcquire(ReplicationSlotControlLock, LW_EXCLUSIVE); in ReplicationSlotDropPtr()
659 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotDropPtr()
774 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotsComputeRequiredXmin()
803 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotsComputeRequiredXmin()
823 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotsComputeRequiredLSN()
841 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotsComputeRequiredLSN()
867 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotsComputeLogicalRestartLSN()
897 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotsComputeLogicalRestartLSN()
920 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotsCountDBSlots()
946 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotsCountDBSlots()
975 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotsDropDBSlots()
1030 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotsDropDBSlots()
1034 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotsDropDBSlots()
1163 Assert(LWLockHeldByMeInMode(ReplicationSlotControlLock, LW_SHARED)); in InvalidatePossiblyObsoleteSlot()
1168 LWLockRelease(ReplicationSlotControlLock); in InvalidatePossiblyObsoleteSlot()
1191 LWLockRelease(ReplicationSlotControlLock); in InvalidatePossiblyObsoleteSlot()
1225 LWLockRelease(ReplicationSlotControlLock); in InvalidatePossiblyObsoleteSlot()
1259 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in InvalidatePossiblyObsoleteSlot()
1272 LWLockRelease(ReplicationSlotControlLock); in InvalidatePossiblyObsoleteSlot()
1290 Assert(released_lock == !LWLockHeldByMe(ReplicationSlotControlLock)); in InvalidatePossiblyObsoleteSlot()
1312 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in InvalidateObsoleteReplicationSlots()
1326 LWLockRelease(ReplicationSlotControlLock); in InvalidateObsoleteReplicationSlots()