Class: Fairy::PThere

Inherits:
PFilter show all
Includes:
PSingleExportable
Defined in:
lib/fairy/node/p-there.rb

Constant Summary

Constants included from PSingleExportable

Fairy::PSingleExportable::END_OF_STREAM, Fairy::PSingleExportable::ST_EXPORT_FINISH, Fairy::PSingleExportable::ST_WAIT_EXPORT_FINISH

Constants inherited from PFilter

Fairy::PFilter::END_OF_STREAM, Fairy::PFilter::ST_ACTIVATE, Fairy::PFilter::ST_FINISH, Fairy::PFilter::ST_INIT

Instance Attribute Summary

Attributes included from PSingleExportable

#export

Attributes inherited from PFilter

#IGNORE_EXCEPTION, #id, #log_id, #ntask

Instance Method Summary collapse

Methods included from PSingleExportable

#start, #start_export, #terminate, #wait_export_finish

Methods inherited from PFilter

#abort_running, #basic_start, #break_running, #each, #global_break, #global_break_from_other, #handle_exception, #key, #key=, #next, #no, #no=, #notice_status, #processor, #start, #start_export, #start_watch_status, #status=, #terminate, #terminate_proc

Constructor Details

#initialize(id, ntask, bjob, opts) ⇒ PThere

Returns a new instance of PThere.



15
16
17
 
# File 'lib/fairy/node/p-there.rb', line 15

def initialize(id, ntask, bjob, opts)
  super
end

Instance Method Details

#basic_each(&block) ⇒ Object 



24
25
26
27
28
29
30
31
 
# File 'lib/fairy/node/p-there.rb', line 24

def basic_each(&block)
  @enumerable.each do |e| 
	if e.__deep_connect_reference? && !PORT_KEEP_IDENTITY_CLASS_SET[e.class]
	  e = e.deep_connect_deep_copy
	end
	block.call  e
  end
end

#open(nthere_place) ⇒ Object 



19
20
21
22
 
# File 'lib/fairy/node/p-there.rb', line 19

def open(nthere_place)
  self.no = nthere_place.no
  @enumerable = nthere_place.enumerable
end