Tim Linquist timlinquist

## em_300_gets.rb
require 'eventmachine'
require 'em-http'

c = 4
urls = DATA.readlines.map {|s| s.strip }
pending = urls.size
before = Time.now

puts "urls: #{pending}"
puts "concurrency: #{c}"

## cucumber_external_resque_worker.rb
class CucumberExternalResqueWorker
  DEFAULT_STARTUP_TIMEOUT = 1.minute
  COUNTER_KEY = "cucumber:counter"

  class << self
    attr_accessor :pid, :startup_timeout

    def start
      # Call from a Cucumber support file so it is run on startup
      return unless Rails.env.cucumber?

## gist:3660384
class TolerantFetcher
  def self.get(url)
    TimeoutNinja.try do
      timeout(20) do
        begin
          handle = open(url)
          response = handle.read
        ensure
          handle.try(:close!)   ####### HERE
        end
	require 'eventmachine'
	require 'em-http'

	c = 4
	urls = DATA.readlines.map {\|s\| s.strip }
	pending = urls.size
	before = Time.now

	puts "urls: #{pending}"
	puts "concurrency: #{c}"
	class CucumberExternalResqueWorker
	DEFAULT_STARTUP_TIMEOUT = 1.minute
	COUNTER_KEY = "cucumber:counter"

	class << self
	attr_accessor :pid, :startup_timeout

	def start
	# Call from a Cucumber support file so it is run on startup
	return unless Rails.env.cucumber?
	class TolerantFetcher
	def self.get(url)
	TimeoutNinja.try do
	timeout(20) do
	begin
	handle = open(url)
	response = handle.read
	ensure
	handle.try(:close!) ####### HERE
	end