123456789_123456789_123456789_123456789_123456789_

Class: Resolv::DNS::Requester::ConnectedUDP

Do not use. This class is for internal use only.
Relationships & Source Files
Namespace Children
Classes:
Sender
Super Chains via Extension / Inclusion / Inheritance
Class Chain:
self, Requester
Instance Chain:
self, Requester
Inherits: Requester
  • Object
Defined in: lib/resolv.rb

Class Method Summary

Instance Method Summary

Constructor Details

.new(host, port = Port) ⇒ ConnectedUDP

[ GitHub ] 

  


# File 'lib/resolv.rb', line 877



def initialize(host, port=Port)
  super()
  @host = host
  @port = port
  @mutex = Thread::Mutex.new
  @initialized = false
end


  







Instance Method Details



  

    #close  
  

  [ GitHub ]


  

  


# File 'lib/resolv.rb', line 933



def close
  @mutex.synchronize do
    if @initialized
      super
      @senders.each_key {|from, id|
        DNS.free_request_id(@host, @port, id)
      }
      @initialized = false
    end
  end
end


  








  

    #connect_socket   (private)
  

  [ GitHub ]


  

  


# File 'lib/resolv.rb', line 945



private def connect_socket
  is_ipv6 = @host.index(':')
  sock = UDPSocket.new(is_ipv6 ? Socket::AF_INET6 : Socket::AF_INET)
  @socks = [sock]
  sock.do_not_reverse_lookup = true
  DNS.bind_random_port(sock, is_ipv6 ? "::" : "0.0.0.0")
  sock.connect(@host, @port)
end


  








  

    #lazy_initialize  
  

  [ GitHub ]


  

  


# File 'lib/resolv.rb', line 885



def lazy_initialize
  @mutex.synchronize {
    next if @initialized
    @initialized = true
    connect_socket
  }
  self
end


  








  

    #recv_reply(readable_socks, timelimit = nil)  
  

  [ GitHub ]


  

  


# File 'lib/resolv.rb', line 903



def recv_reply(readable_socks, timelimit = nil)
  lazy_initialize
  reply = readable_socks[0].recv(UDPSize)
  return reply, nil
rescue Errno::ECONNREFUSED, Errno::ECONNRESET
  # The kernel reports these from an ICMP message, and a second one for
  # the same pair of endpoints is not always passed on: macOS 26.1 and
  # later deliver every other one.  A retry over this socket would then
  # wait out its whole timeout rather than fail at once, so start over
  # from a new source port.
  @mutex.synchronize {
    if @initialized
      @socks&.each(&:close)
      connect_socket
    end
  }
  raise
end


  








  

    #sender(msg, data, host = @host, port = @port)  
  

  [ GitHub ]


  

  


# File 'lib/resolv.rb', line 922



def sender(msg, data, host=@host, port=@port)
  lazy_initialize
  unless host == @host && port == @port
    raise RequestError.new("host/port don't match: #{host}:#{port}")
  end
  id = DNS.allocate_request_id(@host, @port)
  request = msg.encode
  request[0,2] = [id].pack('n')
  return @senders[[nil,id]] = Sender.new(request, data, self)
end


  








  

    #sock  
  



  

    
The socket to talk to the nameserver over, opening one if there is
none yet.  #recv_reply may have replaced it since a sender was
created, so senders ask for it per request instead of holding on to
one.

  



  [ GitHub ]


  

  


# File 'lib/resolv.rb', line 898



def sock
  lazy_initialize
  @socks[0]
end