Fix benchmark indexing

Signed-off-by: Marek Siarkowicz <[email protected]>
serathius · Nov 29, 2024 · 18f85ae · 18f85ae
1 parent 8f91eb1
commit 18f85ae
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tools/benchmark/cmd/watch_latency.go b/tools/benchmark/cmd/watch_latency.go
@@ -145,7 +145,7 @@ func setupWatchChannels(key string) []clientv3.WatchChan {
 	wchs := make([]clientv3.WatchChan, len(streams)*watchLWatchersPerStream)
 	for i := 0; i < len(streams); i++ {
 		for j := 0; j < watchLWatchersPerStream; j++ {
-			wchs[i*len(streams)+j] = streams[i].Watch(context.TODO(), key, opts...)
+			wchs[i*watchLWatchersPerStream+j] = streams[i].Watch(context.TODO(), key, opts...)
 		}
 	}
 	return wchs