Diff for /loncom/cgi/clusterstatus.pl between versions 1.7 and 1.8

version 1.7, 2003/02/25 21:56:48 version 1.8, 2003/07/30 21:20:16
Line 14  use LWP::UserAgent(); Line 14  use LWP::UserAgent();
 use HTTP::Headers;  use HTTP::Headers;
 use IO::File;  use IO::File;
   
   my %host=();
   my $oneday=60*60*24;
   
   my %connectionstatus=();
   
   sub key {
       my ($local,$url)=@_;
       my $key=$local.'_'.$url;
       $key=~s/\W/\_/gs;
       return $key;
   }
   
   sub hidden {
       my ($name,$value)=@_;
       print "\n<input type='hidden' name='$name' value='$value' />";
   }
   
   sub request {
       my ($local,$url,$cachetime)=@_;
       my $key=&key($local,$url);
       my $reply='';
       if ($FORM{$key.'_time'}) {
    if ((time-$FORM{$key.'_time'})<$cachetime) {
       $reply=$FORM{$key};
       &hidden($key.'_time',$FORM{$key.'_time'});
       &hidden($key.'_fromcache',1);
    }
       }
       unless ($reply) {
    unless ($hostname{$local}) { 
       $reply='local_unknown'; 
    } else {
   
       my $ua=new LWP::UserAgent(timeout => 20);
       
       my $request=new HTTP::Request('GET',
     "http://".$hostname{$local}.$url);
       $request->authorization_basic('lonadm','litelite');
   
       my $response=$ua->request($request);
   
       unless ($response->is_success) { 
    $reply='local_error'; 
       } else {
    $reply=$response->content;
    chomp($reply);
       }
    }
    &hidden($key.'_time',time);
       }
       &hidden($key,$reply);
       return $reply;
   }
   
   # ============================================= Are local and remote connected?
 sub connected {  sub connected {
     my ($local,$remote)=@_;      my ($local,$remote)=@_;
     $local=~s/\W//g;      $local=~s/\W//g;
     $remote=~s/\W//g;      $remote=~s/\W//g;
   
     unless ($hostname{$local}) { return 'local_unknown'; }  
     unless ($hostname{$remote}) { return 'remote_unknown'; }      unless ($hostname{$remote}) { return 'remote_unknown'; }
       my $url='/cgi-bin/ping.pl?'.$remote;
     my $ua=new LWP::UserAgent;  #
       # Slowly phase this in: if not cached, only do 10 percent of the cases 
     my $request=new HTTP::Request('GET',  #
       "http://".$hostname{$local}.'/cgi-bin/ping.pl?'.$remote);      unless ($FORM{&key($local,$url)}) {
    unless (rand>0.9) { return 'not_yet'; }
     my $response=$ua->request($request);      }
   #
     unless ($response->is_success) { return 'local_error'; }  # Actually do the query
   #
     my $reply=$response->content;      &statuslist($local,'connecting '.$remote);
       my $reply=&request($local,$url,1800);
     $reply=(split("\n",$reply))[0];      $reply=(split("\n",$reply))[0];
     $reply=~s/\W//g;      $reply=~s/\W//g;
     if ($reply ne $remote) { return $reply; }      if ($reply ne $remote) { return $reply; }
     return 'ok';      return 'ok';
 }  }
   # ============================================================ Get a reply hash
   
   sub replyhash {
       my %returnhash=();
       foreach (split(/\&/,&request(@_))) {
    my ($name,$value)=split(/\=/,$_);
    if ($name) {
       unless ($value) { $value=''; }
       $returnhash{$name}=$value;
    }
       }
       return %returnhash;
   }
   
    # ========================================================== Show server status
   
   sub otherwindow {
       my ($local,$url,$label)=@_;
       return
     "<a href='http://$hostname{$local}$url' target='newwin$local'>$label</a>";
   }
   
   sub serverstatus {
       my $local=shift;
       print "\n<hr /><h3>$local $hostdom{$local} ($hostname{$local}; $hostrole{$local})</h3>\n";
   # checkrpms
       if ($host{$local.'_checkrpms'}) {
    print "<br />RPMs: ".$host{$local.'_checkrpms'}
       }
   # mysql
       if ($host{$local.'_mysql'}) {
    print "<br />MySQL Database: ".$host{$local.'_mysql'}
       }
   }
   
   # ====================================================================== Status
   sub statuslist {
       my ($local,$what)=@_;
       print 
   "<script>document.prgstat.progress.value='Testing $local ($hostname{$local}): $what';</script>\n";
   }
   
   #
   # Main program
   #
   # ========================================================= Get form parameters
   my $buffer;
   
   read(STDIN, $buffer, $ENV{'CONTENT_LENGTH'});
   my @pairs=split(/&/,$buffer);
   my $pair; my $name; my $value;
   undef %FORM;
   %FORM=();
   foreach $pair (@pairs) {
       ($name,$value) = split(/=/,$pair);
       $value =~ tr/+/ /;
       $value =~ s/%([a-fA-F0-9][a-fA-F0-9])/pack("C",hex($1))/eg;
       $FORM{$name}=$value;
   } 
   
   $buffer=$ENV{'QUERY_STRING'};
   @pairs=split(/&/,$buffer);
   foreach $pair (@pairs) {
       ($name,$value) = split(/=/,$pair);
       $value =~ tr/+/ /;
       $value =~ s/%([a-fA-F0-9][a-fA-F0-9])/pack("C",hex($1))/eg;
       $FORM{$name}=$value;
   } 
   
   # ====================================================== Determine refresh rate
   
   my $refresh=(($FORM{'refresh'}=~/^\d+$/)?$FORM{'refresh'}:60);
   if ($refresh<30) { $refresh=30; }
   my $starttime=time;
   # ================================================================ Send Headers
 print "Content-type: text/html\n\n".  print "Content-type: text/html\n\n".
       "<html><body bgcolor=#FFFFFF>\n";      "<html><body bgcolor=#FFFFFF>\n";
 # -------------------- Read loncapa.conf (and by default, loncapa_apache.conf).  # -------------------- Read loncapa.conf (and by default, loncapa_apache.conf).
 my $perlvarref=LONCAPA::Configuration::read_conf('loncapa.conf');  my $perlvarref=LONCAPA::Configuration::read_conf('loncapa.conf');
 my %perlvar=%{$perlvarref};  my %perlvar=%{$perlvarref};
