We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent db9f287 commit 0726c76Copy full SHA for 0726c76
src/backend/replication/slot.c
@@ -512,7 +512,7 @@ ReplicationSlotRelease(void)
512
MyReplicationSlot = NULL;
513
514
/* might not have been set when we've been a plain slot */
515
- LWLockAcquire(ProcArrayLock, LW_SHARED);
+ LWLockAcquire(ProcArrayLock, LW_EXCLUSIVE);
516
MyProc->statusFlags &= ~PROC_IN_LOGICAL_DECODING;
517
ProcGlobal->statusFlags[MyProc->pgxactoff] = MyProc->statusFlags;
518
LWLockRelease(ProcArrayLock);
0 commit comments