Parent

Class/Module Index [+]

Quicksearch

Fluent::HttpInput::KeepaliveManager

Public Class Methods

new(timeout) click to toggle source
# File lib/fluent/plugin/in_http.rb, line 50
def initialize(timeout)
  super(1, true)
  @cons = {}
  @timeout = timeout.to_i
end

Public Instance Methods

add(sock) click to toggle source
# File lib/fluent/plugin/in_http.rb, line 56
def add(sock)
  @cons[sock] = sock
end
delete(sock) click to toggle source
# File lib/fluent/plugin/in_http.rb, line 60
def delete(sock)
  @cons.delete(sock)
end
on_timer() click to toggle source
# 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.