class Vagrant::LXC::SudoWrapper
Attributes
wrapper_path[R]
Public Class Methods
new(wrapper_path = nil)
click to toggle source
# File lib/vagrant-lxc/sudo_wrapper.rb, line 9 def initialize(wrapper_path = nil) @wrapper_path = wrapper_path @logger = Log4r::Logger.new("vagrant::lxc::sudo_wrapper") end
Public Instance Methods
run(*command)
click to toggle source
# File lib/vagrant-lxc/sudo_wrapper.rb, line 14 def run(*command) options = command.last.is_a?(Hash) ? command.last : {} command.unshift @wrapper_path if @wrapper_path && !options[:no_wrapper] execute *(['sudo'] + command) end
Private Instance Methods
execute(*command, &block)
click to toggle source
TODO: Review code below this line, it was pretty much a copy and
paste from VirtualBox base driver and has no tests
# File lib/vagrant-lxc/sudo_wrapper.rb, line 24 def execute(*command, &block) # Get the options hash if it exists opts = {} opts = command.pop if command.last.is_a?(Hash) tries = 0 tries = 3 if opts[:retryable] sleep = opts.fetch(:sleep, 1) # Variable to store our execution result r = nil retryable(:on => LXC::Errors::ExecuteError, :tries => tries, :sleep => sleep) do # Execute the command r = raw(*command, &block) # If the command was a failure, then raise an exception that is # nicely handled by Vagrant. if r.exit_code != 0 if @interrupted @logger.info("Exit code != 0, but interrupted. Ignoring.") else raise LXC::Errors::ExecuteError, command: command.inspect, stderr: r.stderr, stdout: r.stdout end end end # Return the output, making sure to replace any Windows-style # newlines with Unix-style. stdout = r.stdout.gsub("\r\n", "\n") if opts[:show_stderr] { :stdout => stdout, :stderr => r.stderr.gsub("\r\n", "\n") } else stdout end end
raw(*command, &block)
click to toggle source
# File lib/vagrant-lxc/sudo_wrapper.rb, line 63 def raw(*command, &block) int_callback = lambda do @interrupted = true @logger.info("Interrupted.") end # Append in the options for subprocess command << { :notify => [:stdout, :stderr] } Vagrant::Util::Busy.busy(int_callback) do Vagrant::Util::Subprocess.execute(*command, &block) end end