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