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