puppetlabs/vmpooler
2
0
Fork 0
mirror of https://github.com/puppetlabs/vmpooler.git synced 2026-01-26 18:08:42 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Replace srem/sadd with smove, check power state of 'ready' and 'running' VMs

Browse source
This commit is contained in:
Scott Schneider 2013-12-05 11:38:11 -08:00
parent 5de7a8b244
commit 674a3eaf6f
1 changed files with 26 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

38
vmware-host-pooler
View file

@ -50,14 +50,12 @@ def check_pending_vm vm, pool, timeout
# $logger.log('d', "[!] [#{pool}] '#{vm}' cannot connect") # $logger.log('d', "[!] [#{pool}] '#{vm}' cannot connect")
end end
$redis.srem('vmware_host_pool__pending__'+pool, vm) $redis.smove('vmware_host_pool__pending__'+pool, 'vmware_host_pool__ready__'+pool, vm)
$redis.sadd('vmware_host_pool__ready__'+pool, vm)
$logger.log('s', "[>] [#{pool}] '#{vm}' moved to 'ready' queue") $logger.log('s', "[>] [#{pool}] '#{vm}' moved to 'ready' queue")
else else
if ((((Time.now - host.runtime.bootTime)/60).to_s[/^\d+\.\d{1}/].to_f) > timeout) if ((((Time.now - host.runtime.bootTime)/60).to_s[/^\d+\.\d{1}/].to_f) > timeout)
$redis.srem('vmware_host_pool__pending__'+pool, vm) $redis.smove('vmware_host_pool__pending__'+pool, 'vmware_host_pool__completed__'+pool, vm)
$redis.sadd('vmware_host_pool__completed__'+pool, vm)
$logger.log('d', "[!] [#{pool}] '#{vm}' marked as 'failed' after #{timeout} minutes") $logger.log('d', "[!] [#{pool}] '#{vm}' marked as 'failed' after #{timeout} minutes")
end end
@ -70,11 +68,19 @@ def check_ready_vm vm, pool, ttl
Thread.new { Thread.new {
host = $vsphere_helper.find_vms(vm)[vm] host = $vsphere_helper.find_vms(vm)[vm]
if ((((Time.now - host.runtime.bootTime)/60).to_s[/^\d+\.\d{1}/].to_f) > ttl) if (
$redis.srem('vmware_host_pool__ready__'+pool, vm) (host.runtime)
$redis.sadd('vmware_host_pool__completed__'+pool, vm) (host.runtime.powerState != 'poweredOn')
)
$redis.smove('vmware_host_pool__ready__'+pool, 'vmware_host_pool__completed__'+pool, vm)
$logger.log('d', "[!] [#{pool}] '#{vm}' reached end of TTL after #{ttl} minutes") $logger.log('d', "[!] [#{pool}] '#{vm}' appears to be powered off or dead")
else
if ((((Time.now - host.runtime.bootTime)/60).to_s[/^\d+\.\d{1}/].to_f) > ttl)
$redis.smove('vmware_host_pool__ready__'+pool, 'vmware_host_pool__completed__'+pool, vm)
$logger.log('d', "[!] [#{pool}] '#{vm}' reached end of TTL after #{ttl} minutes")
end
end end
} }
end end
@ -83,11 +89,19 @@ def check_running_vm vm, pool, ttl
Thread.new { Thread.new {
host = $vsphere_helper.find_vms(vm)[vm] host = $vsphere_helper.find_vms(vm)[vm]
if ((((Time.now - host.runtime.bootTime)/60).to_s[/^\d+\.\d{1}/].to_f) > ttl) if (
$redis.srem('vmware_host_pool__running__'+pool, vm) (host.runtime) and
$redis.sadd('vmware_host_pool__completed__'+pool, vm) (host.runtime.powerState != 'poweredOn')
)
$redis.smove('vmware_host_pool__running__'+pool, 'vmware_host_pool__completed__'+pool, vm)
$logger.log('d', "[!] [#{pool}] '#{vm}' reached end of TTL after #{ttl} minutes") $logger.log('d', "[!] [#{pool}] '#{vm}' appears to be powered off or dead")
else
if ((((Time.now - host.runtime.bootTime)/60).to_s[/^\d+\.\d{1}/].to_f) > ttl)
$redis.smove('vmware_host_pool__running__'+pool, 'vmware_host_pool__completed__'+pool, vm)
$logger.log('d', "[!] [#{pool}] '#{vm}' reached end of TTL after #{ttl} minutes")
end
end end
} }
end end