Class: Resolv::DNS::Requester::UnconnectedUDP

Inherits:
Resolv::DNS::Requester show all
Defined in:
lib/resolv.rb

Overview

:nodoc:

Defined Under Namespace

Classes: Sender

Instance Method Summary (collapse)

Methods inherited from Resolv::DNS::Requester

#request

Constructor Details

- (UnconnectedUDP) initialize(*nameserver_port)

A new instance of UnconnectedUDP



673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
 
# File 'lib/resolv.rb', line 673

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.do_not_reverse_lookup = true
    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

- (Object) close 



711
712
713
714
715
716
 
# File 'lib/resolv.rb', line 711

def close
  super
  @senders.each_key {|service, id|
    DNS.free_request_id(service[0], service[1], id)
  }
end

- (Object) recv_reply(readable_socks) 



696
697
698
699
 
# File 'lib/resolv.rb', line 696

def recv_reply(readable_socks)
  reply, from = readable_socks[0].recvfrom(UDPSize)
  return reply, [from[3],from[1]]
end

- (Object) sender(msg, data, host, port = Port) 



701
702
703
704
705
706
707
708
709
 
# File 'lib/resolv.rb', line 701

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