From 6739e7bcc8683db911489c60b6965a3eb2e2c42e Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Fri, 25 Apr 2025 12:21:30 +0530 Subject: [PATCH] Broadcast inside lock (#3626) --- pkg/utils/incrementaldispatcher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/utils/incrementaldispatcher.go b/pkg/utils/incrementaldispatcher.go index 2aaaf9ffd..845ed3e85 100644 --- a/pkg/utils/incrementaldispatcher.go +++ b/pkg/utils/incrementaldispatcher.go @@ -43,8 +43,8 @@ func (d *IncrementalDispatcher[T]) Add(item T) { } d.lock.Lock() d.items = append(d.items, item) - d.lock.Unlock() d.cond.Broadcast() + d.lock.Unlock() } func (d *IncrementalDispatcher[T]) Done() {