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

Inherits:
Resolv::DNS::Requester show all
Defined in:
lib/net/dns/resolv.rb

Overview

:nodoc:

Defined Under Namespace

Classes: Sender

Instance Method Summary collapse

Methods inherited from Resolv::DNS::Requester

#close, #delete

Constructor Details

#initialize(host, port = Port) ⇒ TCP 



712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
 
# File 'lib/net/dns/resolv.rb', line 712

def initialize(host, port=Port)
  super()
  @host = host
  @port = port
  @sock = TCPSocket.new
  @sock.connect(host, port)
  @sock.fcntl(Fcntl::F_SETFD, 1) if defined? Fcntl::F_SETFD
  @id = -1
  @senders = {}
  @thread = Thread.new {
    DNSThreadGroup.add Thread.current
    loop {
      len = @sock.read(2).unpack('n')
      reply = @sock.read(len)
      msg = begin
        Message.decode(reply)
      rescue DecodeError
        STDERR.print("DNS message decoding error: #{reply.inspect}")
        next
      end
      if s = @senders[msg.id]
        s.push msg
      else
        #STDERR.print("non-handled DNS message: #{msg.inspect}")
      end
    }
  }
end

Instance Method Details

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



741
742
743
744
745
746
747
748
749
 
# File 'lib/net/dns/resolv.rb', line 741

def sender(msg, data, queue, host=@host, port=@port)
  unless host == @host && port == @port
    raise RequestError.new("host/port don't match: #{host}:#{port}")
  end
  id = Thread.exclusive { @id = (@id + 1) & 0xffff }
  request = msg.encode
  request[0,2] = [request.length, id].pack('nn')
  return @senders[id] = Sender.new(request, data, @sock, queue)
end