Contents

# 
# Usage:
#  drbqs-server server.rb -- 30 50
#  drbqs-server server.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 do |server, argv, opts|
  start_num = (argv[0] || 10).to_i
  end_num = (argv[1] || 100).to_i
  step_num = opts[:step] || 10

  server.task_generator(:generate => 10) do |tgen|
    start_num.step(end_num, step_num).with_index do |i, count|
      create_add(Sum.new(i - 10, i), :exec, group: (count.even? ? :even : :odd)) do |srv, ret|
        puts "Receive: #{ret.inspect}"
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
drbqs-0.1.1	examples/group/server.rb
drbqs-0.1.0	examples/group/server.rb
drbqs-0.0.19	example/group/server.rb
drbqs-0.0.18	example/group/server.rb