# File lib/fluent/plugin/buf_file.rb, line 19 def initialize(key, path, unique_id, mode="a+", symlink_path = nil) super(key) @path = path @unique_id = unique_id @file = File.open(@path, mode, DEFAULT_FILE_PERMISSION) @file.sync = true @size = @file.stat.size FileUtils.ln_sf(@path, symlink_path) if symlink_path end
# File lib/fluent/plugin/buf_file.rb, line 31 def <<(data) @file.write(data) @size += data.bytesize end
# File lib/fluent/plugin/buf_file.rb, line 44 def close stat = @file.stat @file.close if stat.size == 0 File.unlink(@path) end end
# File lib/fluent/plugin/buf_file.rb, line 40 def empty? @size == 0 end
# File lib/fluent/plugin/buf_file.rb, line 67 def mv(path) File.rename(@path, path) @path = path end
# File lib/fluent/plugin/buf_file.rb, line 62 def open(&block) @file.pos = 0 yield @file end
# File lib/fluent/plugin/buf_file.rb, line 52 def purge @file.close File.unlink(@path) rescue nil # TODO rescue? end
Generated with the Darkfish Rdoc Generator 2.