Class: EventMachine::DnsResolver::Request
- Inherits:
-
Object
- Object
- EventMachine::DnsResolver::Request
- Includes:
- Deferrable
- Defined in:
- lib/em/dns_resolver.rb
Overview
Request
Instance Attribute Summary collapse
-
#max_tries ⇒ Object
Returns the value of attribute max_tries.
-
#retry_interval ⇒ Object
Returns the value of attribute retry_interval.
Instance Method Summary collapse
-
#initialize(socket, hostname) ⇒ Request
constructor
A new instance of Request.
-
#receive_answer(msg) ⇒ Object
Called by DnsSocket#receive_data.
- #tick ⇒ Object
Constructor Details
#initialize(socket, hostname) ⇒ Request
Returns a new instance of Request.
97 98 99 100 101 102 103 104 105 |
# File 'lib/em/dns_resolver.rb', line 97 def initialize(socket, hostname) @socket = socket @hostname = hostname @tries = 0 @last_send = Time.at(0) @retry_interval = 3 @max_tries = 5 EM.next_tick { tick } end |
Instance Attribute Details
#max_tries ⇒ Object
Returns the value of attribute max_tries.
96 97 98 |
# File 'lib/em/dns_resolver.rb', line 96 def max_tries @max_tries end |
#retry_interval ⇒ Object
Returns the value of attribute retry_interval.
95 96 97 |
# File 'lib/em/dns_resolver.rb', line 95 def retry_interval @retry_interval end |
Instance Method Details
#receive_answer(msg) ⇒ Object
Called by DnsSocket#receive_data
117 118 119 120 121 122 123 124 125 126 127 128 129 130 |
# File 'lib/em/dns_resolver.rb', line 117 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 ⇒ Object
106 107 108 109 110 111 112 113 114 115 |
# File 'lib/em/dns_resolver.rb', line 106 def tick # Break early if nothing to do return if @last_send + @retry_interval > Time.now if @tries < @max_tries send else fail 'retries exceeded' end end |