class Ring::SQA::Responder

Public Class Methods

new() click to toggle source
# File lib/ring/sqa/poller/responder.rb, line 14
def initialize
  run
end

Public Instance Methods

run() click to toggle source
# File lib/ring/sqa/poller/responder.rb, line 5
def run
  udp = udp_socket
  Log.debug "Responder binding to #{address.inspect} in port #{port}" if CFG.debug?
  udp.bind address, port
  loop { respond udp }
end

Private Instance Methods

respond(udp) click to toggle source
# File lib/ring/sqa/poller/responder.rb, line 18
def respond udp
  data, far_end = udp.recvfrom MAX_READ
  udp.send data, 0, far_end[3], port+1
  Log.debug "Sent response '#{data}' to '#{far_end[3]}'" if CFG.debug?
end