Index: trunk/ippMonitor/Makefile.in =================================================================== --- trunk/ippMonitor/Makefile.in (revision 27892) +++ trunk/ippMonitor/Makefile.in (revision 27927) @@ -13,5 +13,8 @@ PROGRAMS = \ -$(DESTBIN)/skyplot.dvo +$(DESTBIN)/skyplot.dvo \ +$(DESTBIN)/getLabels.pl \ +$(DESTBIN)/checkServer.pl \ +$(DESTBIN)/getServerStatus.pl RAWSRC = \ @@ -43,5 +46,7 @@ $(DESTWWW)/simplePlotraw.php \ $(DESTWWW)/skyplot.php \ -$(DESTWWW)/getimage.php +$(DESTWWW)/getimage.php \ +$(DESTWWW)/czartool.php \ + DEFSRC = \ Index: trunk/ippMonitor/raw/czartool.php =================================================================== --- trunk/ippMonitor/raw/czartool.php (revision 27927) +++ trunk/ippMonitor/raw/czartool.php (revision 27927) @@ -0,0 +1,315 @@ +"; + for ($i = 0; $i < count($distLabels); $i++) { + echo "$distLabels[$i]
"; + } +} + +$states=array("full","new","drop","wait"); +$stages=array("chip","cam","fake","warp","stack","diff","magic","destreak","dist"); +$servers=array("addstar", "cleanup", "detrend", "distribution", "pstamp", "publishing", "registration", "replication", "stdscience", "summitcopy"); +$separator = "-----"; +// set up the form +echo "
\n"; +echo "\n"; +echo "\n"; + +echo "\n"; +echo "\n"; +echo "\n"; +echo "
\n"; + + +$stateChosen = 0; +foreach ($states as &$state) { + + if ($userSelection == $state) { + showAllLabels($pass, $proj, $db, $stdsLabels, $distLabels, $stages, $states, $state); + $stateChosen=1; + break; + } +} + +$serverChosen = 0; +foreach ($servers as &$server) { + + if ($userSelection == $server) { + showServerStatus($server); + $serverChosen=1; + break; + } +} +if (!$stateChosen && !$serverChosen) { + + if ($userSelection == "servers") {showAllServerStatus($servers); }// TODO + elseif ($userSelection == $separator) {} + else { showOneLabel($pass, $proj, $db, $userSelection, $stages, $states);} + +} +menu_end(); + +########################################################################### +# +# Shows the status of the provided pantasks server +# +########################################################################### +function showServerStatus($server) { + + echo "

Status for $server server

"; + + $results=array(); + exec("getServerStatus.pl -s $server", $results, $status); + + foreach ($results as &$line) { + echo "
\n";
+        echo "$line\n";
+        echo "
\n"; + + } + +} + +########################################################################### +# +# Checks the status of all the pantasks servers +# +########################################################################### +function showAllServerStatus($servers) { + + echo "

Status for all pantasks servers

"; + + // set up table columns + $class = "list"; + echo "\n"; + echo "\n"; + write_header_cell($class, "Server"); + write_header_cell($class, "Alive?"); + write_header_cell($class, "Scheduler running?"); + echo "\n"; + + foreach ($servers as &$server) { + + $results=array(); + exec("checkServer.pl -s $server", $results, $status); + + echo "\n"; + write_table_cell($class, '%s', "", $server); + write_table_cell($class, '%s', "", $results[0]); + write_table_cell($class, '%s', "", $results[1]); + echo "\n"; + } + + echo "
\n"; +} + + +########################################################################### +# +# Checks one label and prints results in a table +# +########################################################################### +function showOneLabel($pass, $proj, $db, $label, $stages, $states) { + + echo "

Current status for label '$label' (any faults are shown in parentheses)

