123456789_123456789_123456789_123456789_123456789_

Class: Resolv::DNS::Requester::TCP

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, ::Resolv::DNS::Requester
Instance Chain:
self, ::Resolv::DNS::Requester
Inherits: Resolv::DNS::Requester
Defined in: lib/resolv.rb

Class Method Summary

::Resolv::DNS::Requester - Inherited

.new

Instance Method Summary

::Resolv::DNS::Requester - Inherited

#close, #request, #sender_for

Constructor Details

.new(host, port = Port) ⇒ TCP

[ GitHub ] 

  


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



def initialize(host, port=Port)
  super()
  @host = host
  @port = port
  sock = TCPSocket.new(@host, @port)
  @socks = [sock]
  @senders = {}
end


  







Instance Method Details



  

    #close  
  

  [ GitHub ]


  

  


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



def close
  super
  @senders.each_key {|from,id|
    DNS.free_request_id(@host, @port, id)
  }
end


  








  

    #recv_reply(readable_socks)  
  

  [ GitHub ]


  

  


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



def recv_reply(readable_socks)
  len = readable_socks[0].read(2).unpack('n')[0]
  reply = @socks[0].read(len)
  return reply, nil
end


  








  

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

  [ GitHub ]


  

  


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



def sender(msg, data, host=@host, port=@port)
  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] = [request.length, id].pack('nn')
  return @senders[[nil,id]] = Sender.new(request, data, @socks[0])
end