dc55c914e4
The LXC provider issues the "fetch_ip" action to look up the IP address of the container as part of its "ssh_info" action. Vagrant::LXC::Action.action_fetch_ip checks the machine state using Builtin::IsState, which calls Vagrant::Machine.state, which also updates the state in the machine index and acquires a machine index entry lock to do that. A race condition ensues in WaitForCommunicator.call, where ready_thr tries to acquire the machine index lock while running ssh_info, and states_thr tries to acquire the same lock doing its own state look up (env[:machine].state.id). If they both try to acquire the lock at the same time, one will fail, and an exception will be raised. Work around this issue by checking for the desired machine state (:running) in Vagrant::LXC::Provider.ssh_info, which can get the state from Vagrant::LXC::Provider.state, which in turn does not write out the state into the index file and does not acquire the index entry lock.
104 lines
3.1 KiB
Ruby
104 lines
3.1 KiB
Ruby
require "log4r"
|
|
|
|
require "vagrant-lxc/action"
|
|
require "vagrant-lxc/driver"
|
|
require "vagrant-lxc/sudo_wrapper"
|
|
|
|
module Vagrant
|
|
module LXC
|
|
class Provider < Vagrant.plugin("2", :provider)
|
|
attr_reader :driver
|
|
|
|
def initialize(machine)
|
|
@logger = Log4r::Logger.new("vagrant::provider::lxc")
|
|
@machine = machine
|
|
|
|
ensure_lxc_installed!
|
|
machine_id_changed
|
|
end
|
|
|
|
def sudo_wrapper
|
|
@shell ||= begin
|
|
wrapper = Pathname.new(LXC.sudo_wrapper_path).exist? &&
|
|
LXC.sudo_wrapper_path || nil
|
|
@logger.debug("Found sudo wrapper : #{wrapper}") if wrapper
|
|
SudoWrapper.new(wrapper)
|
|
end
|
|
end
|
|
|
|
def ensure_lxc_installed!
|
|
begin
|
|
sudo_wrapper.run("which", "lxc-create")
|
|
rescue Vagrant::LXC::Errors::ExecuteError
|
|
raise Errors::LxcNotInstalled
|
|
end
|
|
end
|
|
|
|
# If the machine ID changed, then we need to rebuild our underlying
|
|
# container.
|
|
def machine_id_changed
|
|
id = @machine.id
|
|
|
|
begin
|
|
@logger.debug("Instantiating the container for: #{id.inspect}")
|
|
@driver = Driver.new(id, self.sudo_wrapper)
|
|
@driver.validate!
|
|
rescue Driver::ContainerNotFound
|
|
# The container doesn't exist, so we probably have a stale
|
|
# ID. Just clear the id out of the machine and reload it.
|
|
@logger.debug("Container not found! Clearing saved machine ID and reloading.")
|
|
id = nil
|
|
retry
|
|
end
|
|
end
|
|
|
|
# @see Vagrant::Plugin::V2::Provider#action
|
|
def action(name)
|
|
# Attempt to get the action method from the Action class if it
|
|
# exists, otherwise return nil to show that we don't support the
|
|
# given action.
|
|
action_method = "action_#{name}"
|
|
return LXC::Action.send(action_method) if LXC::Action.respond_to?(action_method)
|
|
nil
|
|
end
|
|
|
|
# Returns the SSH info for accessing the Container.
|
|
def ssh_info
|
|
# If the Container is not running then we cannot possibly SSH into it, so
|
|
# we return nil.
|
|
return nil if state.id != :running
|
|
|
|
# Run a custom action called "fetch_ip" which does what it says and puts
|
|
# the IP found into the `:machine_ip` key in the environment.
|
|
env = @machine.action("fetch_ip")
|
|
|
|
# If we were not able to identify the container's IP, we return nil
|
|
# here and we let Vagrant core deal with it ;)
|
|
return nil unless env[:machine_ip]
|
|
|
|
{
|
|
:host => env[:machine_ip],
|
|
:port => @machine.config.ssh.guest_port
|
|
}
|
|
end
|
|
|
|
def state
|
|
state_id = nil
|
|
state_id = :not_created if !@driver.container_name
|
|
state_id = @driver.state if !state_id
|
|
state_id = :unknown if !state_id
|
|
|
|
short = state_id.to_s.gsub("_", " ")
|
|
long = I18n.t("vagrant.commands.status.#{state_id}")
|
|
|
|
Vagrant::MachineState.new(state_id, short, long)
|
|
end
|
|
|
|
def to_s
|
|
id = @machine.id ? @machine.id : "new VM"
|
|
"LXC (#{id})"
|
|
end
|
|
end
|
|
end
|
|
end
|