Skip to content

Commit

Permalink
Merge pull request #2714 from ganmacs/fix-typo
Browse files Browse the repository at this point in the history
Fix typo
  • Loading branch information
ganmacs authored Dec 4, 2019
2 parents 29ad441 + 729bb01 commit bfc39b5
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions lib/fluent/engine.rb
Original file line number Diff line number Diff line change
Expand Up @@ -103,9 +103,9 @@ def run_configure(conf, dry_run: false)
def configure(conf)
@root_agent.configure(conf)

@fleunt_log_event_router = FluentLogEventRouter.build(@root_agent)
@fluent_log_event_router = FluentLogEventRouter.build(@root_agent)

if @fleunt_log_event_router.emittable?
if @fluent_log_event_router.emittable?
$log.enable_event(true)
end

Expand Down Expand Up @@ -145,7 +145,7 @@ def run
$log.info "starting fluentd worker", pid: Process.pid, ppid: Process.ppid, worker: worker_id
start

@fleunt_log_event_router.start
@fluent_log_event_router.start

$log.info "fluentd worker is now running", worker: worker_id
sleep MAINLOOP_SLEEP_INTERVAL until @engine_stopped
Expand All @@ -159,12 +159,12 @@ def run

unless @log_event_verbose
$log.enable_event(false)
@fleunt_log_event_router.graceful_stop
@fluent_log_event_router.graceful_stop
end
$log.info "shutting down fluentd worker", worker: worker_id
shutdown

@fleunt_log_event_router.stop
@fluent_log_event_router.stop
end

def stop
Expand All @@ -173,7 +173,7 @@ def stop
end

def push_log_event(tag, time, record)
@fleunt_log_event_router.emit_event([tag, time, record])
@fluent_log_event_router.emit_event([tag, time, record])
end

def worker_id
Expand Down

0 comments on commit bfc39b5

Please sign in to comment.