Sha256: f9cf33d9ba28b0ac94d31a2b20bae57fc79e6717b63445b10606b364fd7cafca
Contents?: true
Size: 1.2 KB
Versions: 57
Compression:
Stored size: 1.2 KB
Contents
require "log4r"
require "timeout"
module VagrantPlugins
module MCS
module Action
# This action will wait for a machine to reach a specific state or quit by timeout
class WaitForState
# env[:result] will be false in case of timeout.
# @param [Symbol] state Target machine state.
# @param [Number] timeout Timeout in seconds.
def initialize(app, env, state, timeout)
@app = app
@logger = Log4r::Logger.new("vagrant_mcs::action::wait_for_state")
@state = state
@timeout = timeout
end
def call(env)
env[:result] = true
if env[:machine].state.id == @state
@logger.info(I18n.t("vagrant_mcs.already_status", :status => @state))
else
@logger.info("Waiting for machine to reach state #{@state}")
begin
Timeout.timeout(@timeout) do
until env[:machine].state.id == @state
sleep 2
end
end
rescue Timeout::Error
env[:result] = false # couldn't reach state in time
end
end
@app.call(env)
end
end
end
end
end
Version data entries
57 entries across 57 versions & 1 rubygems