require File.dirname(__FILE__) + '/test_helper.rb'

class TestEvdispatch < Test::Unit::TestCase

  def test_object_test
    d = Evdispatch::Loop.new

    # start the event loop thread
    d.start

    # increase this to verify
    1.times do

      begin

        ObjectSpace.garbage_collect

        10.times do
          begin
            start_count = ObjectSpace.each_object { }
            duration =  run_trial(d, 100)
            new_count = ObjectSpace.each_object { }
            puts "10 trials: #{duration} seconds, new objects #{new_count - start_count}, #{new_count} - #{start_count}"
          end

          begin
            start_count = ObjectSpace.each_object { }
            duration = run_trial(d, 200)
            new_count = ObjectSpace.each_object { }
            puts "100 trials: #{duration} seconds, new objects #{new_count - start_count}, #{new_count} - #{start_count}"
          end

        end

      rescue => e
        puts e.message, e.backtrace
      end

    end

    count = ObjectSpace.each_object { }
    puts "Final Total objects: #{count}"
    count = nil
    ObjectSpace.garbage_collect
    count = ObjectSpace.each_object { }
    puts "After garbage collection objects: #{count}"
 
    # sometime later you can stop the event loop
    d.stop
  end

  def request_bytes_from( d, base, amount, range )
    ids = []
    amount.times do|i|
      am = rand( range )
      ids << d.request_http( base + "bytes/#{am}/" )
    end
    ids
  end

  def request_delay_from( d, base, amount, delay )
    ids = []
    amount.times do|i|
      am = rand( delay )
      ids << d.request_http( base + "delay/#{delay}/" )
    end
    ids
  end

  def run_trial( d, trials )

    ebbbase = "http://127.0.0.1:4044/"
    timer = Time.now
    ids = request_bytes_from( d, ebbbase, trials, 1000 )
    #ids += request_delay_from( d, ebbbase, trials, 1 )

    # wait for each response
    puts "expecting #{ids.size} responses..."
    ids.each do|id|
      response = d.response( id )
      #puts response[:name]
    end

    duration = Time.now - timer


    duration
  end
end