Coolio::TimerWatcher
# File lib/fluent/plugin/in_http.rb, line 50 def initialize(timeout) super(1, true) @cons = {} @timeout = timeout.to_i end
# File lib/fluent/plugin/in_http.rb, line 56 def add(sock) @cons[sock] = sock end
# File lib/fluent/plugin/in_http.rb, line 60 def delete(sock) @cons.delete(sock) end
# File lib/fluent/plugin/in_http.rb, line 64 def on_timer @cons.each_pair {|sock,val| if sock.step_idle > @timeout sock.close end } end
[Validate]
Generated with the Darkfish Rdoc Generator 2.