# File lib/puma/reactor.rb, line 7 def initialize(server, app_pool) @server = server @events = server.events @app_pool = app_pool @mutex = Mutex.new @ready, @trigger = Puma::Util.pipe @input = [] @sleep_for = DefaultSleepFor @timeouts = [] @sockets = [@ready] end
# File lib/puma/reactor.rb, line 152 def add(c) @mutex.synchronize do @input << c @trigger << "*" if c.timeout_at @timeouts << c @timeouts.sort! { |a,b| a.timeout_at <=> b.timeout_at } calculate_sleep end end end
# File lib/puma/reactor.rb, line 138 def calculate_sleep if @timeouts.empty? @sleep_for = DefaultSleepFor else diff = @timeouts.first.timeout_at.to_f - Time.now.to_f if diff < 0.0 @sleep_for = 0 else @sleep_for = diff end end end
Close all watched sockets and clear them from being watched
# File lib/puma/reactor.rb, line 167 def clear! begin @trigger << "c" rescue IOError end end
# File lib/puma/reactor.rb, line 116 def run run_internal ensure @trigger.close @ready.close end
# File lib/puma/reactor.rb, line 123 def run_in_thread @thread = Thread.new do begin run_internal rescue StandardError => e STDERR.puts "Error in reactor loop escaped: #{e.message} (#{e.class})" STDERR.puts e.backtrace retry ensure @trigger.close @ready.close end end end
Generated with the Darkfish Rdoc Generator 2.