Method: BaseChip::Tasker#get_task

Defined in:

lib/base_chip/tasker.rb

#get_task(client_id) ⇒ Object

# File 'lib/base_chip/tasker.rb', line 183

def get_task(client_id)
  @mutex.lock
  ready = maintain_workers

  w = @workers[client_id]
  raise "Could not find worker based on unique id #{client_id}" unless w

  t = nil
  ready.each do |rt|
    if rt.worker_command.nil? || rt.worker_command.call(0) == w[:worker_command]
      t = rt
      break
    end
  end

  if t
    @pending_tasks.delete t
    @running_tasks <<     t
    @tasks_pending -= 1
    @tasks_running += 1

    w[:tasks] << t
    w[:state] = :running
  else
    w[:state] = :stopped
    w[:cluster].slots_used -= 1 if w[:cluster]
  end

  finish if @pending_tasks.empty? && @running_tasks.empty? && ready.empty?

  if @pending_tasks.size > 0 && @running_tasks.empty? && ready.empty?
    raise("Could not build tasks because their dependencies never cleared: " + (@pending_tasks.map{|t|t.task_name}.join(" ")))
  end

  status_line
  @mutex.unlock
  t
end