Lines Matching refs:ReplicationSlotControlLock

246 	LWLockAcquire(ReplicationSlotControlLock, LW_SHARED);  in ReplicationSlotCreate()
258 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotCreate()
304 LWLockAcquire(ReplicationSlotControlLock, LW_EXCLUSIVE); in ReplicationSlotCreate()
315 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotCreate()
340 Assert(LWLockHeldByMeInMode(ReplicationSlotControlLock, in SearchNamedReplicationSlot()
392 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotAcquireInternal()
401 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotAcquireInternal()
433 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotAcquireInternal()
538 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotCleanup()
551 LWLockRelease(ReplicationSlotControlLock); /* avoid deadlock */ in ReplicationSlotCleanup()
562 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotCleanup()
663 LWLockAcquire(ReplicationSlotControlLock, LW_EXCLUSIVE); in ReplicationSlotDropPtr()
666 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotDropPtr()
762 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotsComputeRequiredXmin()
791 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotsComputeRequiredXmin()
811 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotsComputeRequiredLSN()
829 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotsComputeRequiredLSN()
855 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotsComputeLogicalRestartLSN()
885 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotsComputeLogicalRestartLSN()
908 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotsCountDBSlots()
934 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotsCountDBSlots()
963 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in ReplicationSlotsDropDBSlots()
1018 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotsDropDBSlots()
1022 LWLockRelease(ReplicationSlotControlLock); in ReplicationSlotsDropDBSlots()
1151 Assert(LWLockHeldByMeInMode(ReplicationSlotControlLock, LW_SHARED)); in InvalidatePossiblyObsoleteSlot()
1156 LWLockRelease(ReplicationSlotControlLock); in InvalidatePossiblyObsoleteSlot()
1179 LWLockRelease(ReplicationSlotControlLock); in InvalidatePossiblyObsoleteSlot()
1213 LWLockRelease(ReplicationSlotControlLock); in InvalidatePossiblyObsoleteSlot()
1247 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in InvalidatePossiblyObsoleteSlot()
1260 LWLockRelease(ReplicationSlotControlLock); in InvalidatePossiblyObsoleteSlot()
1279 Assert(released_lock == !LWLockHeldByMe(ReplicationSlotControlLock)); in InvalidatePossiblyObsoleteSlot()
1301 LWLockAcquire(ReplicationSlotControlLock, LW_SHARED); in InvalidateObsoleteReplicationSlots()
1315 LWLockRelease(ReplicationSlotControlLock); in InvalidateObsoleteReplicationSlots()