Tweak code for log throttling

Signed-off-by: Hiroshi Hatake <hatake@calyptia.com>
fluent · May 11, 2021 · 338651e · 338651e
1 parent 478b487
commit 338651e
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/lib/fluent/plugin/in_tail.rb b/lib/fluent/plugin/in_tail.rb
@@ -958,10 +958,12 @@ def handle_notify
                     limit_bytes_per_second_reached = (number_bytes_read >= @read_bytes_limit_per_second && @read_bytes_limit_per_second > 0)
                     @log.debug("reading file: #{@path}")
                     if @lines.size >= @read_lines_limit || limit_bytes_per_second_reached
-                      # not to use too much memory in case the file is very large
-                      read_more = true
-
-                      read_more = false if limit_bytes_per_second_reached && need_to_get_out_for_log_ingestion_loop?(start_reading)
+                      if limit_bytes_per_second_reached && need_to_get_out_for_log_ingestion_loop?(start_reading)
+                        # Do nothing. Just get out from tailing loop.
+                      else
+                        # not to use too much memory in case the file is very large
+                        read_more = true
+                      end
 
                       break
                     end