Methods
Public Class
Public Instance
Constants
DEFAULTS | = | { nameserver: nil, **Resolv::DNS::Config.default_config_hash, packet_size: 512, timeouts: Resolver::RESOLVE_TIMEOUT, }.freeze | ||
DNS_PORT | = | 53 |
Attributes
state | [R] |
Public Class methods
new(family, options)
[show source]
# File lib/httpx/resolver/native.rb 24 def initialize(family, options) 25 super 26 @ns_index = 0 27 @resolver_options = DEFAULTS.merge(@options.resolver_options) 28 @socket_type = @resolver_options.fetch(:socket_type, :udp) 29 @nameserver = if (nameserver = @resolver_options[:nameserver]) 30 nameserver = nameserver[family] if nameserver.is_a?(Hash) 31 Array(nameserver) 32 end 33 @ndots = @resolver_options.fetch(:ndots, 1) 34 @search = Array(@resolver_options[:search]).map { |srch| srch.scan(/[^.]+/) } 35 @_timeouts = Array(@resolver_options[:timeouts]) 36 @timeouts = Hash.new { |timeouts, host| timeouts[host] = @_timeouts.dup } 37 @connections = [] 38 @queries = {} 39 @read_buffer = "".b 40 @write_buffer = Buffer.new(@resolver_options[:packet_size]) 41 @state = :idle 42 end
Public Instance methods
<<(connection)
[show source]
# File lib/httpx/resolver/native.rb 87 def <<(connection) 88 if @nameserver.nil? 89 ex = ResolveError.new("No available nameserver") 90 ex.set_backtrace(caller) 91 connection.force_reset 92 throw(:resolve_error, ex) 93 else 94 @connections << connection 95 resolve 96 end 97 end
call()
[show source]
# File lib/httpx/resolver/native.rb 56 def call 57 case @state 58 when :open 59 consume 60 end 61 nil 62 rescue Errno::EHOSTUNREACH => e 63 @ns_index += 1 64 nameserver = @nameserver 65 if nameserver && @ns_index < nameserver.size 66 log { "resolver: failed resolving on nameserver #{@nameserver[@ns_index - 1]} (#{e.message})" } 67 transition(:idle) 68 else 69 handle_error(e) 70 end 71 rescue NativeResolveError => e 72 handle_error(e) 73 end
close()
[show source]
# File lib/httpx/resolver/native.rb 44 def close 45 transition(:closed) 46 end
closed?()
[show source]
# File lib/httpx/resolver/native.rb 48 def closed? 49 @state == :closed 50 end
handle_socket_timeout(interval)
[show source]
# File lib/httpx/resolver/native.rb 107 def handle_socket_timeout(interval) 108 do_retry(interval) 109 end
interests()
[show source]
# File lib/httpx/resolver/native.rb 75 def interests 76 case @state 77 when :idle 78 transition(:open) 79 when :closed 80 transition(:idle) 81 transition(:open) 82 end 83 84 calculate_interests 85 end
timeout()
[show source]
# File lib/httpx/resolver/native.rb 99 def timeout 100 return if @connections.empty? 101 102 @start_timeout = Utils.now 103 hosts = @queries.keys 104 @timeouts.values_at(*hosts).reject(&:empty?).map(&:first).min 105 end