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

Inherits:
Requester
  • Object
show all
Defined in:
lib/resolv.rb

Overview

:nodoc:

Defined Under Namespace

Classes: Sender

Instance Method Summary collapse

Constructor Details

#initialize(host, port = Port) ⇒ ConnectedUDP

Returns a new instance of ConnectedUDP.



877
878
879
880
881
882
883
 
# 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 ⇒ Object 



933
934
935
936
937
938
939
940
941
942
943
 
# 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

#lazy_initialize ⇒ Object 



885
886
887
888
889
890
891
892
 
# 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) ⇒ Object 



903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
 
# 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) ⇒ Object 



922
923
924
925
926
927
928
929
930
931
 
# 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 ⇒ Object

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.



898
899
900
901
 
# File 'lib/resolv.rb', line 898

def sock
  lazy_initialize
  @socks[0]
end