"; + + // set up table columns + $class = "list"; + echo "\n"; + echo "\n"; + write_header_cell($class, "state"); + foreach ($stages as &$stage) {write_header_cell($class, $stage);} + echo "\n"; + + // write rows + foreach ($states as &$state) { + + $link = "czartool.php?pass=" . $pass . "&proj=" . $proj . "&label=" . $state; + + echo "\n"; + write_table_cell($class, '%s', $link, $state); + write_table_cell($class, '%s', "", getStateAndFaults($db, $label,"chipRun", $state, "chip")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $label,"camRun", $state, "cam")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $label,"fakeRun", $state, "fake")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $label,"warpRun", $state, "warp")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $label,"stackRun", $state, "stack")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $label,"diffRun", $state, "diff")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $label,"magicRun", $state, "magic")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $label,"magicDSRun", $state, "magicDS")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $label,"distRun", $state, "dist")); + echo "\n"; + } + + echo "
\n"; +} + +########################################################################### +# +# Creates table for all labels showing all stages for given 'state' +# +########################################################################### +function showAllLabels($pass, $proj, $db, $stdsLabels, $distLabels, $stages, $states, $selectedState) { + + echo "

Current stdscience labels for '$selectedState' (any faults are shown in parentheses)

"; + + // set up table columns + $class = "list"; + echo "\n"; + echo "\n"; + write_header_cell($class, "label"); + write_header_cell($class, "distributing?"); + // echo "\n"; + // echo "\n"; + + foreach ($stages as &$stage) {write_header_cell($class, $stage);} + //foreach ($stages as &$stage) { + + // $link = "czartool.php?pass=" . $pass . "&proj=" . $proj . "&label=" . $stage; + // echo "\n"; + // } + + echo "\n"; + + // write rows + foreach ($stdsLabels as &$stdsLabel) { + + $distributing = false; + foreach ($distLabels as &$distLabel) { + + if ($stdsLabel == $distLabel) { $distributing = true; break;} + } + + + // create link to label summary page for each label + $link = "czartool.php?pass=" . $pass . "&proj=" . $proj . "&label=" . $stdsLabel; + + echo "\n"; + write_table_cell($class, '%s', $link, $stdsLabel); + write_table_cell($class, '%s', "", $distributing ? "yes" : "NO"); + write_table_cell($class, '%s', "", getStateAndFaults($db, $stdsLabel,"chipRun", $selectedState, "chip")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $stdsLabel,"camRun", $selectedState, "cam")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $stdsLabel,"fakeRun", $selectedState, "fake")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $stdsLabel,"warpRun", $selectedState, "warp")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $stdsLabel,"stackRun", $selectedState, "stack")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $stdsLabel,"diffRun", $selectedState, "diff")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $stdsLabel,"magicRun", $selectedState, "magic")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $stdsLabel,"magicDSRun", $selectedState, "magicDS")); + write_table_cell($class, '%s', "", getStateAndFaults($db, $stdsLabel,"distRun", $selectedState, "dist")); + echo "\n"; + } + + echo "
$myValue label$stage
\n"; +} + +########################################################################### +# +# Returns state and fault-count (if new) as a string +# +########################################################################### +function getStateAndFaults($db, $label, $table, $state, $stage) { + + $new = checkLabel($db, $label, $table, $state, $stage); + + if ($state != "new") {return $new;} + + $faults = countFaults($db, $label,$table,$stage); + + if ($faults < 1) {return $new;} + + return $new."(".$faults.")"; +} + +########################################################################### +# +# Returns count of exposures with this state for this label +# +########################################################################### +function checkLabel($db, $label, $table, $state, $stage) { + + $sql = "SELECT COUNT(state) FROM $table WHERE label LIKE '$label' AND state = '$state'"; + if ($debug) {echo "$sql
";} + + $qry = $db->query($sql); + if (dberror($qry)) {echo "error with $sql
\n";} + if (!$qry->fetchInto($row)) {echo "error with $sql
\n";} + return $row[0]; +} + +########################################################################### +# +# Returns count of faults for this stage and label +# +########################################################################### +function countFaults($db, $label, $table, $stage) { + + $joinTable = 0; + $id = $stage."_id"; + + if ($stage == "chip") {$joinTable="chipProcessedImfile";} + elseif ($stage == "cam") {$joinTable="camProcessedExp";} + elseif ($stage == "fake") {$joinTable="fakeProcessedImfile";} + elseif ($stage == "warp") {$joinTable="warpSkyfile";} + elseif ($stage == "stack") {$joinTable="stackSumSkyfile";} + elseif ($stage == "diff") {$joinTable="diffSkyfile";} + elseif ($stage == "magic") {$joinTable="magicNodeResult";} + elseif ($stage == "magicDS") {$id = "magic_ds_id"; $joinTable="magicDSFile";} + elseif ($stage == "dist") {$joinTable="distComponent";} + else {return -1;} + + $faultCol = $joinTable.".fault"; + + $sql = "SELECT COUNT(DISTINCT $id) FROM $table JOIN $joinTable USING ($id) WHERE label LIKE '$label' AND $faultCol != 0 AND $table.state = 'new'"; + if ($debug) {echo "$sql
";} + + $qry = $db->query($sql); + if (dberror($qry)) {echo "error with $sql
\n";} + if (!$qry->fetchInto($row)) {echo "error with $sql
\n";} + return $row[0]; +} +?> + Index: trunk/ippMonitor/raw/ipp.imfiles.dat =================================================================== --- trunk/ippMonitor/raw/ipp.imfiles.dat (revision 27892) +++ trunk/ippMonitor/raw/ipp.imfiles.dat (revision 27927) @@ -21,2 +21,4 @@ menutop | menutop | link | simple plot - chip | simplePlot.php menutop | menutop | link | simple plot - cam | simplePlotcam.php +menutop | menutop | link | czartool | czartool.php + Index: trunk/ippMonitor/scripts/checkServer.pl =================================================================== --- trunk/ippMonitor/scripts/checkServer.pl (revision 27927) +++ trunk/ippMonitor/scripts/checkServer.pl (revision 27927) @@ -0,0 +1,25 @@ +#!/usr/bin/perl -w + +use warnings; +use strict; +use Getopt::Long; + +my $server = undef; +GetOptions ("server|s=s" => \$server); + +my @cmdOut = `echo "status ;quit" | pantasks_client -c ~ipp/$server/ptolemy.rc 2>&1`; +my $line; +my $foundStatus = 0; +my $isRunning = 0; +foreach $line (@cmdOut) { + + chomp($line); + if ($line =~ m/Scheduler is stopped/) {$isRunning = 0; $foundStatus=1;last;} + if ($line =~ m/Scheduler is running/) {$isRunning = 1; $foundStatus=1;last;} + if ($line =~ m/Task Staus/) {last;} + +} + +($foundStatus) ? print "yes\n" : print "no\n"; +($isRunning) ? print "yes\n" : print "no\n"; + Index: trunk/ippMonitor/scripts/getLabels.pl =================================================================== --- trunk/ippMonitor/scripts/getLabels.pl (revision 27927) +++ trunk/ippMonitor/scripts/getLabels.pl (revision 27927) @@ -0,0 +1,25 @@ +#!/usr/bin/perl -w + +use warnings; +use strict; +use Getopt::Long; + +my $server = undef; +GetOptions ("server|s=s" => \$server); + +my @cmdOut = `echo "show.labels;quit" | pantasks_client -c ~ipp/$server/ptolemy.rc 2>&1`; +my $line; +my $passedHeader=0; +foreach $line (@cmdOut) { + + chomp($line); + if ($line =~ m/pantasks:\s+(.*)/) { + + # HACK to get around 'dummy' label in stdscience + if ($1 !~ m/.*dummy.*/) {print "$1\n"}; + $passedHeader=1; + next; + } + + if ($passedHeader){print "$line\n";} +} Index: trunk/ippMonitor/scripts/getServerStatus.pl =================================================================== --- trunk/ippMonitor/scripts/getServerStatus.pl (revision 27927) +++ trunk/ippMonitor/scripts/getServerStatus.pl (revision 27927) @@ -0,0 +1,18 @@ +#!/usr/bin/perl -w + +use warnings; +use strict; +use Getopt::Long; + +my $server = undef; +GetOptions ("server|s=s" => \$server); + +my @cmdOut = `echo "status;quit" | pantasks_client -c ~ipp/$server/ptolemy.rc 2>&1`; +my $line; +my $passedHeader=0; +foreach $line (@cmdOut) { + + chomp($line); + if ($line =~ m/.*Task Status.*/) {$passedHeader=1;next;} + if ($passedHeader){print "$line
";} +}