Sha256: 081fe6704f70ac994fbf90ded641ce207287dd743b69907a6adaac088940903a
Contents?: true
Size: 1.77 KB
Versions: 6
Compression:
Stored size: 1.77 KB
Contents
module Snapsync
module Btrfs
class Error < RuntimeError
attr_reader :error_lines
def initialize(error_lines = Array.new)
@error_lines = error_lines
end
def pretty_print(pp)
pp.text message
pp.nest(2) do
error_lines.each do |l|
pp.breakable
pp.text l.chomp
end
end
end
end
def self.popen(*args, mode: 'r', raise_on_error: true, **options)
err_r, err_w = IO.pipe
block_error, block_result = nil
IO.popen(['btrfs', *args, err: err_w, **options], mode) do |io|
err_w.close
if block_given?
begin
block_result = yield(io)
rescue Error
raise
rescue Exception => block_error
end
else io.read
end
end
if $?.success? && !block_error
block_result
elsif raise_on_error
if block_error
raise Error.new, block_error.message
else
raise Error.new, "btrfs failed"
end
end
rescue Error => e
prefix = args.join(" ")
lines = err_r.readlines.map do |line|
"#{prefix}: #{line.chomp}"
end
raise Error.new(e.error_lines + lines), e.message, e.backtrace
ensure err_r.close
end
def self.run(*args, **options)
popen(*args, **options) do |io|
io.read
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems