Method: Creeper::Manager#processor_died

Defined in:
lib/creeper/manager.rb

#processor_died(processor, reason) ⇒ Object 



85
86
87
88
89
90
91
92
93
94
95
96
97
 
# File 'lib/creeper/manager.rb', line 85

def processor_died(processor, reason)
  watchdog("Manager#processor_died died") do
    @in_progress.delete(processor.object_id)
    @busy.delete(processor)

    unless stopped?
      @ready << Processor.new_link(current_actor)
      dispatch
    else
      signal(:shutdown) if @busy.empty?
    end
  end
end