Class: VagrantPlugins::ProviderLibvirt::Action::ReadState
- Inherits:
-
Object
- Object
- VagrantPlugins::ProviderLibvirt::Action::ReadState
- Defined in:
- lib/vagrant-libvirt/action/read_state.rb
Overview
This action reads the state of the machine and puts it in the ‘:machine_state_id` key in the environment.
Instance Method Summary collapse
- #call(env) ⇒ Object
-
#initialize(app, env) ⇒ ReadState
constructor
A new instance of ReadState.
- #read_state(libvirt, machine) ⇒ Object
Constructor Details
#initialize(app, env) ⇒ ReadState
Returns a new instance of ReadState.
9 10 11 12 |
# File 'lib/vagrant-libvirt/action/read_state.rb', line 9 def initialize(app, env) @app = app @logger = Log4r::Logger.new('vagrant_libvirt::action::read_state') end |
Instance Method Details
#call(env) ⇒ Object
14 15 16 17 |
# File 'lib/vagrant-libvirt/action/read_state.rb', line 14 def call(env) env[:machine_state_id] = read_state(env[:libvirt_compute], env[:machine]) @app.call(env) end |
#read_state(libvirt, machine) ⇒ Object
19 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 |
# File 'lib/vagrant-libvirt/action/read_state.rb', line 19 def read_state(libvirt, machine) return :not_created if machine.id.nil? begin server = libvirt.servers.get(machine.id) rescue Libvirt::RetrieveError => e server = nil @logger.debug('Machine not found #{e}.') end # Find the machine begin # Wait for libvirt to shutdown the domain while libvirt.servers.get(machine.id).state.to_sym == :'shutting-down' do @logger.info('Waiting on the machine to shut down...') sleep 1 end server = libvirt.servers.get(machine.id) if server.nil? || server.state.to_sym == :terminated # The machine can't be found @logger.info('Machine terminated, assuming it got destroyed.') machine.id = nil return :not_created end rescue Libvirt::RetrieveError => e if e.libvirt_code == ProviderLibvirt::Util::ErrorCodes::VIR_ERR_NO_DOMAIN @logger.info("Machine #{machine.id} not found.") machine.id = nil return :not_created else raise e end end # Return the state return server.state.to_sym end |