Query 6.

diff --git a/org.glite.jp.index/examples/pch06/query6.pl b/org.glite.jp.index/examples/pch06/query6.pl
new file mode 100644 (file)
index 0000000..21521e8
--- /dev/null
+++ b/org.glite.jp.index/examples/pch06/query6.pl
@@ -0,0 +1,133 @@
+#! /usr/bin/perl
+
+#
+# 6. query:
+#
+# Find all output averaged images of softmean (average) procedures, where the
+# warped images taken as input were align_warped using a twelfth order
+# nonlinear 1365 parameter model, i.e. "where softmean was preceded in the
+# workflow, directly or indirectly, by an align_warp procedure with argument
+# -m 12. 
+#
+# call:
+#   ./query6.pl 2>/dev/null
+#
+
+use strict;
+use pch;
+use Data::Dumper;
+
+my $ps='https://skurut1.cesnet.cz:8901';
+my $is='https://skurut1.cesnet.cz:8902';
+my $program_name='align_warp';
+my $program_param='-m 12';
+my $end_program_name='softmean';
+
+#my %jobs = ();          # just information cache
+my @workflow_jobs = (); # sequencially jobid list
+my %workflow_jobs = (); # hash jobid list
+my @according_jobs = (); # sequencially jobid list
+my %according_jobs = (); # hash jobid list
+my $workflow_count = 0;
+
+
+# debug calls
+$pch::debug = 0;
+my $debug = 0;
+
+#
+# find out processes with given name and parameters
+#
+my @jobs = pch::isquery($is, [
+       ["$pch::jplbtag:IPAW_PROGRAM", ['EQUAL', "<string>$program_name</string>"]],
+       ["$pch::jplbtag:IPAW_PARAM", ['EQUAL', "<string>$program_param</string>"]],
+], ["$pch::jpwf:successor", @pch::view_attributes]);
+print Dumper(@jobs) if ($debug);
+die "...so exit on error" if ($pch::err);
+
+#
+# initial set of starting jobs from index server
+# (root jobs)
+#
+foreach my $job (@jobs) {
+       my %job = %$job;
+       my %attributes = %{$job{attributes}};
+       my $jobid = $job{jobid};
+
+       if (!exists $workflow_jobs{$jobid}) {
+               push @workflow_jobs, $jobid;
+               $workflow_jobs{$jobid} = \%job;
+       }
+}
+undef @jobs;
+
+
+#
+# collect all jobs (tree browsing down)
+#
+$workflow_count = 0;
+foreach my $jobid (@workflow_jobs) {
+       my @succs;
+
+       print "Handling $jobid (position $workflow_count)\n" if ($debug);
+       print "  progname: ".$workflow_jobs{$jobid}{attributes}{"$pch::jplbtag:IPAW_PROGRAM"}{value}[0]."\n" if ($debug);
+
+       if ($workflow_jobs{$jobid}{attributes}{"$pch::jplbtag:IPAW_PROGRAM"}{value}[0] eq $end_program_name) {
+               print "It's $end_program_name, adding\n" if $debug;
+               $according_jobs{$jobid} = \%{$workflow_jobs{$jobid}};
+               next;
+       }
+
+       @succs = pch::isquery($is, [["$pch::jpwf:ancestor", ['EQUAL', "<string>$jobid</string>"]]], \@pch::view_attributes);
+       die "...so exit on error" if ($pch::err);
+
+       for my $succ (@succs) {
+               my %succ = %$succ;
+               print "Considered: $succ{jobid}\n" if ($debug);
+               if (!exists $workflow_jobs{$succ{jobid}}) {
+                       $workflow_jobs{$succ{jobid}} = \%succ;
+                       push @workflow_jobs, $succ{jobid};
+                       print "Added $succ{jobid} to $#workflow_jobs\n" if ($debug);
+               }
+               else {
+                       print "Already existing $succ{jobid}\n" if ($debug);
+               }
+       }
+       $workflow_count++;
+}
+undef @workflow_jobs;
+undef %workflow_jobs;
+
+
+#
+# print the result set
+#
+print "Results\n";
+print "=======\n";
+print "\n";
+foreach my $jobid (sort { $according_jobs{$b}{attributes}{"$pch::jplbtag:IPAW_STAGE"}{value}[0] <=> $according_jobs{$a}{attributes}{"$pch::jplbtag:IPAW_STAGE"}{value}[0] } keys %according_jobs) {
+       my %job = %{$according_jobs{$jobid}};
+       my %attributes = %{$job{attributes}};
+
+       print "jobid $jobid:\n";
+
+       # output all desired atributes
+       foreach my $attr (@pch::view_attributes) {
+               my $attr_name = $attr; $attr_name =~ s/.*://;
+
+               print "  attr $attr_name: ";
+               if (exists $attributes{$attr}) {
+                       my %attr = %{$attributes{$attr}};
+
+                       if ($attr eq "$pch::jpsys:regtime") {
+                               print gmtime($attr{value}[0])." (".join(", ", @{$attr{value}}).")\n";
+                       } else {
+                               print join(", ", @{$attr{value}})."\n";
+                       }
+               } else {
+                       print "N/A\n";
+               }
+       }
+
+       print "\n";
+}