test: keep pipelining size in moderation for benchmarks (#176)

Author: supercaracal

test/benchmark_mixin.rb

@@ -2,6 +2,7 @@
 
 module BenchmarkMixin
   MIN_THRESHOLD = 0.95
+  MAX_PIPELINE_SIZE = 30
 
   def setup
     @client = new_test_client
@@ -41,29 +42,35 @@ def bench_get
 
   def bench_pipeline_echo
     assert_performance_linear(MIN_THRESHOLD) do |n|
-      @client.pipelined do |pi|
-        n.times do
-          pi.call('ECHO', 'Hello world')
+      (1..n).each_slice(MAX_PIPELINE_SIZE) do |list|
+        @client.pipelined do |pi|
+          list.each do
+            pi.call('ECHO', 'Hello world')
+          end
         end
       end
     end
   end
 
   def bench_pipeline_set
     assert_performance_linear(MIN_THRESHOLD) do |n|
-      @client.pipelined do |pi|
-        n.times do |i|
-          pi.call('SET', "key#{i}", i)
+      (1..n).each_slice(MAX_PIPELINE_SIZE) do |list|
+        @client.pipelined do |pi|
+          list.each do |i|
+            pi.call('SET', "key#{i}", i)
+          end
         end
       end
     end
   end
 
   def bench_pipeline_get
     assert_performance_linear(MIN_THRESHOLD) do |n|
-      @client.pipelined do |pi|
-        n.times do |i|
-          pi.call('GET', "key#{i}")
+      (1..n).each_slice(MAX_PIPELINE_SIZE) do |list|
+        @client.pipelined do |pi|
+          list.each do |i|
+            pi.call('GET', "key#{i}")
+          end
         end
       end
     end

test/prof_mem.rb

@@ -9,7 +9,7 @@ module ProfMem
 
   ATTEMPT_COUNT = 1000
   MAX_PIPELINE_SIZE = 30
-  SLICED_NUMBERS = Array.new(ATTEMPT_COUNT) { |i| i }.each_slice(MAX_PIPELINE_SIZE).freeze
+  SLICED_NUMBERS = (1..ATTEMPT_COUNT).each_slice(MAX_PIPELINE_SIZE).freeze
   CLI_TYPES = %w[primary_only scale_read_random scale_read_latency pooled].freeze
   MODES = {
     single: lambda do |client_builder_method|