Class Mechanize::Chain::ConnectionResolver
In: lib/mechanize/chain/connection_resolver.rb
Parent: Object
Mechanize\n[lib/mechanize.rb\nlib/mechanize/chain.rb\nlib/mechanize/chain/auth_headers.rb\nlib/mechanize/chain/body_decoding_handler.rb\nlib/mechanize/chain/connection_resolver.rb\nlib/mechanize/chain/custom_headers.rb\nlib/mechanize/chain/handler.rb\nlib/mechanize/chain/header_resolver.rb\nlib/mechanize/chain/parameter_resolver.rb\nlib/mechanize/chain/pre_connect_hook.rb\nlib/mechanize/chain/request_resolver.rb\nlib/mechanize/chain/response_body_parser.rb\nlib/mechanize/chain/response_header_handler.rb\nlib/mechanize/chain/response_reader.rb\nlib/mechanize/chain/ssl_resolver.rb\nlib/mechanize/chain/uri_resolver.rb\nlib/mechanize/content_type_error.rb\nlib/mechanize/cookie.rb\nlib/mechanize/cookie_jar.rb\nlib/mechanize/file.rb\nlib/mechanize/file_response.rb\nlib/mechanize/file_saver.rb\nlib/mechanize/form.rb\nlib/mechanize/form/button.rb\nlib/mechanize/form/check_box.rb\nlib/mechanize/form/field.rb\nlib/mechanize/form/file_upload.rb\nlib/mechanize/form/image_button.rb\nlib/mechanize/form/multi_select_list.rb\nlib/mechanize/form/option.rb\nlib/mechanize/form/radio_button.rb\nlib/mechanize/form/select_list.rb\nlib/mechanize/headers.rb\nlib/mechanize/history.rb\nlib/mechanize/monkey_patch.rb\nlib/mechanize/page.rb\nlib/mechanize/page/base.rb\nlib/mechanize/page/frame.rb\nlib/mechanize/page/image.rb\nlib/mechanize/page/label.rb\nlib/mechanize/page/link.rb\nlib/mechanize/page/meta.rb\nlib/mechanize/pluggable_parsers.rb\nlib/mechanize/redirect_limit_reached_error.rb\nlib/mechanize/redirect_not_get_or_head_error.rb\nlib/mechanize/response_code_error.rb\nlib/mechanize/unsupported_scheme_error.rb\nlib/mechanize/util.rb] dot/f_53.png

Methods

handle   new  

Included Modules

Mechanize::Handler

Public Class methods

[Source]

    # File lib/mechanize/chain/connection_resolver.rb, line 6
 6:       def initialize( connection_cache,
 7:                       keep_alive,
 8:                       proxy_addr,
 9:                       proxy_port,
10:                       proxy_user,
11:                       proxy_pass )
12: 
13:         @connection_cache = connection_cache
14:         @keep_alive = keep_alive
15:         @proxy_addr = proxy_addr
16:         @proxy_port = proxy_port
17:         @proxy_user = proxy_user
18:         @proxy_pass = proxy_pass
19:       end

Public Instance methods

[Source]

    # File lib/mechanize/chain/connection_resolver.rb, line 21
21:       def handle(ctx, params)
22:         uri = params[:uri]
23:         http_obj = nil
24: 
25:         case uri.scheme.downcase
26:         when 'http', 'https'
27:           cache_obj = (@connection_cache["#{uri.host}:#{uri.port}"] ||= {
28:                          :connection         => nil,
29:                          :keep_alive_options => {},
30:                        })
31:           http_obj = cache_obj[:connection]
32:           if http_obj.nil? || ! http_obj.started?
33:             http_obj = cache_obj[:connection] =
34:               Net::HTTP.new( uri.host,
35:                              uri.port,
36:                              @proxy_addr,
37:                              @proxy_port,
38:                              @proxy_user,
39:                              @proxy_pass
40:                              )
41:             cache_obj[:keep_alive_options] = {}
42:           end
43: 
44:           # If we're keeping connections alive and the last request time is too
45:           # long ago, stop the connection.  Or, if the max requests left is 1,
46:           # reset the connection.
47:           if @keep_alive && http_obj.started?
48:             opts = cache_obj[:keep_alive_options]
49:             if((opts[:timeout] &&
50:                 Time.now.to_i - cache_obj[:last_request_time] > opts[:timeout].to_i) ||
51:                opts[:max] && opts[:max].to_i == 1)
52: 
53:               Mechanize.log.debug('Finishing stale connection') if Mechanize.log
54:               http_obj.finish
55: 
56:             end
57:           end
58: 
59:           cache_obj[:last_request_time] = Time.now.to_i
60:         when 'file'
61:           http_obj = Object.new
62:           class << http_obj
63:             def started?; true; end
64:             def request(request, *args, &block)
65:               response = FileResponse.new(request.uri.path)
66:               yield response
67:             end
68:           end
69:         end
70: 
71:         http_obj.extend(Mutex_m)
72:         params[:connection] = http_obj
73:         super
74:       end

[Validate]