Class: Resolv::DNS::Requester::UnconnectedUDP
- Inherits:
-
Resolv::DNS::Requester
- Object
- Resolv::DNS::Requester
- Resolv::DNS::Requester::UnconnectedUDP
- Defined in:
- lib/resolv.rb
Overview
:nodoc:
Direct Known Subclasses
Defined Under Namespace
Classes: Sender
Instance Method Summary collapse
- #close ⇒ Object
-
#initialize(*nameserver_port) ⇒ UnconnectedUDP
constructor
A new instance of UnconnectedUDP.
- #recv_reply(readable_socks) ⇒ Object
- #sender(msg, data, host, port = Port) ⇒ Object
Methods inherited from Resolv::DNS::Requester
Constructor Details
#initialize(*nameserver_port) ⇒ UnconnectedUDP
Returns a new instance of UnconnectedUDP.
732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 |
# File 'lib/resolv.rb', line 732 def initialize(*nameserver_port) super() @nameserver_port = nameserver_port @socks_hash = {} @socks = [] nameserver_port.each {|host, port| if host.index(':') bind_host = "::" af = Socket::AF_INET6 else bind_host = "0.0.0.0" af = Socket::AF_INET end next if @socks_hash[bind_host] begin sock = UDPSocket.new(af) rescue Errno::EAFNOSUPPORT next # The kernel doesn't support the address family. end sock.do_not_reverse_lookup = true DNS.bind_random_port(sock, bind_host) @socks << sock @socks_hash[bind_host] = sock } end |
Instance Method Details
#close ⇒ Object
774 775 776 777 778 779 |
# File 'lib/resolv.rb', line 774 def close super @senders.each_key {|service, id| DNS.free_request_id(service[0], service[1], id) } end |
#recv_reply(readable_socks) ⇒ Object
758 759 760 761 |
# File 'lib/resolv.rb', line 758 def recv_reply(readable_socks) reply, from = readable_socks[0].recvfrom(UDPSize) return reply, [from[3],from[1]] end |
#sender(msg, data, host, port = Port) ⇒ Object
763 764 765 766 767 768 769 770 771 772 |
# File 'lib/resolv.rb', line 763 def sender(msg, data, host, port=Port) sock = @socks_hash[host.index(':') ? "::" : "0.0.0.0"] return nil if !sock service = [host, port] id = DNS.allocate_request_id(host, port) request = msg.encode request[0,2] = [id].pack('n') return @senders[[service, id]] = Sender.new(request, data, sock, host, port) end |