Contents

$LOAD_PATH.unshift(File.dirname(__FILE__)) unless $LOAD_PATH.include?(File.dirname(__FILE__))

require 'rack/utils'
require 'digest/sha2'
require 'typhoeus/easy'
require 'typhoeus/multi'
require 'typhoeus/native'
require 'typhoeus/filter'
require 'typhoeus/remote_method'
require 'typhoeus/remote'
require 'typhoeus/remote_proxy_object'
require 'typhoeus/response'
require 'typhoeus/request'
require 'typhoeus/hydra'

module Typhoeus
  VERSION = File.read(File.dirname(__FILE__) + "/../VERSION").chomp

  def self.easy_object_pool
    @easy_objects ||= []
  end

  def self.init_easy_object_pool
    20.times do
      easy_object_pool << Typhoeus::Easy.new
    end
  end

  def self.release_easy_object(easy)
    easy.reset
    easy_object_pool << easy
  end

  def self.get_easy_object
    if easy_object_pool.empty?
      Typhoeus::Easy.new
    else
      easy_object_pool.pop
    end
  end

  def self.add_easy_request(easy_object)
    Thread.current[:curl_multi] ||= Typhoeus::Multi.new
    Thread.current[:curl_multi].add(easy_object)
  end

  def self.perform_easy_requests
    multi = Thread.current[:curl_multi]
    start_time = Time.now
    multi.easy_handles.each do |easy|
      easy.start_time = start_time
    end
    multi.perform
  end
end

Version data entries

15 entries across 15 versions & 4 rubygems

Version	Path
fblee-typhoeus-0.1.31	lib/typhoeus.rb
tech-angels-typhoeus-0.1.36	lib/typhoeus.rb
typhoeus-0.1.31	lib/typhoeus.rb
typhoeus-0.1.30	lib/typhoeus.rb
typhoeus-0.1.29	lib/typhoeus.rb
gravis-typhoeus-0.1.36	lib/typhoeus.rb
typhoeus-0.1.28	lib/typhoeus.rb
gravis-typhoeus-0.1.35	lib/typhoeus.rb
gravis-typhoeus-0.1.34	lib/typhoeus.rb
gravis-typhoeus-0.1.33	lib/typhoeus.rb
gravis-typhoeus-0.1.32	lib/typhoeus.rb
gravis-typhoeus-0.1.31	lib/typhoeus.rb
gravis-typhoeus-0.1.30	lib/typhoeus.rb
gravis-typhoeus-0.1.29	lib/typhoeus.rb
typhoeus-0.1.27	lib/typhoeus.rb