Nov 1, 2024 · Oct 31, 2024
diff --git a/coderd/database/pubsub/pubsub.go b/coderd/database/pubsub/pubsub.go
 if len(listeners) == 0 {
 delete(p.queues, event)
 }
 listenerCount := len(listeners)
 p.qMu.Unlock()
 // as above, we must not hold the lock while calling into pgListener

 iflen(listeners) == 0 {
 iflistenerCount == 0 {
 uErr := p.pgListener.Unlisten(event)
 p.closeMu.Lock()
 defer p.closeMu.Unlock()
Original file line number	Diff line number	Diff line change
Expand Up		@@ -278,10 +278,11 @@ func (p PGPubsub) subscribeQueue(event string, newQ msgQueue) (cancel func(),
		if len(listeners) == 0 {
		delete(p.queues, event)
		}
		listenerCount := len(listeners)
		p.qMu.Unlock()
		// as above, we must not hold the lock while calling into pgListener

		iflen(listeners) == 0 {
		iflistenerCount == 0 {
		uErr := p.pgListener.Unlisten(event)
		p.closeMu.Lock()
		defer p.closeMu.Unlock()
Expand Down