18
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
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
|
# File 'lib/vagrant-joyent/action/run_instance.rb', line 18
def call(env)
env[:metrics] ||= {}
dataset = env[:machine].provider_config.dataset
flavor = env[:machine].provider_config.flavor
node_name = env[:machine].provider_config.node_name || env[:machine].name
keyname = env[:machine].provider_config.joyent_keyname
env[:ui].info(I18n.t("vagrant_joyent.launching_instance"))
env[:ui].info(" -- Flavor: #{flavor}")
env[:ui].info(" -- Dataset: #{dataset}")
env[:ui].info(" -- Node name: #{node_name}")
env[:ui].info(" -- Key name: #{keyname}")
begin
options = {
:name => node_name,
:dataset => dataset,
:package => flavor
}
server = env[:joyent_compute].servers.create(options)
rescue Fog::Compute::Joyent::NotFound => e
raise Errors::FogError, :message => e.message
rescue Fog::Compute::Joyent::Error => e
raise Errors::FogError, :message => e.message
end
env[:machine].id = server.id
env[:metrics]["instance_ready_time"] = Util::Timer.time do
env[:ui].info(I18n.t("vagrant_joyent.waiting_for_ready"))
retryable(:on => Fog::Errors::TimeoutError, :tries => 30) do
next if env[:interrupted]
server.wait_for(2) { ready? }
end
end
@logger.info("Time to instance ready: #{env[:metrics]["instance_ready_time"]}")
if !env[:interrupted]
env[:metrics]["instance_ssh_time"] = Util::Timer.time do
env[:ui].info(I18n.t("vagrant_joyent.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_joyent.ready"))
end
terminate(env) if env[:interrupted]
@app.call(env)
end
|