From 537a12a4416c8d58e58e3a9975649da65889d5bd Mon Sep 17 00:00:00 2001
From: =?utf8?q?Franti=C5=A1ek=20Dvo=C5=99=C3=A1k?= <valtri@civ.zcu.cz>
Date: Wed, 13 Sep 2006 15:00:43 +0000
Subject: [PATCH] Query 6.

---
 org.glite.jp.index/examples/pch06/query6.pl | 133 ++++++++++++++++++++++++++++
 1 file changed, 133 insertions(+)
 create mode 100644 org.glite.jp.index/examples/pch06/query6.pl

diff --git a/org.glite.jp.index/examples/pch06/query6.pl b/org.glite.jp.index/examples/pch06/query6.pl
new file mode 100644
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";
+}
-- 
1.8.2.3