Class: EventMachine::DnsResolver::DnsSocket

Inherits:
EM::Connection
  • Object
show all
Defined in:
lib/em/dns_resolver.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.open ⇒ Object 



43
44
45
 
# File 'lib/em/dns_resolver.rb', line 43

def self.open
  EM::open_datagram_socket('0.0.0.0', 0, self)
end

Instance Method Details

#nameserver ⇒ Object 



69
70
71
 
# File 'lib/em/dns_resolver.rb', line 69

def nameserver
  @nameserver ||= DnsResolver.nameserver
end

#nameserver=(ns) ⇒ Object 



66
67
68
 
# File 'lib/em/dns_resolver.rb', line 66

def nameserver=(ns)
  @nameserver = ns
end

#post_init ⇒ Object 



46
47
48
49
 
# File 'lib/em/dns_resolver.rb', line 46

def post_init
  @requests = {}
  EM.add_periodic_timer(0.1, &method(:tick))
end

#receive_data(data) ⇒ Object

Decodes the packet, looks for the request and passes the response over to the requester



74
75
76
77
78
79
80
81
82
83
84
85
86
 
# File 'lib/em/dns_resolver.rb', line 74

def receive_data(data)
  msg = nil
  begin
    msg = Resolv::DNS::Message.decode data
  rescue
  else
    req = @requests[msg.id]
    if req
      @requests.delete(msg.id)
      req.receive_answer(msg)
    end
  end
end

#register_request(id, req) ⇒ Object 



56
57
58
59
60
61
62
 
# File 'lib/em/dns_resolver.rb', line 56

def register_request(id, req)
  if @requests.has_key?(id)
    raise RequestIdAlreadyUsed
  else
    @requests[id] = req
  end
end

#send_packet(pkt) ⇒ Object 



63
64
65
 
# File 'lib/em/dns_resolver.rb', line 63

def send_packet(pkt)
  send_datagram(pkt, nameserver, 53)
end

#tick ⇒ Object

Periodically called each second to fire request retries



51
52
53
54
55
 
# File 'lib/em/dns_resolver.rb', line 51

def tick
  @requests.each do |id,req|
    req.tick
  end
end