1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
#!/bin/sh
#
#___INFO__MARK_BEGIN__
##########################################################################
#
# The Contents of this file are made available subject to the terms of
# the Sun Industry Standards Source License Version 1.2
#
# Sun Microsystems Inc., March, 2001
#
#
# Sun Industry Standards Source License Version 1.2
# =================================================
# The contents of this file are subject to the Sun Industry Standards
# Source License Version 1.2 (the "License"); You may not use this file
# except in compliance with the License. You may obtain a copy of the
# License at http://gridengine.sunsource.net/Gridengine_SISSL_license.html
#
# Software provided under this License is provided on an "AS IS" basis,
# WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING,
# WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS,
# MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING.
# See the License for the specific provisions governing your rights and
# obligations concerning the Software.
#
# The Initial Developer of the Original Code is: Sun Microsystems, Inc.
#
# Copyright: 2001 by Sun Microsystems, Inc.
#
# All Rights Reserved.
#
##########################################################################
#___INFO__MARK_END__
#
# This is a sample script to demonstrate use of job dependencies. The
# sample submits one job for each node in the pascal triangle:
#
# 1 depth 1
# / \
# 1 1 depth 2
# / \ / \
# 1 2 1 depth 3
# / \ / \ / \
# 1 3 3 1 depth 4
#
# : : : :
#
# Data exchange between jobs is done via files in jobnet_dir.
#
# Usage: pascal.sh <depth of pascal triangle>
jobnet_dir=$HOME/pascal_jobnet
if [ $# -ne 1 ]; then
echo "usage: pascal.sh <depth of pascal triangle>" >&2
exit 1
fi
n=$1
i=1
mkdir $jobnet_dir
rm $jobnet_dir/*
while [ $i -le $n ]; do
j=1
while [ $j -le $i ]; do
prev_line=`expr $i - 1`
# specify own jobname
submit_args="-N P${i}_${j}"
if [ $j -gt 1 -a $j -lt $i ]; then
depend1=P${prev_line}_`expr ${j} - 1`
depend2=P${prev_line}_${j}
depend="$depend1 $depend2"
submit_args="$submit_args -hold_jid $depend1,$depend2"
elif [ $j -gt 1 ]; then
depend=P${prev_line}_`expr ${j} - 1`
submit_args="$submit_args -hold_jid $depend"
elif [ $j -lt $i ]; then
depend=P${prev_line}_${j}
submit_args="$submit_args -hold_jid $depend"
fi
echo "qsub -j y -o $jobnet_dir $submit_args -- $jobnet_dir $depend"
qsub -r y -j y -o $jobnet_dir $submit_args -- $jobnet_dir $depend << EOF
#!/bin/sh
#$ -S /bin/sh
result=0
jobnet_dir=\$1
shift
while [ \$# -gt 0 ]; do
depend=\$1
shift
to_add=\`cat \$jobnet_dir/DATA_\$depend\`
result=\`expr \$result + \$to_add\`
echo "\$REQUEST: adding \$to_add found in \$jobnet_dir/DATA_\$depend results in \$result"
done
if [ \$result = 0 ]; then
result=1
fi
echo \$result > \$jobnet_dir/DATA_\$REQUEST
EOF
j=`expr $j + 1`
done
i=`expr $i + 1`
done
|
