Class: DRbQS::ExecuteNode

Inherits:
Object
  • Object
show all
Defined in:
lib/drbqs/execute_node.rb

Instance Method Summary collapse

Constructor Details

#initialize(uri, log_prefix, log_level) ⇒ ExecuteNode

Returns a new instance of ExecuteNode.



4
5
6
7
8
9
10
11
12
13
14
15
 
# File 'lib/drbqs/execute_node.rb', line 4

def initialize(uri, log_prefix, log_level)
  @uri = uri
  @log_level = log_level
  if log_prefix
    @fname = FileName.new(log_prefix, :position => :suffix, :type => :time,
                          :add => :always, :directory => :parent,
                          :format => lambda { |t| t.strftime("%Y%m%d_%H%M_#{Process.pid}.log") })
  else
    @fname = nil
  end
  @pid = []
end

Instance Method Details

#execute(process_num, interval = 0) ⇒ Object 



34
35
36
37
38
39
 
# File 'lib/drbqs/execute_node.rb', line 34

def execute(process_num, interval = 0)
  process_num.times do |i|
    create_process
    sleep(interval) if interval > 0
  end
end

#wait ⇒ Object 



41
42
43
 
# File 'lib/drbqs/execute_node.rb', line 41

def wait
  Process.waitall 
end