Class: Vagrant::Action::Runner

Inherits:
Object
  • Object
show all
Defined in:
lib/vagrant/action/runner.rb

Constant Summary collapse

@@reported_interrupt = 
false

Instance Method Summary collapse

Constructor Details

#initialize(globals = nil, &block) ⇒ Runner

Returns a new instance of Runner.



14
15
16
17
18
 
# File 'lib/vagrant/action/runner.rb', line 14

def initialize(globals=nil, &block)
  @globals      = globals || {}
  @lazy_globals = block
  @logger       = Log4r::Logger.new("vagrant::action::runner")
end

Instance Method Details

#run(callable_id, options = nil) ⇒ Object

Raises:

  • (ArgumentError) 


20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/vagrant/action/runner.rb', line 20

def run(callable_id, options=nil)
  callable = callable_id
  callable = Builder.build(callable_id) if callable_id.kind_of?(Class)
  raise ArgumentError, "Argument to run must be a callable object or registered action." if !callable || !callable.respond_to?(:call)

  # Create the initial environment with the options given
  environment = {}
  environment.merge!(@globals)
  environment.merge!(@lazy_globals.call) if @lazy_globals
  environment.merge!(options || {})

  # Setup the action hooks
  hooks = Vagrant.plugin("2").manager.action_hooks(environment[:action_name])
  if !hooks.empty?
    @logger.info("Preparing hooks for middleware sequence...")
    environment[:action_hooks] = hooks.map do |hook_proc|
      Hook.new.tap do |h|
        hook_proc.call(h)
      end
    end

    @logger.info("#{environment[:action_hooks].length} hooks defined.")
  end

  # Run the action chain in a busy block, marking the environment as
  # interrupted if a SIGINT occurs, and exiting cleanly once the
  # chain has been run.
  ui = environment[:ui] if environment.has_key?(:ui)
  int_callback = lambda do
    if environment[:interrupted]
      ui.error I18n.t("vagrant.actions.runner.exit_immediately") if ui
      abort
    end

    ui.warn I18n.t("vagrant.actions.runner.waiting_cleanup") if ui && !@@reported_interrupt
    environment[:interrupted] = true
    @@reported_interrupt = true
  end

  # We place a process lock around every action that is called
  @logger.info("Running action: #{callable_id}")
  Util::Busy.busy(int_callback) { callable.call(environment) }

  # Return the environment in case there are things in there that
  # the caller wants to use.
  environment
end