in_tail: reduce the lifespan of the buffer area

Signed-off-by: Shizuo Fujita <[email protected]>
fluent · Jan 9, 2025 · a7eb00c · a7eb00c
1 parent 5080f81
commit a7eb00c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/fluent/plugin/in_tail.rb b/lib/fluent/plugin/in_tail.rb
@@ -1119,7 +1119,6 @@ def initialize(watcher, path:, read_lines_limit:, read_bytes_limit_per_second:,
           @receive_lines = receive_lines
           @open_on_every_update = open_on_every_update
           @fifo = FIFO.new(from_encoding || Encoding::ASCII_8BIT, encoding || Encoding::ASCII_8BIT, log, max_line_size)
-          @iobuf = ''.force_encoding('ASCII-8BIT')
           @lines = []
           @io = nil
           @notify_mutex = Mutex.new
@@ -1201,6 +1200,7 @@ def handle_notify
           end
 
           with_io do |io|
+            iobuf = ''.force_encoding('ASCII-8BIT')
             begin
               read_more = false
               has_skipped_line = false
@@ -1211,7 +1211,7 @@ def handle_notify
                     @start_reading_time ||= Fluent::Clock.now
                     group_watcher&.update_reading_time(@path)
 
-                    data = io.readpartial(BYTES_TO_READ, @iobuf)
+                    data = io.readpartial(BYTES_TO_READ, iobuf)
                     @eof = false
                     @number_bytes_read += data.bytesize
                     @fifo << data