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 



934
935
936
937
938
939
940
941
942
943
944
945
946
 
# File 'lib/fairy/controller.rb', line 934

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 



948
949
950
 
# File 'lib/fairy/controller.rb', line 948

def bind_input(njob)
	njob.input = input_filter
end

#initialze(mapper) ⇒ Object 



929
930
931
932
 
# File 'lib/fairy/controller.rb', line 929

def initialze(mapper)
	super
	@import = nil
end