shaba/one
1
0
Fork 0
mirror of https://github.com/OpenNebula/one.git synced 2025-03-16 22:50:10 +03:00
Code Releases Wiki Activity

M #-: flow watch dog don't update same state

Browse Source
This commit is contained in:
Alejandro Huertas 2020-05-19 18:09:11 +02:00
parent b0ffa98b49
commit 1891c4d723
No known key found for this signature in database
GPG Key ID: 3044AF06BE405104
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/flow/lib/LifeCycleManager.rb
View File

@ -668,8 +668,13 @@ class ServiceLCM
def error_wd_cb(client, service_id, role_name, _node)
rc = @srv_pool.get(service_id, client) do |service|
service.set_state(Service::STATE['WARNING'])
service.roles[role_name].set_state(Role::STATE['WARNING'])
if service.state != Service::STATE['WARNING']
service.set_state(Service::STATE['WARNING'])
end
if service.roles[role_name].state != Role::STATE['WARNING']
service.roles[role_name].set_state(Role::STATE['WARNING'])
end
service.update
end
@ -699,10 +704,14 @@ class ServiceLCM
def running_wd_cb(client, service_id, role_name, _node)
rc = @srv_pool.get(service_id, client) do |service|
service.roles[role_name].set_state(Role::STATE['RUNNING'])
if service.roles[role_name].state != Role::STATE['RUNNING']
service.roles[role_name].set_state(Role::STATE['RUNNING'])
end
if service.all_roles_running?
service.set_state(Service::STATE['RUNNING'])
if service.state != Service::STATE['RUNNING']
service.set_state(Service::STATE['RUNNING'])
end
end
service.update