HTTPX::Resolver::System

Implementation of a synchronous name resolver which relies on the system resolver, which is lib’c getaddrinfo function (abstracted in ruby via Addrinfo.getaddrinfo).

Its main advantage is relying on the reference implementation for name resolution across most/all OSs which deploy ruby (it’s what TCPSocket also uses), its main disadvantage is the inability to set timeouts / check socket for readiness events, hence why it relies on using the Timeout module, which poses a lot of problems for the selector loop, specially when network is unstable.

Methods

Public Class

multi?
new

Public Instance

call
close
closed?
closed_for_select?
early_resolve
empty?
force_close
handle_socket_timeout
interests
lazy_resolve
multi
resolvers
state
timeout
to_io

Classes and Modules

HTTPX::Resolver::System::AddrinfoTimeoutError

Constants

 DONE
 ERROR
 RESOLV_ERRORS

Attributes

state [R]

Public Class methods

multi?()

   # File lib/httpx/resolver/system.rb
30 def multi?
31   false
32 end

new(options)

   # File lib/httpx/resolver/system.rb
37 def initialize(options)
38   super(0, options)
39   @resolver_options = @options.resolver_options
40   resolv_options = @resolver_options.dup
41   timeouts = resolv_options.delete(:timeouts) || Resolver::RESOLVE_TIMEOUT
42   @_timeouts = Array(timeouts)
43   @timeouts = Hash.new { |tims, host| tims[host] = @_timeouts.dup }
44   resolv_options.delete(:cache)
45   @queries = []
46   @ips = []
47   @pipe_mutex = Thread::Mutex.new
48   @state = :idle
49 end

Public Instance methods

call()

   # File lib/httpx/resolver/system.rb
85 def call
86   case @state
87   when :open
88     consume
89   end
90   nil
91 end

close()

   # File lib/httpx/resolver/system.rb
65 def close
66   transition(:closed)
67 end

closed?()

   # File lib/httpx/resolver/system.rb
77 def closed?
78   @state == :closed
79 end

closed_for_select?()

   # File lib/httpx/resolver/system.rb
93 def closed_for_select?
94   @state == :closed
95 end

early_resolve(_, **)

    # File lib/httpx/resolver/system.rb
126 def early_resolve(_, **) # rubocop:disable Naming/PredicateMethod
127   false
128 end

empty?()

   # File lib/httpx/resolver/system.rb
61 def empty?
62   @connections.empty?
63 end

force_close(*)

   # File lib/httpx/resolver/system.rb
69 def force_close(*)
70   close
71   @queries.clear
72   @timeouts.clear
73   @ips.clear
74   super
75 end

handle_socket_timeout(interval)

    # File lib/httpx/resolver/system.rb
130 def handle_socket_timeout(interval)
131   error = HTTPX::ResolveTimeoutError.new(interval, "timed out while waiting on select")
132   error.set_backtrace(caller)
133   @queries.each do |_, connection| # rubocop:disable Style/HashEachMethods
134     emit_resolve_error(connection, connection.peer.host, error) if @connections.delete(connection)
135   end
136 
137   while (connection = @connections.shift)
138     emit_resolve_error(connection, connection.peer.host, error)
139   end
140 
141   close_or_resolve
142 end

interests()

    # File lib/httpx/resolver/system.rb
 97 def interests
 98   return if @queries.empty?
 99 
100   :r
101 end

lazy_resolve(connection)

    # File lib/httpx/resolver/system.rb
117 def lazy_resolve(connection)
118   @connections << connection
119   resolve
120 
121   return if empty?
122 
123   @current_session.select_resolver(self, @current_selector)
124 end

multi()

   # File lib/httpx/resolver/system.rb
57 def multi
58   self
59 end

resolvers()

   # File lib/httpx/resolver/system.rb
51 def resolvers
52   return enum_for(__method__) unless block_given?
53 
54   yield self
55 end

timeout()

    # File lib/httpx/resolver/system.rb
103 def timeout
104   _, connection = @queries.first
105 
106   return unless connection
107 
108   timeouts = @timeouts[connection.peer.host]
109 
110   return if timeouts.empty?
111 
112   log(level: 2) { "resolver #{FAMILY_TYPES[@record_type]}: next timeout #{timeouts.first} secs... (#{timeouts.size - 1} left)" }
113 
114   timeouts.first
115 end

to_io()

   # File lib/httpx/resolver/system.rb
81 def to_io
82   @pipe_read.to_io
83 end