Contents

BENCHMARK_ROOT = File.dirname(__FILE__)
REDIS_ROOT = File.join(BENCHMARK_ROOT, "..", "lib")

$: << REDIS_ROOT
require 'redis'
require 'benchmark'

def show_usage
  puts <<-EOL
    Usage: worker.rb [read:write] <start_index> <end_index> <sleep_msec>
  EOL
end

def shift_from_argv
  value = ARGV.shift
  unless value
    show_usage
    exit -1
  end
  value
end

operation = shift_from_argv.to_sym
start_index = shift_from_argv.to_i
end_index = shift_from_argv.to_i
sleep_msec = shift_from_argv.to_i
sleep_duration = sleep_msec/1000.0

redis = Redis.new

case operation
  when :initialize

    start_index.upto(end_index) do |i|
      redis[i] = 0
    end

  when :clear

    start_index.upto(end_index) do |i|
      redis.delete(i)
    end

  when :read, :write

    puts "Starting to #{operation} at segment #{end_index + 1}"

    loop do
      t1 = Time.now
      start_index.upto(end_index) do |i|
        case operation
          when :read
            redis.get(i)
          when :write
            redis.incr(i)
          else
            raise "Unknown operation: #{operation}"
        end
        sleep sleep_duration
      end
      t2 = Time.now

      requests_processed = end_index - start_index
      time = t2 - t1
      puts "#{t2.strftime("%H:%M")} [segment #{end_index + 1}] : Processed #{requests_processed} requests in #{time} seconds - #{(requests_processed/time).round} requests/sec"
    end

  else
    raise "Unknown operation: #{operation}"
end

Version data entries

108 entries across 106 versions & 17 rubygems

Version	Path
finsync_redis-3.3.5	benchmarking/worker.rb
redis-4.0.3	benchmarking/worker.rb
redis-4.1.0.beta1	benchmarking/worker.rb
redis-4.0.2	benchmarking/worker.rb
redis-3.3.5	benchmarking/worker.rb
redis-4.0.1	benchmarking/worker.rb
redis-4.0.0	benchmarking/worker.rb
logstash-filter-cache-redis-0.3.1	vendor/bundle/jruby/1.9/gems/redis-3.3.3/benchmarking/worker.rb
logstash-filter-cache-redis-0.3.0	vendor/bundle/jruby/1.9/gems/redis-3.3.3/benchmarking/worker.rb
logstash-filter-cache-redis-0.2.0	vendor/bundle/jruby/1.9/gems/redis-3.3.3/benchmarking/worker.rb
logstash-filter-cache-redis-0.1.0	vendor/bundle/jruby/1.9/gems/redis-3.3.3/benchmarking/worker.rb
enju_leaf-1.2.1	vendor/bundle/ruby/2.3/gems/redis-3.3.3/benchmarking/worker.rb
redis-3.3.3	benchmarking/worker.rb
abaci-0.3.0	vendor/bundle/gems/redis-3.3.2/benchmarking/worker.rb
abaci-0.3.0	vendor/bundle/gems/redis-2.2.2/benchmarking/worker.rb
abaci-0.3.0	vendor/bundle/gems/redis-3.3.1/benchmarking/worker.rb
redis-4.0.0.rc1	benchmarking/worker.rb
redis-3.3.2	benchmarking/worker.rb
redis-3.3.1	benchmarking/worker.rb
ish_lib_manager-0.0.1	test/dummy/vendor/bundle/ruby/2.3.0/gems/redis-3.3.0/benchmarking/worker.rb