xcat-core/xCAT-rmc/scripts/rmcmetrixmon

#!/usr/bin/env perl
use Getopt::Long;

BEGIN
{
    $::XCATROOT = $ENV{'XCATROOT'} ? $ENV{'XCATROOT'} : '/opt/xcat';
}

#Modules to use
use lib "$::XCATROOT/lib/perl";
use xCAT::Utils;
use xCAT_monitoring::rrdutil;
use xCAT_monitoring::rmcmetrix;

###############################################################
#Error handle
#Input:
#	$c	error code
#	$m	error msg
#return:
#	None;
##############################################################
sub err_handle
{
    my ($c, $m) = @_;
    if ($c != 0) {
        print "ERROR: $m\n";
        exit($c);
    }
}
###############################################################
#sub getcrontime
#Input:
#	$minute	interval in minute
#return:
#	string whose format is "MIN HOUR DAY MONTH *"
##############################################################
sub getcrontime
{
    my $minute = shift @_;
    my ($min, $hour, $day, $month);
    my $temp  = undef;
    my $temp1 = undef;
    $temp = $minute % 60;
    if ($temp < 2) {
        $min = '*';
    } else {
        $temp1 = $temp;
        $min   = '0';
        while ($temp1 < 60) {
            $min   = $min . ",$temp1";
            $temp1 = $temp1 + $temp;
        }
    }
    $minute = int $minute / 60;
    $temp   = $minute % 24;
    if ($temp < 2) {
        $hour = '*';
    } else {
        $temp1 = $temp;
        $hour  = '0';
        while ($temp1 < 24) {
            $hour  = $hour . ",$temp1";
            $temp1 = $temp1 + $temp;
        }
    }
    $minute = int $minute / 24;
    $temp   = $minute % 31;
    if ($temp < 2) {
        $day = '*';
    } else {
        $temp1 = $temp;
        $day   = '0';
        while ($day < 31) {
            $day   = $day . ",$temp1";
            $temp1 = $temp1 + $temp;
        }
    }
    $minute = int $minute / 31;
    $temp   = $minute % 12;
    if ($temp < 2) {
        $month = '*';
    } else {
        $month = '0';
        while ($month < 12) {
            $month = $month . ",$temp1";
            $temp1 = $temp1 + $temp;
        }
    }
    return "$min $hour $day $month *";

}
################################################################
#Usage:
#	1. To start RRD server
#	./rmcmetrixmon init rrdserver
#	2. To stop RRD server
#	./rmcmetrixmon clean rrdserver
#	3. To start a data collector
#	./rmcmetrixmon init resourceclass resoucename attr0, attr1, attr2, ... minute
#	4. To stop all data collectors and data consolidators
#	./rmcmetrixmon clean
#	5. To work as a data collector
#	./rmcmetrixmon data resourceclass resourcename attr0, attr1, attr2, ... minute
#	6. To work as a data consolidator
#	./rmcmetrixmon sum resourceclass attr0, attr1, attr2, ... minute
#################################################################

my $cmd      = $ARGV[0];
my @tabs     = ();
my $entry    = undef;
my $minute   = undef;
my $crontime = undef;
my $code     = 0;
my $msg      = undef;
if ($cmd eq 'init') {
    if ($ARGV[1] eq 'rrdserver') {
        $code = xCAT_monitoring::rrdutil::start_RRD_server('13900', "/var/rrd/");
        &err_handle($code, "can't start RRD server");
        exit 0;
    }
    $minute   = $ARGV[4];
    $crontime = &getcrontime($minute);
    ($code, $msg) = xCAT::Utils->add_cron_job("$crontime /opt/xcat/sbin/rmcmon/rmcmetrixmon data $ARGV[1] $ARGV[2] $ARGV[3] $ARGV[4] > /dev/null");
    &err_handle($code, $msg);
    if (xCAT::Utils->isMN()) {
        $minute   = $minute * 5;
        $crontime = &getcrontime($minute);
        ($code, $msg) = xCAT::Utils->add_cron_job("$crontime /opt/xcat/sbin/rmcmon/rmcmetrixmon sum $ARGV[1] $ARGV[3] $ARGV[4] > /dev/null");
        &err_handle($code, $msg);
    }
} elsif ($cmd eq 'clean') {
    if ($ARGV[1] eq 'rrdserver') {
        $code = xCAT_monitoring::rrdutil::stop_RRD_server();
        &err_handle($code, "can't stop RRD server");
        exit 0;
    }

    $msg = `rm -rf /var/rrd/*`;
    &err_handle($?, $msg);
    @tabs = `/usr/bin/crontab -l 2>/dev/null;`;
    foreach $entry (@tabs) {
        chomp($entry);
        if ($entry =~ /rmcmetrixmon/) {
            ($code, $msg) = xCAT::Utils->remove_cron_job($entry);
            &err_handle($code, $msg);
        }
    }
} elsif ($cmd eq 'data') {
    ($code, $msg) = &xCAT_monitoring::rmcmetrix::getmetrix($ARGV[1], $ARGV[2], $ARGV[3], $ARGV[4]);
    &err_handle($code, $msg);
} elsif ($cmd eq 'sum') {
    ($code, $msg) = &xCAT_monitoring::rmcmetrix::get_sum_metrix($ARGV[2], $ARGV[3]);
    &err_handle($code, $msg);
} else {
    print "ERROR:Invalid parameter\n";
}

1;