fix: concurrent map iteration and map write

kedacore · Jul 7, 2023 · 8fa412a · 8fa412a
1 parent 0610339
commit 8fa412a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/queue/queue.go b/pkg/queue/queue.go
@@ -85,6 +85,8 @@ func (r *Memory) Current() (*Counts, error) {
 	r.mut.RLock()
 	defer r.mut.RUnlock()
 	cts := NewCounts()
-	cts.Counts = r.countMap
+	for key, val := range r.countMap {
+		cts.Counts[key] = val
+	}
 	return cts, nil
 }