Class: RubyDNS::Resolver::Request
- Inherits:
-
Object
- Object
- RubyDNS::Resolver::Request
- Includes:
- EventMachine::Deferrable
- Defined in:
- lib/rubydns/resolver.rb
Overview
Manages a single DNS question message across one or more servers.
Defined Under Namespace
Modules: TCPRequestHandler, UDPRequestHandler
Instance Attribute Summary collapse
-
#logger ⇒ Object
readonly
Returns the value of attribute logger.
-
#message ⇒ Object
readonly
Returns the value of attribute message.
-
#packet ⇒ Object
readonly
Returns the value of attribute packet.
Class Method Summary collapse
Instance Method Summary collapse
-
#initialize(message, servers, options = {}, &block) ⇒ Request
constructor
A new instance of Request.
-
#process_response!(response) ⇒ Object
Once either an exception or message is received, we update the status of this request.
- #run! ⇒ Object
Constructor Details
#initialize(message, servers, options = {}, &block) ⇒ Request
Returns a new instance of Request.
97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 |
# File 'lib/rubydns/resolver.rb', line 97 def initialize(, servers, = {}, &block) = @packet = .encode @servers = servers.dup # We select the protocol based on the size of the data: if @packet.bytesize > UDP_TRUNCATION_SIZE @servers.delete_if{|server| server[0] == :udp} end # Measured in seconds: @timeout = [:timeout] || 1 @logger = [:logger] end |
Instance Attribute Details
#logger ⇒ Object (readonly)
Returns the value of attribute logger.
116 117 118 |
# File 'lib/rubydns/resolver.rb', line 116 def logger @logger end |
#message ⇒ Object (readonly)
Returns the value of attribute message.
114 115 116 |
# File 'lib/rubydns/resolver.rb', line 114 def end |
#packet ⇒ Object (readonly)
Returns the value of attribute packet.
115 116 117 |
# File 'lib/rubydns/resolver.rb', line 115 def packet @packet end |
Class Method Details
.fetch(*args) ⇒ Object
81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 |
# File 'lib/rubydns/resolver.rb', line 81 def self.fetch(*args) request = self.new(*args) request.callback do || yield end request.errback do |error| # In the case of a timeout, error will be nil, so we make one up. yield error end request.run! end |
Instance Method Details
#process_response!(response) ⇒ Object
Once either an exception or message is received, we update the status of this request.
123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 |
# File 'lib/rubydns/resolver.rb', line 123 def process_response!(response) finish_request! if Exception === response @logger.warn "[#{@message.id}] Failure while processing response #{response}!" if @logger RubyDNS.log_exception(@logger, response) if @logger try_next_server! elsif response.tc != 0 @logger.warn "[#{@message.id}] Received truncated response!" if @logger try_next_server! elsif response.id != .id @logger.warn "[#{@message.id}] Received response with incorrect message id: #{response.id}" if @logger try_next_server! else @logger.debug "[#{@message.id}] Received valid response #{response.inspect}" if @logger succeed response end end |
#run! ⇒ Object
118 119 120 |
# File 'lib/rubydns/resolver.rb', line 118 def run! try_next_server! end |