Sha256: 78cdc2040f61ae71250b2da5354cfffb0e52166e62929f572551e4d124a0c60b
Contents?: true
Size: 1.17 KB
Versions: 99
Compression:
Stored size: 1.17 KB
Contents
module ForemanInventoryUpload
module Async
class ProgressOutput
def self.get(label)
ProgressOutput.new(label, :reader)
end
def self.register(label)
ProgressOutput.new(label, :writer)
end
def initialize(label, mode)
@label = label
@mode = mode
end
def buffer
@buffer ||= begin
File.open(file_name, file_mode)
rescue Errno::ENOENT
StringIO.new
end
end
def full_output
buffer.read
end
def write_line(line)
buffer << line
buffer.fsync
end
def close
@buffer&.close
end
def status
File.read(file_name(:status))
rescue Errno::ENOENT
''
end
def status=(status)
File.atomic_write(file_name(:status)) do |status_file|
status_file.write(status)
end
end
private
def file_mode
(@mode == :reader) ? 'r' : 'w'
end
def file_name(type = 'out')
File.join(ForemanInventoryUpload.outputs_folder, "#{@label}.#{type}")
end
end
end
end
Version data entries
99 entries across 99 versions & 2 rubygems