Class: Resolv::DNS::Requester::TCP
- Inherits:
-
Resolv::DNS::Requester
- Object
- Resolv::DNS::Requester
- Resolv::DNS::Requester::TCP
- Defined in:
- lib/resolv.rb
Defined Under Namespace
Classes: Sender
Instance Method Summary collapse
- #close ⇒ Object
-
#initialize(host, port = Port) ⇒ TCP
constructor
A new instance of TCP.
- #recv_reply ⇒ Object
- #sender(msg, data, host = @host, port = @port) ⇒ Object
Methods inherited from Resolv::DNS::Requester
Constructor Details
#initialize(host, port = Port) ⇒ TCP
Returns a new instance of TCP.
716 717 718 719 720 721 722 723 |
# File 'lib/resolv.rb', line 716 def initialize(host, port=Port) super() @host = host @port = port @sock = TCPSocket.new(@host, @port) @sock.fcntl(Fcntl::F_SETFD, Fcntl::FD_CLOEXEC) if defined? Fcntl::F_SETFD @senders = {} end |
Instance Method Details
#close ⇒ Object
749 750 751 752 753 754 |
# File 'lib/resolv.rb', line 749 def close super @senders.each_key {|from,id| DNS.free_request_id(@host, @port, id) } end |
#recv_reply ⇒ Object
725 726 727 728 729 |
# File 'lib/resolv.rb', line 725 def recv_reply len = @sock.read(2).unpack('n')[0] reply = @sock.read(len) return reply, nil end |
#sender(msg, data, host = @host, port = @port) ⇒ Object
731 732 733 734 735 736 737 738 739 |
# File 'lib/resolv.rb', line 731 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, @sock) end |