Line 68  delete $perlvar{'lonSqlAccess'}; # remov Line 196  delete $perlvar{'lonSqlAccess'}; # remov
     }      }
 }  }
   
 print   print "<h1>Cluster Status ".localtime()."</h1>";
 "<h1>Cluster Status</h1>";  print "<form name='prgstat'>\n".
 print "Please be patient while building cluster status ...<p>\n";  "<input type='text' name='progress' value='Starting ...' size='100' /><br />".
 $table='';  "</form>\n";;
   print "<form name='status' method='post'>\n";
 $table.="<table border=2><tr><th rowspan=2>From (local)</th>".  &hidden('refresh',$refresh);
 "<th colspan=$total>To (remote)</th></tr><tr>";  
 foreach $remote (sort keys %hostname) {  # ==================================================== Main Loop over all Hosts
    $table.="<th";  
    if ($remote eq $perlvar{'lonHostID'}) {  
        $table.=" bgcolor=#CCFFBB";  
    } else {  
        if ($libserv{$remote}) { $table.=" bgcolor=#FFFF99"; }  
    }  
    $table.=  
  "><a href=http://".$hostname{$remote}."/lon-status/>$remote</a></th>";  
 }  
 $table.="</tr>";  
 foreach $local (sort keys %hostname) {  foreach $local (sort keys %hostname) {
    print "Checking $local: ";  # -- Check general status
    $table.="<tr><td";      &statuslist($local,'General');
    if ($local eq $perlvar{'lonHostID'}) {      my %loncron=&replyhash($local,'/lon-status/loncron_simple.txt',1200);
        $table.=" bgcolor=#CCFFBB";      if (defined($loncron{'local_error'})) {
    } else {   $host{$local.'_loncron'}='Could not determine.';
        if ($libserv{$local}) { $table.=" bgcolor=#FFFF99"; }      } else {
    }   if ((time-$loncron{'time'})>$oneday) {
    $table.=      $host{$local.'_loncron'}='Stale.';
  "><b><a href=http://".$hostname{$local}."/lon-status/>$local</a></b><br>".   } else {
      $hostrole{$local}.' '.$hostdom{$local}.'<br>'.   }
      "<tt><a href=http://".$hostname{$local}."/server-status/>".      }
       $hostname{$local}."</a></tt><br>".  # -- Check user status
      "<a href=http://".$hostname{$local}."/cgi-bin/loncron.pl>New Report</a>".      &statuslist($local,'Users');
      "</td>";      my %userstatus=&replyhash($local,'/cgi-bin/userstatus.pl?simple',600);
    foreach $remote (sort keys %hostname) {      if (defined($userstatus{'local_error'})) {
        $status=&connected($local,$remote);   $host{$local.'_userstatus'}='Could not determine.';
        if ($status eq 'ok') {      } else {
    $table.="<td";      }
            if ($libserv{$remote}) {  # -- Check mysql status
        if ($libserv{$local}) {      &statuslist($local,'Database');
    $table.=" bgcolor=#FFFF44";      my %mysql=&replyhash($local,'/lon-status/mysql.txt',1200);
                } else {      if (defined($mysql{'local_error'})) {
                    $table.=" bgcolor=#FFFF99";   $host{$local.'_mysql'}='Could not determine.';
                }      } else {
            } elsif ($libserv{$local}) {   if ((time-$mysql{'time'})>(7*$oneday)) {
                $table.=" bgcolor=#FFFF99";      if ($hostrole{$local} eq 'library') {
            }   $host{$local.'_mysql'}='Stale.';
            $table.="><b><font color=#00FF00>OK</font></b></td>";   $host{$local.'_mysql_doomed'}=1;
            print ".";      }
        } else {      if ($mysql{'mysql'} eq 'defunct') {
            print "X";   $host{$local.'_mysql'}='Defunct (maybe stale).';
            $table.="<td><b><font color=#FF0000>".$status."</font></b><br>".   $host{$local.'_mysql_doomed'}=2;
      "<a href=http://".$hostname{$local}.      }
  "/lon-status/loncstatus.txt>lonc</a>".   } elsif ($mysql{'mysql'} eq 'defunct') {
     " <a href=http://".$hostname{$remote}.      $host{$local.'_mysql'}='Defunct.';
       "/lon-status/londstatus.txt>lond</a>".      $host{$local.'_mysql_doomed'}=3;
             "</td>";   }
        }      }
    }  # -- Check rpm status
    $table.="</tr>\n";      &statuslist($local,'RPMs');
     print "<br>\n";      my %checkrpms=&replyhash($local,'/lon-status/checkrpms.txt',2400);
 }      if (defined($checkrpms{'local_error'})) {
 $table.="</table>";   $host{$local.'_checkrpms'}='Could not determine.';
 print $table;      } else {
 print "</body></html>";   if ((time-$checkrpms{'time'})>(4*$oneday)) {
       $host{$local.'_checkrpms'}='Stale.';
       $host{$local.'_checkrpms_doomed'}=50;
    } elsif ($checkrpms{'status'} eq 'fail') {
       $host{$local.'_checkrpms'}='Could not checked RPMs.';
       $host{$local.'_checkrpms_doomed'}=100;
    } elsif ($checkrpms{'rpmcount'}) {
       $host{$local.'_checkrpms'}='Outdated RPMs: '.
    $checkrpms{'rpmcount'};
       $host{$local.'_checkrpms_doomed'}=$checkrpms{'rpmcount'};
    }
       }
   # -- Check connections
       &statuslist($local,'Connections');
       $host{$local.'_notconnected'}='';
       $host{$local.'_notconnected_doomed'}=0;
       foreach $remote (sort keys %hostname) {
    my $status=&connected($local,$remote);
    $connectionstatus{$local.'_TO_'.$remote}=$status;
    unless (($status eq 'ok') || ($status eq 'not_yet')) {
       $host{$local.'_notconnected'}.=' '.$remote;
       $host{$local.'_notconnected_doomed'}++;
    }
       }
   # Eventually, use doomed count
       &serverstatus($local);
   }
   
   # =============================================================== End Mail Loop
   print "</form><script>";
   $runtime=time-$starttime;
   if ($runtime>=$refresh) {
       print 'document.status.submit();';
   } else {
       $refreshtime=int(1000*($refresh-$runtime));
       print "setTimeout('document.status.submit()',$refreshtime);";
   }
   print "</script></body></html>";
   exit 0;

Removed from v.1.7  
changed lines
  Added in v.1.8


FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>