Sha256: a50f1b7818a56db7c4092639787b3bb86de90efabee1fae515f2fabe9d2c5066

Contents?: true

Size: 593 Bytes

Versions: 2

Compression:

Stored size: 593 Bytes

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 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 do |reg|
    (start_num..end_num).step(step_num) do |i|
      reg.create_add(Sum.new(i - 10, i), :exec) do |srv, ret|
        puts "Receive: #{ret.inspect}"
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
drbqs-0.1.1 examples/sum2/server_def.rb
drbqs-0.1.0 examples/sum2/server_def.rb