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

Inherits:
Resolv::DNS::Requester show all
Defined in:
lib/logstash/patches/resolv_9270.rb

Overview

:nodoc:

Defined Under Namespace

Classes: Sender

Instance Method Summary collapse

Methods inherited from Resolv::DNS::Requester

#request, #sender_for

Constructor Details

#initialize(host, port = Port) ⇒ ConnectedUDP

Returns a new instance of ConnectedUDP.



828
829
830
831
832
833
834
 
# File 'lib/logstash/patches/resolv_9270.rb', line 828

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

Instance Method Details

#close ⇒ Object 



867
868
869
870
871
872
873
874
875
876
877
 
# File 'lib/logstash/patches/resolv_9270.rb', line 867

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 



836
837
838
839
840
841
842
843
844
845
846
847
848
 
# File 'lib/logstash/patches/resolv_9270.rb', line 836

def lazy_initialize
  @mutex.synchronize {
    next if @initialized
    @initialized = true
    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)
  }
  self
end

#recv_reply(readable_socks) ⇒ Object 



850
851
852
853
854
 
# File 'lib/logstash/patches/resolv_9270.rb', line 850

def recv_reply(readable_socks)
  lazy_initialize
  reply = readable_socks[0].recv(UDPSize)
  return reply, nil
end

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



856
857
858
859
860
861
862
863
864
865
 
# File 'lib/logstash/patches/resolv_9270.rb', line 856

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, @socks[0])
end