class ForemanTasksCore::Runner::Dispatcher
Public Class Methods
instance()
click to toggle source
# File lib/foreman_tasks_core/runner/dispatcher.rb, line 4 def self.instance return @instance if @instance @instance = new(ForemanTasksCore.dynflow_world.clock, ForemanTasksCore.dynflow_world.logger) end
new(clock, logger)
click to toggle source
# File lib/foreman_tasks_core/runner/dispatcher.rb, line 81 def initialize(clock, logger) @mutex = Mutex.new @clock = clock @logger = logger @runner_actors = {} @runner_suspended_actions = {} end
Public Instance Methods
finish(runner_id)
click to toggle source
# File lib/foreman_tasks_core/runner/dispatcher.rb, line 121 def finish(runner_id) synchronize do begin _finish(runner_id) rescue => exception _handle_command_exception(runner_id, exception, false) end end end
handle_command_exception(*args)
click to toggle source
# File lib/foreman_tasks_core/runner/dispatcher.rb, line 131 def handle_command_exception(*args) synchronize { _handle_command_exception(*args) } end
kill(runner_id)
click to toggle source
# File lib/foreman_tasks_core/runner/dispatcher.rb, line 110 def kill(runner_id) synchronize do begin runner_actor = @runner_actors[runner_id] runner_actor.tell(:kill) if runner_actor rescue => exception _handle_command_exception(runner_id, exception, false) end end end
start(suspended_action, runner)
click to toggle source
# File lib/foreman_tasks_core/runner/dispatcher.rb, line 93 def start(suspended_action, runner) synchronize do begin raise "Actor with runner id #{runner.id} already exists" if @runner_actors[runner.id] runner.logger = @logger runner_actor = RunnerActor.spawn("runner-actor-#{runner.id}", self, suspended_action, runner, @clock, @logger) @runner_actors[runner.id] = runner_actor @runner_suspended_actions[runner.id] = suspended_action runner_actor.tell(:start_runner) return runner.id rescue => exception _handle_command_exception(runner.id, exception) return nil end end end
synchronize(&block)
click to toggle source
# File lib/foreman_tasks_core/runner/dispatcher.rb, line 89 def synchronize(&block) @mutex.synchronize(&block) end
Private Instance Methods
_finish(runner_id)
click to toggle source
# File lib/foreman_tasks_core/runner/dispatcher.rb, line 137 def _finish(runner_id) runner_actor = @runner_actors.delete(runner_id) return unless runner_actor @logger.debug("closing session for command [#{runner_id}]," "#{@runner_actors.size} actors left ") runner_actor.tell([:start_termination, Concurrent.future]) ensure @runner_suspended_actions.delete(runner_id) end
_handle_command_exception(runner_id, exception, fatal = true)
click to toggle source
# File lib/foreman_tasks_core/runner/dispatcher.rb, line 147 def _handle_command_exception(runner_id, exception, fatal = true) @logger.error("error while dispatching request to runner #{runner_id}:" "#{exception.class} #{exception.message}:\n #{exception.backtrace.join("\n")}") suspended_action = @runner_suspended_actions[runner_id] if suspended_action suspended_action << Runner::Update.encode_exception('Runner error', exception, fatal) end _finish(runner_id) if fatal end