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
|
# File 'lib/vagrant-google/action/run_instance.rb', line 30
def call(env)
env[:metrics] ||= {}
zone = env[:machine].provider_config.zone
zone_config = env[:machine].provider_config.get_zone_config(zone)
image = zone_config.image
name = zone_config.name
machine_type = zone_config.machine_type
network = zone_config.network
metadata = zone_config.metadata
env[:ui].info(I18n.t("vagrant_google.launching_instance"))
env[:ui].info(" -- Name: #{name}")
env[:ui].info(" -- Type: #{machine_type}")
env[:ui].info(" -- Image: #{image}")
env[:ui].info(" -- Zone: #{zone}") if zone
env[:ui].info(" -- Network: #{network}") if network
env[:ui].info(" -- Metadata: '#{metadata}'")
begin
request_start_time = Time.now().to_i
disk = env[:google_compute].disks.create(
name: name,
size_gb: 10,
zone_name: zone,
source_image: image
)
disk.wait_for { disk.ready? }
defaults = {
:name => name,
:zone_name => zone,
:machine_type => machine_type,
:image => image,
:network => network,
:metadata => metadata,
:disks => [disk.get_as_boot_disk(true, true)],
}
server = env[:google_compute].servers.create(defaults)
@logger.info("Machine '#{zone}:#{name}' created.")
rescue Fog::Compute::Google::NotFound => e
raise
rescue Fog::Compute::Google::Error => e
raise Errors::FogError, :message => e.message
end
env[:machine].id = server.name
server.reload
env[:ui].info(I18n.t("vagrant_google.waiting_for_ready"))
begin
server.wait_for { ready? }
env[:metrics]["instance_ready_time"] = Time.now().to_i - request_start_time
@logger.info("Time for instance ready: #{env[:metrics]["instance_ready_time"]}")
env[:ui].info(I18n.t("vagrant_google.ready"))
rescue
env[:interrupted] = true
end
if !env[:terminated]
env[:metrics]["instance_ssh_time"] = Util::Timer.time do
env[:ui].info(I18n.t("vagrant_google.waiting_for_ssh"))
while true
break if env[:interrupted]
break if env[:machine].communicate.ready?
sleep 2
end
end
@logger.info("Time for SSH ready: #{env[:metrics]["instance_ssh_time"]}")
env[:ui].info(I18n.t("vagrant_google.ready_ssh"))
end
terminate(env) if env[:interrupted]
@app.call(env)
end
|