Sha256: b8235088a41757aada7b1650802ce8e11601d4debd76e61b8c2b3ebbc9813039
Contents?: true
Size: 1.26 KB
Versions: 23
Compression:
Stored size: 1.26 KB
Contents
#!/usr/bin/env ruby
$:.unshift(File.join(File.dirname(__FILE__), "..", "lib"))
require "poolparty"
require "poolpartycl"
available_monitors = PoolParty::Monitors.available_monitors
o = PoolParty::Optioner.new(ARGV) do |opts, optioner|
opts.on('-n name', '--name name', 'Host name') { |h| optioner.hostname h }
opts.on('-l', '--no-shell', 'No shell') {optioner.noshell true}
end
o.loaded_clouds.each do |cloud|
with_cloud(cloud) do
@nonprovisioned_nodes = list_of_running_instances.map {|a| a.name } - cloud.get_current_nodes
# @tp = ThreadPool.new(10)
@nonprovisioned_nodes.each do |node|
vputs "Provisioning #{node}"
next if node == "master"
# @tp.process do
str = returning Array.new do |s|
s << "/usr/sbin/puppetca --clean #{node}.compute-1.internal"
s << "/usr/sbin/puppetca --clean #{node}.ec2.internal"
end.join(";")
node_id = node.gsub(/node/, '')
cmd = ". /etc/profile && #{str};cloud-provision -n #{cloud.name} -i #{node_id};#{str}"
running_cmd = "ps aux | grep -v grep | grep \"cloud-provision -n #{cloud.name} -i #{node_id};\""
vputs "Executing #{cmd}"
running = %x[#{running_cmd}]
`#{cmd}` if running.chomp.empty?
end
# @tp.join
end
end
Version data entries
23 entries across 23 versions & 2 rubygems