Changeset 27632

Timestamp:

Apr 7, 2010, 11:07:45 AM (16 years ago)

Author:

Paul Price

Message:

Adding destreak.

File:

• trunk/tools/errors.pl (modified) (2 diffs)

trunk/tools/errors.pl

@@ -46 +46 @@
 
 my $sql;                        # Query to run
-my $table;                      # Table with fault
+my $fault_table;                # Table with fault
+my $label_table;                # Table with label
 if ($stage eq "diff") {
     $sql = "SELECT diff_id, skycell_id, hostname, path_base FROM diffRun JOIN diffSkyfile USING(diff_id) WHERE fault != 0";
-    $table = "diffSkyfile";
+    $label_table = "diffRun";
+    $fault_table = "diffSkyfile";
 } elsif ($stage eq "stack") {
     $sql = "SELECT stack_id, 'stack', hostname, path_base FROM stackRun JOIN stackSumSkyfile USING(stack_id) WHERE fault != 0";
-    $table = "stackSumSkyfile";
+    $label_table = "stackRun";
+    $fault_table = "stackSumSkyfile";
 } elsif ($stage eq "warp") {
     $sql = "SELECT warp_id, skycell_id, hostname, path_base FROM warpRun JOIN warpSkyfile USING(warp_id) WHERE fault != 0";
-    $table = "warpSkyfile";
+    $label_table = "warpRun";
+    $fault_table = "warpSkyfile";
 } elsif ($stage eq "magic") {
     $sql = "SELECT magic_id, node, 'unknown' AS hostname, CONCAT(workdir, '/', exp_id, '/', exp_id, '.mgc.', magic_id, '.', node) FROM magicRun JOIN magicNodeResult USING(magic_id) WHERE magicNodeResult.fault != 0";
-    $table = "magicNodeResult";
+    $label_table = "magicRun";
+    $fault_table = "magicNodeResult";
 } elsif ($stage eq "chip") {
     $sql = "SELECT chip_id, class_id, hostname, CONCAT(path_base, '.', class_id) FROM chipRun JOIN chipProcessedImfile USING(chip_id) WHERE fault != 0";
-    $table = "chipProcessedImfile";
+    $label_table = "chipRun";
+    $fault_table = "chipProcessedImfile";
 } elsif ($stage eq "camera") {
     $sql = "SELECT cam_id, 'cam', hostname, path_base FROM camRun JOIN camProcessedExp USING(cam_id) WHERE fault != 0";
-    $table = "camProcessedExp";
+    $label_table = "camRun";
+    $fault_table = "camProcessedExp";
+} elsif ($stage eq "destreak") {
+    $sql = "SELECT magic_ds_id, component, 'unknown', CONCAT_WS('.', CONCAT(outroot, '/', exp_id), 'mds', magic_ds_id, stage_id, component) FROM magicDSRun JOIN magicDSFile USING(magic_ds_id) JOIN magicRun USING(magic_id) WHERE magicDSFile.fault != 0";
+    $label_table = "magicDSRun";
+    $fault_table = "magicDSFile";
 } else {
     die "Unsupported stage: $stage\n";
@@ -70 +81 @@
 
 my $where = "";                 # WHERE restriction
-$where .= " AND (label LIKE '" . join("' OR label LIKE '", @$label) . "')" if defined $label;
-$where .= " AND $table.fault = $fault" if defined $fault;
+$where .= " AND ($label_table.label LIKE '" . join("' OR $label_table.label LIKE '", @$label) . "')" if defined $label;
+$where .= " AND $fault_table.fault = $fault" if defined $fault;
 
 $sql .= $where if length $where > 0;