From 2a7020ecaac040a9d34bcc87d448e43269099049 Mon Sep 17 00:00:00 2001
From: ellen56 <ellen56@8638fb3e-16cb-4fca-ae20-7b5d299a9bcd>
Date: Sun, 27 Mar 2011 14:47:56 +0000
Subject: [PATCH] monshow enhancement for rmcmon eventlog

git-svn-id: https://svn.code.sf.net/p/xcat/code/xcat-core/trunk@9159 8638fb3e-16cb-4fca-ae20-7b5d299a9bcd
---
 xCAT-rmc/plugin/rmcmon.pm | 105 +++++++++++++++++++++++++++++++++++++-
 1 file changed, 103 insertions(+), 2 deletions(-)

diff --git a/xCAT-rmc/plugin/rmcmon.pm b/xCAT-rmc/plugin/rmcmon.pm
index cb02a72b8..17d816caf 100644
--- a/xCAT-rmc/plugin/rmcmon.pm
+++ b/xCAT-rmc/plugin/rmcmon.pm
@@ -1583,6 +1583,92 @@ sub showmetrix($rrddir, $attrs, $start_time, $end_time)
 	return $result;
 
 }
+
+sub showeventlog
+{
+  my @result = ();
+  my ($table, $node,$attrs,$start_time,$end_time,$where) = @_;
+
+  my $need_filter = 0;  #need second search to sql
+  my @attr = ();
+  my @attrkey = ();
+  my @severity = ('Informational', 'Warning', 'Critical');
+
+  if(!$attrs){
+    @attrkey = ('eventtype','monitor','monnode','application',
+               'component','id','severity','message','rawdata','comments');
+  } else {
+    @attrkey = split /,/, $attrs;
+  }
+  
+  #node 
+  push @attr, "node==$node";
+  #plugin
+  push @attr, "application==RMC";
+  #where
+  if(defined($where)){
+    foreach my $a (@$where){
+      if($a =~ /severity([!=><]+)(\w+)/){
+        my $op = $1;
+        my $sev = $2;
+        if(($op eq '==')||($op eq '!=')){
+          push @attr, $a;
+        } elsif($op eq '>=') {
+          foreach my $s (@severity){
+            if($sev =~ /^$s$/i){
+              last; 
+            }
+            push @attr, "severity!=$s"; 
+          }
+        } elsif($op eq '<=') {
+          my $s = pop @severity;
+          while($s !~ /^$sev$/i){
+            push @attr, "severity!=$s";
+            $s = pop @severity;
+          }
+        } elsif($op eq '>') {
+          foreach my $s (@severity){
+            if($sev =~ /^$s$/i){
+              push @attr, "severity!=$s";
+              last;
+            }
+          }
+        } elsif($op eq '<') {
+          my $s = pop @severity;
+          while($sev !~ /^$s$/i){
+            push @attr, "severity!=$s";
+            $s = pop @severity;
+          }
+          push @attr, "severity!=$s";
+        } 
+      } else {
+        push @attr, $a;
+      }
+    } 
+  }
+  #eventtime
+  my ($s_sec,$s_min,$s_hour,$s_mday,$s_mon,$s_year) = localtime($start_time);
+  my ($e_sec,$e_min,$e_hour,$e_mday,$e_mon,$e_year) = localtime($end_time);
+  my $tmp = sprintf("eventtime>=%04d-%02d-%02d %02d:%02d:%02d",$s_year+1900,$s_mon+1,$s_mday,$s_hour,$s_min,$s_sec);
+  push @attr, $tmp;
+  $tmp = sprintf("eventtime<=%04d-%02d-%02d %02d:%02d:%02d",$e_year+1900,$e_mon+1,$e_mday,$e_hour,$e_min,$e_sec);
+  push @attr, $tmp;
+
+  my @r = $table->getAllAttribsWhere(\@attr, 'eventtime', @attrkey);
+
+  push @result, (join ",", @attrkey);
+  $result[0] = "eventtime,$result[0]";
+  foreach my $entry (@r){
+    my $str = "\'$entry->{eventtime}\'";
+    foreach my $a (@attrkey){
+      $str = $str. ",\'$entry->{$a}\'";
+    }
+    push @result, $str;
+  }
+  return \@result;
+  
+}
+
 #--------------------------------------------------------------------------------
 =head3    show
       This function configures the cluster for the given nodes.  
@@ -1599,10 +1685,11 @@ sub showmetrix($rrddir, $attrs, $start_time, $end_time)
        (error code, error message)
 =cut
 #--------------------------------------------------------------------------------
-sub show {
+sub show 
+{
   print "rmcmon:show called\n";
   no strict 'refs';
-  my ($noderef, $sum, $time, $attrs, $pe, $callback) = @_;
+  my ($noderef, $sum, $time, $attrs, $pe, $where,$callback) = @_;
   my @monnodes = ();
   my $rsp = {};
   my $localhostname=hostname();
@@ -1636,6 +1723,7 @@ sub show {
   }
   $sum &= 0x1;
 
+  if($pe =~ /p/){
   if($sum){
     foreach $node (@monnodes){
       if($node eq $localhostname){
@@ -1668,6 +1756,19 @@ sub show {
       push @{$rsp->{data}}, @$output;
     }
   }
+  } elsif($pe =~ /e/){
+    my $eventtable =xCAT::Table->new("eventlog", -create =>0);
+    if (!$eventtable) {
+      push @{$rsp->{data}}, "Error:Can't open table eventlog!";
+      return -1;
+    }
+    foreach $node (@monnodes){
+      push @{$rsp->{data}}, "\n$node:";
+      $output = showeventlog($eventtable,$node,$attrs,$start_time,$end_time,$where);
+      push @{$rsp->{data}}, @$output;
+    }
+    $eventtable->close();
+  }
   $callback->($rsp);
   return (0, "");
 }