app/services/katello/event_daemon.rb in katello-3.15.3.1 vs app/services/katello/event_daemon.rb in katello-3.16.0.rc1

- old
+ new

@@ -16,28 +16,27 @@ end end def check_services(error, status) @service_classes.each do |service_class| - begin - status = service_class.status - rescue => error - Rails.logger.error("Error occurred while pinging #{service_class}") - Rails.logger.error(error.message) - Rails.logger.error(error.backtrace.join("\n")) - ensure - if error || !status&.dig(:running) - begin - service_class.close - service_class.run - rescue => error - Rails.logger.error("Error occurred while starting #{service_class}") - Rails.logger.error(error.message) - Rails.logger.error(error.backtrace.join("\n")) - ensure - error = nil - end + status = service_class.status + rescue => error + Rails.logger.error("Error occurred while pinging #{service_class}") + Rails.logger.error(error.message) + Rails.logger.error(error.backtrace.join("\n")) + ensure + if error || !status&.dig(:running) + begin + service_class.close + service_class.run + service_class.status + rescue => error + Rails.logger.error("Error occurred while starting #{service_class}") + Rails.logger.error(error.message) + Rails.logger.error(error.backtrace.join("\n")) + ensure + error = nil end end end end end @@ -78,9 +77,10 @@ end def stop return unless pid == Process.pid @monitor_thread.kill + @cache.clear services.values.each(&:close) File.unlink(pid_file) if pid_file && File.exist?(pid_file) end def start