class DRbQS::Execution::ExecuteNode
Public Class Methods
new(uri, log_prefix, log_level, node_opts = {})
click to toggle source
# File lib/drbqs/execute/execute_node.rb, line 4 def initialize(uri, log_prefix, log_level, node_opts = {}) @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 @node_opts = node_opts end
Public Instance Methods
execute(process_num, interval = 0)
click to toggle source
# File lib/drbqs/execute/execute_node.rb, line 25 def execute(process_num, interval = 0) opts = @node_opts.merge({ :log_level => @log_level, :log_file => get_log_file, :process => process_num }) node = DRbQS::Node.new(@uri, opts) node.connect node.calculate end
Private Instance Methods
get_log_file()
click to toggle source
# File lib/drbqs/execute/execute_node.rb, line 17 def get_log_file if @fname return @fname.create end return STDOUT end