Class: Fluent::Plugin::TailInput::TailWatcher::FIFO

Inherits:
Object
  • Object
show all
Defined in:
lib/fluent/plugin/in_tail.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(from_encoding, encoding) ⇒ FIFO

Returns a new instance of FIFO.



982
983
984
985
986
987
988
 
# File 'lib/fluent/plugin/in_tail.rb', line 982

def initialize(from_encoding, encoding)
  @from_encoding = from_encoding
  @encoding = encoding
  @need_enc = from_encoding != encoding
  @buffer = ''.force_encoding(from_encoding)
  @eol = "\n".encode(from_encoding).freeze
end

Instance Attribute Details

#buffer ⇒ Object (readonly)

Returns the value of attribute buffer.



990
991
992
 
# File 'lib/fluent/plugin/in_tail.rb', line 990

def buffer
  @buffer
end

#encoding ⇒ Object (readonly)

Returns the value of attribute encoding.



990
991
992
 
# File 'lib/fluent/plugin/in_tail.rb', line 990

def encoding
  @encoding
end

#from_encoding ⇒ Object (readonly)

Returns the value of attribute from_encoding.



990
991
992
 
# File 'lib/fluent/plugin/in_tail.rb', line 990

def from_encoding
  @from_encoding
end

Instance Method Details

#<<(chunk) ⇒ Object 



992
993
994
995
996
997
998
999
1000
1001
1002
1003
1004
1005
1006
1007
1008
 
# File 'lib/fluent/plugin/in_tail.rb', line 992

def <<(chunk)
  # Although "chunk" is most likely transient besides String#force_encoding itself
  # won't affect the actual content of it, it is also probable that "chunk" is
  # a reused buffer and changing its encoding causes some problems on the caller side.
  #
  # Actually, the caller here is specific and "chunk" comes from IO#partial with
  # the second argument, which the function always returns as a return value.
  #
  # Feeding a string that has its encoding attribute set to any double-byte or
  # quad-byte encoding to IO#readpartial as the second arguments results in an
  # assertion failure on Ruby < 2.4.0 for unknown reasons.
  orig_encoding = chunk.encoding
  chunk.force_encoding(from_encoding)
  @buffer << chunk
  # Thus the encoding needs to be reverted back here
  chunk.force_encoding(orig_encoding)
end

#bytesize ⇒ Object 



1034
1035
1036
 
# File 'lib/fluent/plugin/in_tail.rb', line 1034

def bytesize
  @buffer.bytesize
end

#convert(s) ⇒ Object 



1010
1011
1012
1013
1014
1015
1016
1017
1018
 
# File 'lib/fluent/plugin/in_tail.rb', line 1010

def convert(s)
  if @need_enc
    s.encode!(@encoding, @from_encoding)
  else
    s
  end
rescue
  s.encode!(@encoding, @from_encoding, :invalid => :replace, :undef => :replace)
end

#read_lines(lines) ⇒ Object 



1020
1021
1022
1023
1024
1025
1026
1027
1028
1029
1030
1031
1032
 
# File 'lib/fluent/plugin/in_tail.rb', line 1020

def read_lines(lines)
  idx = @buffer.index(@eol)

  until idx.nil?
    # Using freeze and slice is faster than slice!
    # See https://github.com/fluent/fluentd/pull/2527
    @buffer.freeze
    rbuf = @buffer.slice(0, idx + 1)
    @buffer = @buffer.slice(idx + 1, @buffer.size)
    idx = @buffer.index(@eol)
    lines << convert(rbuf)
  end
end