Class: Resolv::DNS::Requester::UnconnectedUDP
- Inherits:
-
Resolv::DNS::Requester
- Object
- Resolv::DNS::Requester
- Resolv::DNS::Requester::UnconnectedUDP
- Defined in:
- lib/resolv.rb
Overview
:nodoc:
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.
656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 |
# File 'lib/resolv.rb', line 656 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] sock = UDPSocket.new(af) sock.fcntl(Fcntl::F_SETFD, Fcntl::FD_CLOEXEC) if defined? Fcntl::F_SETFD DNS.bind_random_port(sock, bind_host) @socks << sock @socks_hash[bind_host] = sock } end |
Instance Method Details
#close ⇒ Object
693 694 695 696 697 698 |
# File 'lib/resolv.rb', line 693 def close super @senders.each_key {|service, id| DNS.free_request_id(service[0], service[1], id) } end |
#recv_reply(readable_socks) ⇒ Object
678 679 680 681 |
# File 'lib/resolv.rb', line 678 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
683 684 685 686 687 688 689 690 691 |
# File 'lib/resolv.rb', line 683 def sender(msg, data, host, port=Port) service = [host, port] id = DNS.allocate_request_id(host, port) request = msg.encode request[0,2] = [id].pack('n') sock = @socks_hash[host.index(':') ? "::" : "0.0.0.0"] return @senders[[service, id]] = Sender.new(request, data, sock, host, port) end |