Class: Fairy::Controller::MPSameNTask

Inherits:
NjobMappingPolicy show all
Defined in:
lib/fairy/controller.rb

Instance Method Summary collapse

Methods inherited from NjobMappingPolicy

#initialize

Constructor Details

This class inherits a constructor from Fairy::Controller::NjobMappingPolicy

Instance Method Details

#assign_ntask(&block) ⇒ Object 



955
956
957
958
959
960
961
962
963
964
965
966
967
 
# File 'lib/fairy/controller.rb', line 955

def assign_ntask(&block)
	# thread を立ち上げるべき
	# このままでは, 十分に並列性が取れない(for [REQ:#5)]
	controller.assign_same_processor(target_bjob, 
input_filter.processor) do |processor|
	  ntask = input_filter.ntask
	  if input_filter.processor != processor
	    Log::warn(self, "ASSIGN_NTASK: assign defferent processor!!")
	    ntask = processor.create_ntask
	  end
	  block.call(ntask, @mapper)
	end
end

#bind_input(njob) ⇒ Object 



969
970
971
 
# File 'lib/fairy/controller.rb', line 969

def bind_input(njob)
	njob.input = input_filter
end

#initialze(mapper) ⇒ Object 



950
951
952
953
 
# File 'lib/fairy/controller.rb', line 950

def initialze(mapper)
	super
	@import = nil
end