Method: Fairy::Controller#register_processor

Defined in:
lib/fairy/controller.rb

#register_processor(bjob, processor) ⇒ Object 



380
381
382
383
384
385
386
387
388
389
390
 
# File 'lib/fairy/controller.rb', line 380

def register_processor(bjob, processor)
  @bjob2processors_mutex.synchronize do
	@bjob2processors[bjob] = [] unless @bjob2processors[bjob]
	unless @bjob2processors[bjob].include?(processor)
	  @bjob2processors[bjob].push processor
	end
	@bjob2processors_cv.broadcast
	@no_active_ntasks_cv.broadcast
  end
  processor
end