em_put_test.rb

require 'em-http'

N = 10

files = (0...N).map do |n|
  file = "test_file_#{n}"
  File.open( file, "w" ) do |f| 
    100_000.times { f << "0123456789" }
  end
  file
end

c = 4
pending = files.size
before = Time.now

puts "files: #{pending} of size #{File.size(files.first) / 1024}K"
puts "concurrency: #{c}"

EM.run do
  q = EM::Queue.new
  q.push(*files)

  worker = lambda do |file|
    http = EM::HttpRequest.new("http://192.168.213.1:4567/").put(:file => file)
    #http = EM::HttpRequest.new("http://192.168.213.1:4567/").put(:body => File.binread(file))
  
    http.callback do
      pending -= 1
      EM.stop if pending < 1
      q.pop worker
    end

    http.errback do
      puts http.error
    end

    http.errback do
      pending -= 1
      EM.stop if pending < 1
      q.pop worker
    end
  end

  c.times do
    q.pop worker
  end

  EM.add_periodic_timer(1) do
    puts q.size
  end
end

puts "finished in #{Time.now - before}"

put_server.rb

require 'sinatra'

put "/" do
  puts "received #{request.body.size / 1024}K file"
  "OK"
end