Skip to content

Commit

Permalink
fluentd: Turn ForceStopAsyncSend true when async connect is used
Browse files Browse the repository at this point in the history
The flag ForceStopAsyncSend was added to fluent logger lib in v1.5.0 (at
this time named AsyncStop) to tell fluentd to abort sending logs
asynchronously as soon as possible, when its Close() method is called.
However this flag was broken because of the way the lib was handling it
(basically, the lib could be stucked in retry-connect loop without
checking this flag).

Since fluent logger lib v1.7.0, calling Close() (when ForceStopAsyncSend
is true) will really stop all ongoing send/connect procedure,
wherever it's stucked.

Signed-off-by: Albin Kerouanton <albinker@gmail.com>
  • Loading branch information
akerouanton authored and PettitWesley committed Jan 12, 2022
1 parent e05273c commit 8725d8e
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions daemon/logger/fluentd/fluentd.go
Expand Up @@ -242,6 +242,7 @@ func parseConfig(cfg map[string]string) (fluent.Config, error) {
AsyncConnect: asyncConnect,
SubSecondPrecision: subSecondPrecision,
RequestAck: requestAck,
ForceStopAsyncSend: async || asyncConnect,
}

return config, nil
Expand Down

0 comments on commit 8725d8e

Please sign in to comment.