Class: Fairy::COutputNull
- Defined in:
- lib/fairy/master/c-output-null.rb
Instance Attribute Summary
Attributes included from CInputtable
Instance Method Summary collapse
- #all_node_outputted? ⇒ Boolean
-
#initialize(controller, opts) ⇒ COutputNull
constructor
A new instance of COutputNull.
- #node_class_name ⇒ Object
-
#number_of_nodes=(no_nodes) ⇒ Object
def njob_creation_params end.
- #wait_all_output_finished ⇒ Object
Methods inherited from COutput
Methods included from CInputtable
Methods inherited from CFilter
#abort_create_node, #add_node, #assgin_number_of_nodes?, #bind_export, #break_create_node, #break_running, #create_and_add_node, #create_import, #create_node, #create_nodes, #def_job_pool_variable, #each_assigned_filter, #each_export_by, #each_node, #each_node_exist_only, #handle_exception, #input, #job_pool_dict, #job_pool_variable, #njob_creation_params, #nodes, #number_of_nodes, #pool_dict, #postmapping_policy, #start_create_nodes, #start_export, #start_watch_node_status, #update_status, watch_status, watch_status=, #watch_status?
Constructor Details
#initialize(controller, opts) ⇒ COutputNull
Returns a new instance of COutputNull.
12 13 14 |
# File 'lib/fairy/master/c-output-null.rb', line 12 def initialize(controller, opts) super end |
Instance Method Details
#all_node_outputted? ⇒ Boolean
35 36 37 38 39 40 41 42 43 |
# File 'lib/fairy/master/c-output-null.rb', line 35 def all_node_outputted? return false unless @nodes_mutex.synchronize{@number_of_nodes} each_node(:exist_only) do |node| st = @nodes_status[node] return false unless [:ST_FINISH, :ST_OUTPUT_FINISH].include?(st) end true end |
#node_class_name ⇒ Object
16 17 18 |
# File 'lib/fairy/master/c-output-null.rb', line 16 def node_class_name "POutputNull" end |
#number_of_nodes=(no_nodes) ⇒ Object
def njob_creation_params
end
23 24 25 |
# File 'lib/fairy/master/c-output-null.rb', line 23 def number_of_nodes=(no_nodes) super end |
#wait_all_output_finished ⇒ Object
27 28 29 30 31 32 33 |
# File 'lib/fairy/master/c-output-null.rb', line 27 def wait_all_output_finished @nodes_status_mutex.synchronize do while !all_node_outputted? @nodes_status_cv.wait(@nodes_status_mutex) end end end |