class EventMachine::DNS::Request
Attributes
max_tries[RW]
retry_interval[RW]
Public Class Methods
new(socket, hostname)
click to toggle source
# File lib/em/resolver.rb, line 161 def initialize(socket, hostname) @socket = socket @hostname = hostname @tries = 0 @last_send = Time.at(0) @retry_interval = 3 @max_tries = 5 if addrs = Resolver.hosts[hostname] succeed addrs else EM.next_tick { tick } end end
Public Instance Methods
receive_answer(msg)
click to toggle source
# File lib/em/resolver.rb, line 187 def receive_answer(msg) addrs = [] msg.each_answer do |name,ttl,data| if data.kind_of?(Resolv::DNS::Resource::IN::A) || data.kind_of?(Resolv::DNS::Resource::IN::AAAA) addrs << data.address.to_s end end if addrs.empty? fail "rcode=#{msg.rcode}" else succeed addrs end end
tick()
click to toggle source
# File lib/em/resolver.rb, line 176 def tick # Break early if nothing to do return if @last_send + @retry_interval > Time.now if @tries < @max_tries send else @socket.deregister_request(@id, self) fail 'retries exceeded' end end
Private Instance Methods
id()
click to toggle source
# File lib/em/resolver.rb, line 211 def id begin @id = rand(65535) @socket.register_request(@id, self) rescue RequestIdAlreadyUsed retry end unless defined?(@id) @id end
packet()
click to toggle source
# File lib/em/resolver.rb, line 222 def packet msg = Resolv::DNS::Message.new msg.id = id msg.rd = 1 msg.add_question @hostname, Resolv::DNS::Resource::IN::A msg end
send()
click to toggle source
# File lib/em/resolver.rb, line 205 def send @tries += 1 @last_send = Time.now @socket.send_packet(packet.encode) end