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