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

smartcontractkit · Sep 18, 2023 · b4b6853 · b4b6853
1 parent 738944b
commit b4b6853
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()