Class: ResolvFiber::DNS::Requester::TCP

Inherits:
ResolvFiber::DNS::Requester show all
Defined in:
lib/resolv_fiber.rb

Overview

:nodoc:

Defined Under Namespace

Classes: Sender

Instance Method Summary collapse

Methods inherited from ResolvFiber::DNS::Requester

#request, #sender_for

Constructor Details

#initialize(host, port = Port) ⇒ TCP

Returns a new instance of TCP.



909
910
911
912
913
914
915
916
 
# File 'lib/resolv_fiber.rb', line 909

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

Instance Method Details

#close ⇒ Object 



942
943
944
945
946
947
 
# File 'lib/resolv_fiber.rb', line 942

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

#recv_reply(readable_socks) ⇒ Object 



918
919
920
921
922
 
# File 'lib/resolv_fiber.rb', line 918

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) ⇒ Object 



924
925
926
927
928
929
930
931
932
 
# File 'lib/resolv_fiber.rb', line 924

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