Contents

# 
# Usage:
#  drbqs-server server_def.rb -- 30 50
#  drbqs-server server_def.rb -- 100 500 --step 100
# 

require_relative 'sum.rb'

DRbQS.option_parser do |opt, hash|
  opt.on('--step NUM', Integer) do |v|
    hash[:step] = v
  end
end

DRbQS.define_server(:check_alive => 5) do |server, argv, opts|
  start_num = (argv[0] || 10).to_i
  end_num = (argv[1] || 50).to_i
  step_num = opts[:step] || 10
  start_num.step(end_num, step_num) do |i|
    task = DRbQS::Task.new(Sum.new(i - 10, i), :exec) do |srv, ret|
      puts "Receive: #{ret.inspect}"
    end
    server.queue.add(task)
  end

  server.add_hook(:finish) do |serv|
    serv.exit
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
drbqs-0.0.15	example/sum/server_def.rb
drbqs-0.0.14	example/sum/server_def.rb
drbqs-0.0.13	example/sum/server_def.rb
drbqs-0.0.12	example/sum/server_def.rb
drbqs-0.0.11	example/sum/server_def.rb
drbqs-0.0.10	example/sum/server_def.rb
drbqs-0.0.9	example/sum/server_def.rb
drbqs-0.0.8	example/sum/server_def.rb