We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b64c3f8 commit f0f75cfCopy full SHA for f0f75cf
lib/fluent/logger/fluent_logger.rb
@@ -225,15 +225,15 @@ def write(msg)
225
end
226
227
begin
228
- send_data(@pending)
+ data_to_send = @pending
229
@pending = nil
230
+ send_data(data_to_send)
231
true
232
rescue => e
233
set_last_error(e)
234
if pending_bytesize > @limit
235
@logger.error("FluentLogger: Can't send logs to #{connection_string}: #{$!}")
- call_buffer_overflow_handler(@pending)
236
- @pending = nil
+ call_buffer_overflow_handler(data_to_send)
237
238
@con.close if connect?
239
@con = nil
0 commit comments