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

M #-: close all ZMQ subscribers

Browse Source
This commit is contained in:
Alejandro Huertas 2020-05-20 15:30:23 +02:00
parent d7a2f69841
commit 063c3fbef3
No known key found for this signature in database
GPG Key ID: 3044AF06BE405104
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/flow/lib/EventManager.rb
View File

@ -254,6 +254,10 @@ class EventManager
next if !nodes.empty? && rc_nodes[:failure].empty?
nodes.each do |id|
unsubscribe(id, state, lcm_state, subscriber)
end
# If any node is in error wait action will fails
return [false, rc_nodes] unless rc_nodes[:failure].empty?
@ -268,6 +272,8 @@ class EventManager
rc_nodes[:successful] << id
end
subscriber.close
[true, rc_nodes]
end
@ -337,6 +343,8 @@ class EventManager
subscriber.setsockopt(ZMQ::UNSUBSCRIBE, 'EVENT API one.vm.update 1')
subscriber.close
[true, rc_nodes]
end