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 



44
45
46
 
# File 'lib/em-dns-resolver.rb', line 44

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

Instance Method Details

#connected? ⇒ Boolean

Returns:

  • (Boolean) 


89
 
# File 'lib/em-dns-resolver.rb', line 89

def connected?; @connected; end

#nameserver ⇒ Object 



71
72
73
 
# File 'lib/em-dns-resolver.rb', line 71

def nameserver
  @nameserver ||= DnsResolver.nameserver
end

#nameserver=(ns) ⇒ Object 



68
69
70
 
# File 'lib/em-dns-resolver.rb', line 68

def nameserver=(ns)
  @nameserver = ns
end

#post_init ⇒ Object 



47
48
49
50
51
 
# File 'lib/em-dns-resolver.rb', line 47

def post_init
  @requests = {}
  @connected = true
  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



76
77
78
79
80
81
82
83
84
85
86
87
88
 
# File 'lib/em-dns-resolver.rb', line 76

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 



58
59
60
61
62
63
64
 
# File 'lib/em-dns-resolver.rb', line 58

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

#send_packet(pkt) ⇒ Object 



65
66
67
 
# File 'lib/em-dns-resolver.rb', line 65

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

#tick ⇒ Object

Periodically called each second to fire request retries



53
54
55
56
57
 
# File 'lib/em-dns-resolver.rb', line 53

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

#unbind ⇒ Object 



90
91
92
 
# File 'lib/em-dns-resolver.rb', line 90

def unbind
  @connected = false
end