Method: Fairy::Controller#assign_same_obj_processor

Defined in:

lib/fairy/controller.rb

#assign_same_obj_processor(bjob, obj, &block) ⇒ Object

# File 'lib/fairy/controller.rb', line 550

def assign_same_obj_processor(bjob, obj, &block)
  processor = nil
  @reserves_mutex.synchronize do
	@reserves.each_key do |p| 
	  if p.deep_space == obj.deep_space
 processor = p
 break
	  end
	end
  end
  ERR::Raise ERR::NoExistProcesorWithObject obj.to_s unless processor

  ret = reserve_processor(processor) {
	register_processor(bjob, processor)
	yield processor
  }
  
  ERR::Raise ERR::NoExistProcesorWithObject obj.to_s unless ret
end