Read the length of pending records while locked (#10661)

smartcontractkit · Sep 15, 2023 · 05f9558 · 05f9558
1 parent a97547d
commit 05f9558
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/core/services/ocr2/plugins/ocr2keeper/evm21/upkeepstate/store.go b/core/services/ocr2/plugins/ocr2keeper/evm21/upkeepstate/store.go
@@ -132,9 +132,8 @@ func (u *upkeepStateStore) Start(pctx context.Context) error {
 }
 
 func (u *upkeepStateStore) flush(ctx context.Context) {
-	cloneRecords := make([]persistedStateRecord, len(u.pendingRecords))
-
 	u.mu.Lock()
+	cloneRecords := make([]persistedStateRecord, len(u.pendingRecords))
 	copy(cloneRecords, u.pendingRecords)
 	u.pendingRecords = []persistedStateRecord{}
 	u.mu.Unlock()