B #5045: Fix flow server token expiration error (#168)

OpenNebula · Aug 27, 2020 · 3d42b44 · 3d42b44
1 parent 3c3b237
commit 3d42b44
Show file tree

Hide file tree

Showing 5 changed files with 10 additions and 21 deletions.
diff --git a/src/cloud/common/CloudAuth.rb b/src/cloud/common/CloudAuth.rb
@@ -143,7 +143,7 @@ def get_password(username, driver=nil)
         retrieve_from_userpool(xpath)
     end
 
-    # Selects the username that matches the driver and evaluates to true the 
+    # Selects the username that matches the driver and evaluates to true the
     # block passed to the function
     # block:: { |user| true or false }
     # [return] the username or nil

diff --git a/src/flow/lib/EventManager.rb b/src/flow/lib/EventManager.rb
@@ -395,10 +395,9 @@ def check_nodes(nodes, state, lcm_state, subscriber)
 
     def check_nodes_report(nodes)
         rc_nodes = { :successful => [], :failure => [] }
-        client   = @cloud_auth.client
 
         nodes.delete_if do |node|
-            vm = OpenNebula::VirtualMachine.new_with_id(node, client)
+            vm = OpenNebula::VirtualMachine.new_with_id(node, @cloud_auth.client)
 
             vm.info
 

diff --git a/src/flow/lib/LifeCycleManager.rb b/src/flow/lib/LifeCycleManager.rb
@@ -58,7 +58,7 @@ def initialize(client, concurrency, cloud_auth)
 
         @event_manager = EventManager.new(em_conf).am
 
-        @wd = ServiceWD.new(client, em_conf)
+        @wd = ServiceWD.new(em_conf)
 
         # Register Action Manager actions
         @am.register_action(ACTIONS['DEPLOY_CB'],
@@ -94,7 +94,6 @@ def initialize(client, concurrency, cloud_auth)
 
         Thread.new do
             auto_scaler = ServiceAutoScaler.new(@srv_pool,
-                                                client,
                                                 @cloud_auth,
                                                 self)
             auto_scaler.start

diff --git a/src/flow/lib/ServiceAutoScaler.rb b/src/flow/lib/ServiceAutoScaler.rb
@@ -23,23 +23,21 @@ class ServiceAutoScaler
     # Class constructor
     #
     # @param service_pool [OpenNebula::ServicePool] Service pool
-    # @param clien        [OpenNebula::Client]      OpenNebula Client
     # @param cloud_auth   [OpenNebula::CloudAuth]   Cloud auth to get clients
     # @param lcm          [LifeCycleManager]        Lcm for flows
-    def initialize(service_pool, client, cloud_auth, lcm)
+    def initialize(service_pool, cloud_auth, lcm)
         @lcm        = lcm
         @interval   = cloud_auth.conf[:autoscaler_interval]
         @srv_pool   = service_pool
-        @vm_pool    = VirtualMachinePool.new(cloud_auth.client)
         @cloud_auth = cloud_auth
-        @client     = client
     end
 
     # Start auto scaler loop
     def start
         loop do
             @srv_pool.info
-            @vm_pool.info_all_extended
+            vm_pool = VirtualMachinePool.new(client)
+            vm_pool.info_all_extended
 
             @srv_pool.each do |service|
                 # fill service roles information
@@ -51,7 +49,7 @@ def start
                          'Checking policies for ' \
                          "service: #{service.id}"
 
-                apply_scaling_policies(service)
+                apply_scaling_policies(service, vm_pool)
             end
 
             sleep(@interval)
@@ -62,9 +60,6 @@ def start
 
     # Get OpenNebula client
     def client
-        # If there's a client defined use it
-        return @client unless @client.nil?
-
         # If not, get one via cloud_auth
         @cloud_auth.client
     end
@@ -73,9 +68,9 @@ def client
     # to SCALING. Only one role is set to scale.
     #
     # @param  [OpenNebula::Service] service
-    def apply_scaling_policies(service)
+    def apply_scaling_policies(service, vm_pool)
         service.roles.each do |name, role|
-            diff, cooldown_duration = role.scale?(@vm_pool)
+            diff, cooldown_duration = role.scale?(vm_pool)
 
             policies = {}
             policies['elasticity_policies'] = role.elasticity_policies

diff --git a/src/flow/lib/ServiceWatchDog.rb b/src/flow/lib/ServiceWatchDog.rb
@@ -45,14 +45,13 @@ class ServiceWD
     # Class constructor
     #
     # @param options [Hash] event manager options
-    def initialize(client, options)
+    def initialize(options)
         @conf = DEFAULT_CONF.merge(options)
 
         @lcm          = options[:lcm]
         @context      = ZMQ::Context.new(1)
         @cloud_auth   = @conf[:cloud_auth]
         @wait_timeout = @cloud_auth.conf[:wait_timeout]
-        @client       = client
 
         # Array of running services to watch
         @mutex    = Mutex.new
@@ -154,9 +153,6 @@ def remove_service(service_id)
 
     # Get OpenNebula client
     def client
-        # If there's a client defined use it
-        return @client unless @client.nil?
-
         # If not, get one via cloud_auth
         @cloud_auth.client
     end