Object
Asynchronous DNS resolver using Celluloid::IO::UDPSocket
Maximum UDP packet we’ll accept
# File lib/celluloid/io/dns_resolver.rb, line 15 def self.generate_id @mutex.synchronize { @identifier = (@identifier + 1) & 0xFFFF } end
# File lib/celluloid/io/dns_resolver.rb, line 19 def self.nameservers Resolv::DNS::Config.default_config_hash[:nameserver] end
# File lib/celluloid/io/dns_resolver.rb, line 23 def initialize @nameservers = self.class.nameservers @server = IPAddr.new(@nameservers.sample) # The non-blocking secret sauce is here, as this is actually a # Celluloid::IO::UDPSocket @socket = UDPSocket.new(@server.family) end
# File lib/celluloid/io/dns_resolver.rb, line 33 def resolve(hostname) if host = resolve_hostname(hostname) unless ip_address = resolve_host(host) raise Resolv::ResolvError, "invalid entry in hosts file: #{host}" end return ip_address end query = build_query(hostname) @socket.send query.encode, 0, @server.to_s, DNS_PORT data, _ = @socket.recvfrom(MAX_PACKET_SIZE) response = Resolv::DNS::Message.decode(data) addrs = [] # The answer might include IN::CNAME entries so filters them out # to include IN::A & IN::AAAA entries only. response.each_answer { |name, ttl, value| addrs << value.address if value.respond_to?(:address) } return if addrs.empty? return addrs.first if addrs.size == 1 addrs end
Generated with the Darkfish Rdoc Generator 2.