pkg/services: ErrorBuffer.Flush fix race (#998)

smartcontractkit · Jan 15, 2025 · 4e61572 · 4e61572
1 parent 0cd7b49
commit 4e61572
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/services/state.go b/pkg/services/state.go
@@ -208,12 +208,12 @@ type ErrorBuffer struct {
 	// Exceeding the cap results in discarding the oldest error
 	cap int
 
-	mu sync.RWMutex
+	mu sync.Mutex
 }
 
 func (eb *ErrorBuffer) Flush() (err error) {
-	eb.mu.RLock()
-	defer eb.mu.RUnlock()
+	eb.mu.Lock()
+	defer eb.mu.Unlock()
 	err = errors.Join(eb.buffer...)
 	eb.buffer = nil
 	return