mirror of
https://github.com/puppetlabs/vmpooler.git
synced 2026-01-26 10:08:40 -05:00
Avoid racing, only hand over VMs after a successful smove
This commit is contained in:
parent
72b1cd485e
commit
2f1a83eeb6
1 changed files with 18 additions and 6 deletions
|
|
@ -62,9 +62,18 @@ post '/vm/:template' do
|
|||
result[params[:template]]['error'] = 'You must specify a destination \'folder\' and \'pool\''
|
||||
else
|
||||
if ( $redis.scard('vmware_host_pool__ready__'+params[:template]) > 0 )
|
||||
vm = $redis.srandmember('vmware_host_pool__ready__'+params[:template])
|
||||
$redis.srem('vmware_host_pool__ready__'+params[:template], vm)
|
||||
$redis.sadd('vmware_host_pool__running__'+params[:template], vm)
|
||||
vm = nil
|
||||
|
||||
try = $redis.srandmember('vmware_host_pool__ready__'+params[:template])
|
||||
|
||||
if (
|
||||
$redis.smove(
|
||||
'vmware_host_pool__ready__'+params[:template],
|
||||
'vmware_host_pool__running__'+params[:template],
|
||||
try
|
||||
)
|
||||
)
|
||||
vm = try
|
||||
|
||||
logger.log('s', "[<] '#{vm}' moved to 'running' queue")
|
||||
|
||||
|
|
@ -73,6 +82,9 @@ post '/vm/:template' do
|
|||
else
|
||||
result[params[:template]]['ok'] = false
|
||||
end
|
||||
else
|
||||
result[params[:template]]['ok'] = false
|
||||
end
|
||||
end
|
||||
|
||||
JSON.pretty_generate(result)
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue