Class: VagrantPlugins::OpenStack::Action::CreateServer
- Inherits:
-
Object
- Object
- VagrantPlugins::OpenStack::Action::CreateServer
- Includes:
- Vagrant::Util::Retryable
- Defined in:
- lib/vagrant-openstack/action/create_server.rb
Overview
This creates the OpenStack server.
Instance Method Summary collapse
- #call(env) ⇒ Object
-
#initialize(app, env) ⇒ CreateServer
constructor
A new instance of CreateServer.
- #server_to_be_available?(server) ⇒ Boolean
Constructor Details
#initialize(app, env) ⇒ CreateServer
Returns a new instance of CreateServer.
14 15 16 17 |
# File 'lib/vagrant-openstack/action/create_server.rb', line 14 def initialize(app, env) @app = app @logger = Log4r::Logger.new("vagrant_openstack::action::create_server") end |
Instance Method Details
#call(env) ⇒ Object
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 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 |
# File 'lib/vagrant-openstack/action/create_server.rb', line 24 def call(env) # Get the configs config = env[:machine].provider_config if !config.networks.nil? and config.networks.any? @logger.info("Connecting to OpenStack Network...") env[:openstack_network] = Fog::Network.new({ :provider => :openstack, :openstack_region => config.region, :openstack_username => config.username, :openstack_api_key => config.api_key, :openstack_auth_url => config.endpoint, :openstack_tenant => config.tenant }) end # Find the flavor env[:ui].info(I18n.t("vagrant_openstack.finding_flavor")) flavor = find_matching(env[:openstack_compute].flavors.all, config.flavor) raise Errors::NoMatchingFlavor if !flavor # Find the image env[:ui].info(I18n.t("vagrant_openstack.finding_image")) image = find_matching(env[:openstack_compute].images, config.image) raise Errors::NoMatchingImage if !image # Find the networks effective_networks = [] if !config.networks.nil? and config.networks.any? env[:ui].info(I18n.t("vagrant_openstack.finding_network")) available_networks = env[:openstack_network].list_networks[:body]["networks"] for network_name in config.networks match = find_matching(available_networks, network_name) unless match raise Errors::NoMatchingNetwork, :network_name => network_name end effective_networks << match end end # Figure out the name for the server server_name = config.server_name || env[:machine].name # Output the settings we're going to use to the user env[:ui].info(I18n.t("vagrant_openstack.launching_server")) env[:ui].info(" -- Flavor: #{flavor.name}") env[:ui].info(" -- Image: #{image.name}") if effective_networks.any? env[:ui].info(' -- Network(s): ') for net in effective_networks env[:ui].info(" - #{net['name']}") end end env[:ui].info(" -- Name: #{server_name}") openstack_nics = [] for net in effective_networks openstack_nics << {'net_id' => net['id']} end # Build the options for launching... = { :flavor_ref => flavor.id, :image_ref => image.id, :name => server_name, :key_name => config.keypair_name, :user_data_encoded => Base64.encode64(config.user_data), :metadata => config., :os_scheduler_hints => config.scheduler_hints } if openstack_nics.any? [:nics] = openstack_nics end # Create the server server = env[:openstack_compute].servers.create() # Store the ID right away so we can track it env[:machine].id = server.id # Wait for the server to finish building env[:ui].info("Instance UUID: #{env[:machine].id}") env[:ui].info(I18n.t("vagrant_openstack.waiting_for_build")) retryable(:on => Timeout::Error, :tries => 200) do # If we're interrupted don't worry about waiting next if env[:interrupted] # Wait for the server to be ready begin (1..120).each do |n| env[:ui].clear_line env[:ui].report_progress(n, 120, true) server = env[:openstack_compute].servers.get(env[:machine].id) break if self.server_to_be_available?(server) sleep 1 end server = env[:openstack_compute].servers.get(env[:machine].id) raise unless self.server_to_be_available?(server) rescue raise Errors::CreateBadState, :state => server.state end end env[:machine].data_dir.join("cached_metadata").open("w+") do |f| f.write(server.to_json) end unless env[:interrupted] # Clear the line one more time so the progress is removed env[:ui].clear_line ssh_is_responding?(env) env[:ui].info(I18n.t("vagrant_openstack.ready")) end @app.call(env) end |
#server_to_be_available?(server) ⇒ Boolean
19 20 21 22 |
# File 'lib/vagrant-openstack/action/create_server.rb', line 19 def server_to_be_available?(server) raise if server.state == 'ERROR' server.state == 'ACTIVE' end |