Method: Fluent::Plugin::HttpInput#start

Defined in:
lib/fluent/plugin/in_http.rb

#start ⇒ Object 



176
177
178
179
180
181
182
183
184
185
186
187
188
 
# File 'lib/fluent/plugin/in_http.rb', line 176

def start
  @_event_loop_run_timeout = @blocking_timeout

  super

  log.debug "listening http", bind: @bind, port: @port

  @km = KeepaliveManager.new(@keepalive_timeout)
  event_loop_attach(@km)

  server_create_connection(:in_http, @port, bind: @bind, backlog: @backlog, &method(:on_server_connect))
  @float_time_parser = Fluent::NumericTimeParser.new(:float)
end