xcat-core/xCAT-server/sbin/pcp_collect

#!/usr/bin/env perl
# IBM(c) 2007 EPL license http://www.eclipse.org/legal/epl-v10.html
#package xCAT_monitoring::performance;
BEGIN
{
  $::XCATROOT = $ENV{'XCATROOT'} ? $ENV{'XCATROOT'} : '/opt/xcat';
}
use lib "$::XCATROOT/lib/perl";
use xCAT::NodeRange;
use Sys::Hostname;
use Socket;
use xCAT::Utils;
use xCAT::TableUtils;
use xCAT::NetworkUtils;
use xCAT::GlobalDef;
use xCAT_monitoring::monitorctrl;
use xCAT::MsgUtils;
use xCAT_monitoring::xcatmon;
use strict;
use warnings;
1;
performance();
sub  performance
     { #opening subroutine
	  
           my $noderef=xCAT_monitoring::monitorctrl->getMonHierarchy();
           #identification of this node
           my @hostinfo=xCAT::NetworkUtils->determinehostname();
           #print "hosT:@hostinfo\n";
           my $isSV=xCAT::Utils->isServiceNode();
           #print "is sv is:$isSV \n";
           my %iphash=();
           foreach(@hostinfo) {$iphash{$_}=1;}
           if (!$isSV) { $iphash{'noservicenode'}=1;}

           my @children;
           my $str;
		   
           foreach my $key (keys (%$noderef))
            { #opening foreach1
	      #print "opening foreach1 \n";
              #print "key is: $key \n";
              my @key_a=split(':', $key);
	      if (! $iphash{$key_a[0]}) { next;}
              my $mon_nodes=$noderef->{$key};

              foreach(@$mon_nodes)
                { #opening foreach2
                  my $node=$_->[0];
                  my $nodetype=$_->[1];
                  #print "node=$node, nodetype=$nodetype\n";
                  if (($nodetype) && ($nodetype =~ /$::NODETYPE_OSI/))
                   {
                    push(@children,$node);
                   }
                } #closing foreach2
            }  #closing foreach1
          
	  #print "children:@children\n";
          my $count_child=@children;
          if($count_child > 0)
            { #opening if count_child 1
	      #print "number of children is $count_child \n";
              no strict;
	      no warnings;
	      #my $i=0;
	       my @inactive_children;
	       for ($i = 0;$i < $count_child;$i++)
		   { #opening if count_child 2
			$str=`pmdumptext -c $::XCATROOT/lib/perl/xCAT_monitoring/pcp/pcpmon.config -d<> -s1 -h$children[$i] -f%D:%H:%M:%S 2>&1`;
			#print "before split is $str \n";
			#if ($str =~ /\s*No\s*route\s*to\s*host/)
			if ($str =~ /pmdumptext:\s*Error:\s*host\s*"\w*":/) 
                          {
                             #print "host unreachable \n";
			     @inactive_children=$children[$i];
			     #print "inactive children is @inactive_children \n";
                          }
                             
			 else
			       {
				  #print "into elso loop \n";
				  $str =~ s/\n//g;
				  #print "before split_1 is $str \n";
				  my @spl1=split(/<2F>/,$str);
				  #print "splitted and #printing \n";
				  #print @spl1;
				  my $count_spl1=@spl1;
			          #print "the array has $count_spl1 elements \n"; 
				  #print "@spl1[0] \n";
				  #print "@spl1[1] \n";
				  #my $count3= `cat $::XCATROOT/lib/perl/xCAT_monitoring/pcp/pcpmon.config | wc -l`;
			          #print "the number of lines in the file is count3:$count3 \n";
				  #`tr "\n" "<22>" <$::XCATROOT/lib/perl/xCAT_monitoring/pcp/pcpmon.config> $::XCATROOT/lib/perl/xCAT_monitoring/pcp/pcpmon.config.tr`;
				  my $fname;
				  if (-e "/var/log/pcpmon.config")
				   {
				     #print "config under /var/log \n";
				     $fname="/var/log/pcpmon.config";
				   }
				  else
				   {
                                     #print "config not under /var/log \n";
                                     $fname = "$::XCATROOT/lib/perl/xCAT_monitoring/pcp/pcpmon.config"; 
				   }
				  print "config file is in $fname \n";
                                  unless ( open( CONF, $fname ))
                                   {
                                     return(0);
                                   }
                                  my @raw_data = <CONF>;
                                  close( CONF );
				  #print "before chopping @raw_data \n";
				  chop(@raw_data);
				  #print "raw data after chopping is @raw_data \n";
				  my $raw_data = join('<27>', @raw_data);
                                  #print "the contents of the config file are $raw_data \n";
				  my @spl2=split(/<2F>/,$raw_data);
				  #print "splitted and #printing \n";
				  #print @spl2;
				  my $count_spl2=@spl2;
			          #print "the array has $count_spl2 elements \n"; 
				  #print @spl2[0] ;
				  #print @spl2[1] ;
                                  #print "updating table \n";
				  my $table1=xCAT::Table->new("performance", -create => 1,-autocommit => 1);
				  #print "table created \n";
				  my $j;
				  #my $k;
				  my $l=$j+1;
				  #print "l is $l \n";
				  my %setting_hash=();
				  for ($j=0;$j<$count_spl2 ;$j++)
					 {
					  
					    #print "inside j loop \n";
					    #print "spl1[0] is $spl1[0] \n";
					    my %key_col1 = (timestamp=>$spl1[0]);
				            #print "time stamp updated \n";
					    #print "node is $children[$i] \n";
	                                    $key_col1{node}=$children[$i]; 
				            #print "children updatesd \n";
					    #print "spl2 is $spl2[$j] \n";
				            $key_col1{attrname} = $spl2[$j];
					    #$setting_hash{attrname}=$spl2[$j];
					    #print "spl1 is $spl1[$j+1] \n";
                                            $setting_hash{attrvalue}=$spl1[$j+1];
					    $table1->setAttribs(\%key_col1, \%setting_hash);
					 }
				    $table1->close();
				  }
				 } #closing if count_child 2


		      my $table2=xCAT::Table->new("monitoring", -create =>1);
                      if (!$table2)
		       {
                        my $rsp={};
                        $rsp->{data}->[0]="Cannot open the monitoring table.\n";
                        $callback->($rsp);
                        return 1;
                       }

		      my $ref = $table2->getAttribs({'name' => 'pcpmon'}, 'nodestatmon');
		      #print "array is $ref \n";
                      my $node_stat=$ref->{nodestatmon};
		      #print "nodestatmon is $node_stat \n";
		      if ($node_stat ='Y')
		      { #opening ifnodestatusmon
		        #print "inside nodestatus mon $node_stat \n";
                         my %node_status=();
		         #print "2nd set is @inactive_children \n";
		         my $count_inactive=@inactive_children;
                         if ($count_inactive>0) 
		           { 
		             #print "more than 0 inactive children \n";
			     #print "3rd set is @inactive_children \n";			   
                             $node_status{$::STATUS_INACTIVE}=\@inactive_children;
			     my $changed1=$nodes_status{$::STATUS_INACTIVE};
                             #print "the changed1 is $changed1 \n";
			     my @final_inactive=@$changed1;
			     #print "final inactive is @final_inactive \n";
                           }


                           #only set the node status for the changed ones
                           if (keys(%node_status) > 0) 
                           {
                             #print %node_status, "\n"; 
                             #print "updating nodelist table \n";
                             xCAT_monitoring::xcatmon::setNodeStatusAttributes(\%node_status);
                           }

                     } #closing if nodestatusmon
	    } #closing if count_child 1   
			
        } # closing subroutine