ref: refs/heads/master commit dd5d07e95ae49446cbc0f1e117665daf1d002c0f Author: Duncan Mac-Vicar P Date: Mon Jul 20 10:19:56 2009 +0200 status.rb does not need to be an activeresource model --- plugins/status/app/models/status.rb | 182 ----------------------------------- plugins/status/lib/status.rb | 182 +++++++++++++++++++++++++++++++++++ 2 files changed, 182 insertions(+), 182 deletions(-) diff --git a/plugins/status/app/models/status.rb b/plugins/status/app/models/status.rb deleted file mode 100644 index a31ef24..0000000 --- a/plugins/status/app/models/status.rb +++ /dev/null @@ -1,182 +0,0 @@ -class Status < ActiveRecord::Base - require 'scr' - require 'yaml' - - attr_accessor :data, - :datapath, - :health_status, - :metrics - - def initialize() - @scr = Scr.instance - @health_status = nil - @data = Hash.new - start_collectd - - @datapath = set_datapath - @metrics = available_metrics - - #find the correct plugin path for the config file - plugin_config_dir = "#{RAILS_ROOT}/config" #default - Rails.configuration.plugin_paths.each do |plugin_path| - if File.directory?(File.join(plugin_path, "status")) - plugin_config_dir = plugin_path+"/status/config" - Dir.mkdir(plugin_config_dir) unless File.directory?(plugin_config_dir) - break - end - end - @limits = {} - @limits = YAML.load(File.open(File.join(plugin_config_dir, "status_limits.yaml"))) if File.exists?(File.join(plugin_config_dir, "status_limits.yaml")) - end - - def start_collectd - cmd = @scr.execute(["collectd"]) - @timestamp = Time.now - end - - def stop_collectd - cmd = @scr.execute(["killall", "collectd"]) - @timestamp = nil - end - - # set path of stored rrd files, default: /var/lib/collectd/$host.$domain - def set_datapath(path=nil) - if path.blank? #FIXME: read currently used rrdb file from /etc/collectd.conf - cmd = IO.popen("ls /var/lib/collectd/") - path = cmd.read - cmd.close - path = path.split " " #FIXME - @datapath = "/var/lib/collectd/#{path[0].strip}" - else # set default path - @datapath = path.chomp("/") - end - return @datapath - end - - def available_metrics - @metrics = Hash.new - cmd = IO.popen("ls #{@datapath}") - output = cmd.read - cmd.close - output.split(" ").each do |l| - fp = IO.popen("ls #{@datapath}/#{l}") - files = fp.read - fp.close - rrds = Array.new - files.split(" ").each do |d| - rrds << d if d.include? ".rrd" #only .rrd files - @metrics["#{l}"] = { :rrds => rrds} - end - end - return @metrics - end - - def available_metric_files - cmd = IO.popen("ls #{@datapath}..") - lines = cmd.read.split "\n" - cmd.close - return lines - end - - def determine_status - end - - def draw_graph(heigth=nil, width=nil) - end - - # creates several metrics for a defined period - def collect_data(start=nil, stop=nil, data = %w{cpu memory disk}) - available_metrics - result = Hash.new - unless @timestamp.nil? # collectd not started - case data - when nil, "all", "All" # all metrics - @metrics.each_pair do |m, n| - @metrics["#{m}"][:rrds].each do |rrdb| - result["#{rrdb}".chomp(".rrd")] = fetch_metric("#{m}/#{rrdb}", start, stop) - end - @data["#{m}"] = result - result = Hash.new - end - else # only metrics in data - data.each do |d| - @metrics.each_pair do |m, n| - if m.include?(d) - @metrics["#{m}"][:rrds].each do |rrdb| - result["#{rrdb}".chomp(".rrd")] = fetch_metric("#{m}/#{rrdb}", start, stop) - end - @data["#{m}"] = result - result = Hash.new - end - end - end - end - end - return @data - end - - # creates one metric for defined period - def fetch_metric(rrdfile, start=nil, stop=nil) - result = Hash.new - if start.blank? - start = "--start #{Time.now.strftime("%H:%M,%m/%d/%Y")}" - else - start = "--start #{start}" - end - if stop.blank? - stop = "--end #{Time.now.strftime("%H:%M,%m/%d/%Y")}" - else - stop = "--end #{stop}" - end - cmd = IO.popen("rrdtool fetch #{@datapath}/#{rrdfile} AVERAGE #{start} #{stop}") - output = cmd.read - cmd.close - return "failed" if output.blank? - - labels="" - output = output.gsub(",", ".") # translates eg. 1,234e+07 to 1.234e+07 - lines = output.split "\n" - - # set label names - lines[0].each do |l| - if l =~ /\D*/ - labels = l.split " " - end - end - unless labels.blank? - # set values for each label and time - lines.each do |l| # each time - unless l.blank? - if l =~ /\d*:\D*/ - pair = l.split ":" - values = pair[1].split " " - column = 0 - values.each do |v| # each label - if v != "nan" #store valid values only - result["#{labels[column]}"] ||= Hash.new - result["#{labels[column]}"].merge!({"T_#{pair[0].chomp(": ")}" => v}) - column += 1 - end - end - end - end - end - - #setting the limits - result.each do |key, value| - - path = rrdfile.chomp(".rrd") - path +="/" + key if key!="value" #do not take care about the value flag - path = path.tr('-','_') - if @limits.has_key?(path) - result[key] ||= Hash.new - result[key].merge!({"limit" => @limits[path] }) - end - end - - return result - else - return "failed" - end - end -end diff --git a/plugins/status/lib/status.rb b/plugins/status/lib/status.rb new file mode 100644 index 0000000..42cb73d --- /dev/null +++ b/plugins/status/lib/status.rb @@ -0,0 +1,182 @@ +class Status + require 'scr' + require 'yaml' + + attr_accessor :data, + :datapath, + :health_status, + :metrics + + def initialize() + @scr = Scr.instance + @health_status = nil + @data = Hash.new + start_collectd + + @datapath = set_datapath + @metrics = available_metrics + + #find the correct plugin path for the config file + plugin_config_dir = "#{RAILS_ROOT}/config" #default + Rails.configuration.plugin_paths.each do |plugin_path| + if File.directory?(File.join(plugin_path, "status")) + plugin_config_dir = plugin_path+"/status/config" + Dir.mkdir(plugin_config_dir) unless File.directory?(plugin_config_dir) + break + end + end + @limits = {} + @limits = YAML.load(File.open(File.join(plugin_config_dir, "status_limits.yaml"))) if File.exists?(File.join(plugin_config_dir, "status_limits.yaml")) + end + + def start_collectd + cmd = @scr.execute(["collectd"]) + @timestamp = Time.now + end + + def stop_collectd + cmd = @scr.execute(["killall", "collectd"]) + @timestamp = nil + end + + # set path of stored rrd files, default: /var/lib/collectd/$host.$domain + def set_datapath(path=nil) + if path.blank? #FIXME: read currently used rrdb file from /etc/collectd.conf + cmd = IO.popen("ls /var/lib/collectd/") + path = cmd.read + cmd.close + path = path.split " " #FIXME + @datapath = "/var/lib/collectd/#{path[0].strip}" + else # set default path + @datapath = path.chomp("/") + end + return @datapath + end + + def available_metrics + @metrics = Hash.new + cmd = IO.popen("ls #{@datapath}") + output = cmd.read + cmd.close + output.split(" ").each do |l| + fp = IO.popen("ls #{@datapath}/#{l}") + files = fp.read + fp.close + rrds = Array.new + files.split(" ").each do |d| + rrds << d if d.include? ".rrd" #only .rrd files + @metrics["#{l}"] = { :rrds => rrds} + end + end + return @metrics + end + + def available_metric_files + cmd = IO.popen("ls #{@datapath}..") + lines = cmd.read.split "\n" + cmd.close + return lines + end + + def determine_status + end + + def draw_graph(heigth=nil, width=nil) + end + + # creates several metrics for a defined period + def collect_data(start=nil, stop=nil, data = %w{cpu memory disk}) + available_metrics + result = Hash.new + unless @timestamp.nil? # collectd not started + case data + when nil, "all", "All" # all metrics + @metrics.each_pair do |m, n| + @metrics["#{m}"][:rrds].each do |rrdb| + result["#{rrdb}".chomp(".rrd")] = fetch_metric("#{m}/#{rrdb}", start, stop) + end + @data["#{m}"] = result + result = Hash.new + end + else # only metrics in data + data.each do |d| + @metrics.each_pair do |m, n| + if m.include?(d) + @metrics["#{m}"][:rrds].each do |rrdb| + result["#{rrdb}".chomp(".rrd")] = fetch_metric("#{m}/#{rrdb}", start, stop) + end + @data["#{m}"] = result + result = Hash.new + end + end + end + end + end + return @data + end + + # creates one metric for defined period + def fetch_metric(rrdfile, start=nil, stop=nil) + result = Hash.new + if start.blank? + start = "--start #{Time.now.strftime("%H:%M,%m/%d/%Y")}" + else + start = "--start #{start}" + end + if stop.blank? + stop = "--end #{Time.now.strftime("%H:%M,%m/%d/%Y")}" + else + stop = "--end #{stop}" + end + cmd = IO.popen("rrdtool fetch #{@datapath}/#{rrdfile} AVERAGE #{start} #{stop}") + output = cmd.read + cmd.close + return "failed" if output.blank? + + labels="" + output = output.gsub(",", ".") # translates eg. 1,234e+07 to 1.234e+07 + lines = output.split "\n" + + # set label names + lines[0].each do |l| + if l =~ /\D*/ + labels = l.split " " + end + end + unless labels.blank? + # set values for each label and time + lines.each do |l| # each time + unless l.blank? + if l =~ /\d*:\D*/ + pair = l.split ":" + values = pair[1].split " " + column = 0 + values.each do |v| # each label + if v != "nan" #store valid values only + result["#{labels[column]}"] ||= Hash.new + result["#{labels[column]}"].merge!({"T_#{pair[0].chomp(": ")}" => v}) + column += 1 + end + end + end + end + end + + #setting the limits + result.each do |key, value| + + path = rrdfile.chomp(".rrd") + path +="/" + key if key!="value" #do not take care about the value flag + path = path.tr('-','_') + if @limits.has_key?(path) + result[key] ||= Hash.new + result[key].merge!({"limit" => @limits[path] }) + end + end + + return result + else + return "failed" + end + end +end -- To unsubscribe, e-mail: yast-commit+unsubscribe@opensuse.org For additional commands, e-mail: yast-commit+help@opensuse.org