#!/bin/ksh # subjob - Plot-Shellskript Version: @(#)SUBJOB 1.0 13/02/07 # Prozedur zum automatischen Generieren von Batch-Jobs, die unter NQS # laufen sollen und deren Ergebnis (Dayfile) zum Job-generierenden # Host zurueckgeschickt werden sollen # letzte Aenderung: # 29/06/94 - Siggi - Beginn mit Erstellung der Originalversion # 08/07/94 - Siggi - Originalversion abgeschlossen (Version 1.0) # 06/02/98 - Siggi - berte validiert # 27/01/01 - Siggi - ground.yonsei.ac.kr validiert, Jobs zur T3E in Korea # moeglich # 08/02/01 - Siggi - alle subjob-Meldungen ins englische uebersetzt # 25/05/02 - Siggi - Unterstuetzung des LoadLeveler # 30/05/02 - Siggi - Validierung fuer ibm-Rechner in Seoul (nobel) sowie # allgemeine Anpassungen fuer ibm-Rechner # 15/10/02 - Siggi - Neue Default-Jobklasse (p_normal) fuer IBM in Seoul # Ruecktransfer des Jobprotokolls fuer diese # Maschine abgeschaltet # 31/10/02 - Siggi - berni validiert # 06/11/02 - Siggi - Neue Jobklassen auf ibmb und ibmh # 08/11/02 - Siggi - quanero validiert # 11/12/02 - Siggi - Notification fuer Transfer-Jobs abgeschaltet # 23/01/03 - Siggi - hostname nobel changed to nobela # 06/02/03 - Siggi - gregale validated # 12/02/03 - Siggi - orkan and maestro validated # 21/02/03 - Siggi - all nobel nodes in Seoul validated # 12/03/03 - Siggi - nec at DKRZ validated # 13/03/03 - Siggi - new nqs resource variable Memory # 07/04/03 - Siggi - processor request option -c on nech needs tasks per # node # 11/04/03 - Siggi - network on ibms has attribute "shared" # 31/07/03 - Siggi - nqs2 on nech implemented (provisional: -h nech2) # cxxl added to ibmh # 29/08/03 - Siggi - changes in job queues and communication system on # ibms # 24/10/03 - Siggi - using alternate hanni address 130.75.4.2 # 30/10/03 - Siggi - nech is not supported any more # 10/11/03 - Siggi - nech2 renamed to nech # 20/11/03 - Siggi - submit command on nech changed from qsub.test to qsub # 29/03/04 - Siggi - ground not supported any more, gfdl3 validated # 31/03/04 - Siggi - new option -N for node usage # 12/04/04 - Siggi - scp2 instead of scp used for transfer from decalpha # due to error in ssh installation (otherwise a prompt # for the password appears) # 23/07/04 - Siggi - changes due to the new berni configuration # (federation switch) # 01/09/04 - Gerald new job-classes on hanni # 08/09/04 - Siggi - hanni IP address changed to 130.75.4.10 # 23/11/04 - Siggi - new job class cdata on hanni and berni # 03/12/04 - Siggi - notification on ibm switched of in case of # delete_dayfile = true, node usage in cdev set to # shared # 16/02/05 - Gerald hababai validated # 29/03/05 - Micha - new job class channi on hanni # 11/05/05 - Siggi - ConsumableMemory is now required as resource keyword # on ibms # 24/05/05 - Siggi - Default queue on ibms changed from p_normal_1.3 to # p_normal # 30/06/05 - Siggi - network changed for queue cdev from "us" to "ip" # 12/07/05 - Siggi - in network.mpi on ibmh/ibmb "csss" changed to # "sn_all", new job class cexp # 08/09/05 - Siggi - IP-address of gfdl3 changed # 31/10/05 - Siggi - new job class pp on hurricane, serial jobs on # hurricane (with -X0) # 01/11/05 - Siggi - missing queue for jobs submitted on nech (for nech) # added # 30/12/05 - Siggi - change of IP adresses in subnet 130.75.105 # 09/02/06 - Siggi - ibmy admitted # 10/02/06 - Siggi - scp2 changed to /bin/scp on decalpha # 13/04/06 - Siggi - ostria admitted # 18/04/06 - Siggi - new option -O for OpenMP usage # 24/05/06 - Siggi - lctit admitted, ftpjob renamed scpjob # 25/07/06 - Siggi - gfdl5 (ibmy) admitted for submitting jobs # 27/09/06 - Siggi - breg/hreg extended with berni/hanni # 25/10/06 - Siggi - data_limit set to 1.76 GByte on hanni and berni # 28/11/06 - Siggi - levanto admitted # 13/02/07 - Siggi - hpmuk releated code removed # VARIABLENVEREINBARUNGEN + DEFAULTWERTE delete_dayfile=false filetransfer_protocol=scp locat=normal no_default_queue=none no_submit=false job_catalog="~/job_queue" job_name=none local_user=$LOGNAME node_usage=shared numprocs=1 punkte="..........................................................." submcom=qsub queue=default remote_host=none remote_user="" verify=true typeset -i cputime=0 memory=0 Memory=0 minuten resttime sekunden stunden typeset -i inumprocs nodes=0 tasks_per_node=0 threads_per_task=1 typeset -L20 spalte1 typeset -R40 spalte2 typeset -L60 spalte3 # FEHLERBEHANDLUNG # BEI EXIT: trap 'if [[ $locat != normal ]] then case $locat in (option) printf "\n --> available optios can be displayed" printf " by typing:" printf "\n \"subjob ?\" \n";; (ftpcopy|parameter|scp|verify) printf "\n";; (*) printf "\n +++ unknown error" printf "\n please inform S. Raasch!\n" esac [[ -f $job_to_send ]] && rm $job_to_send printf "\n\n+++ SUBJOB killed \n\n" fi' exit # BEI TERMINAL-BREAK: trap '[[ -f $job_to_send ]] && rm $job_to_send printf "\n\n+++ SUBJOB killed \n\n" exit ' 2 # LOKALEN HOSTNAMEN FESTSTELLEN local_host=$(hostname) # HOSTSPEZIFISCHE VARIABLEN VEREINBAREN BZW. PRUEFEN, OB LOKALER HOST # UEBERHAUPT ZULAESSIG IST case $local_host in (atmos) local_addres=172.20.25.35; local_host=lcide;; (bora) local_addres=130.75.105.103; local_host=lcmuk;; (breg*-en0|berni*-en0) local_addres=130.73.230.10; local_host=ibmb;; (cs*) local_addres=136.172.44.131; local_host=nech;; (elephanta) local_addres=130.75.105.6; local_host=lcmuk;; (gfdl5) local_addres=165.132.26.58; local_host=ibmy;; (gfdl3.yonsei.ac.kr) local_addres=165.132.26.56; local_host=decalpha;; (gregale) local_addres=130.75.105.109; local_host=lcmuk;; (hababai) local_addres=130.75.105.108; local_host=lcmuk;; (hreg*-en0|hanni*-en0) local_addres=130.75.4.10; local_host=ibmh;; (irifi) local_addres=130.75.105.104; local_host=lcmuk;; (levanto) local_addres=130.75.105.45; local_host=lcmuk;; (maestro) local_addres=130.75.105.2; local_host=lcmuk;; (nobel*) local_addres=150.183.5.101; local_host=ibms;; (orkan) local_addres=130.75.105.3; local_host=lcmuk;; (ostria) local_addres=130.75.105.106; local_host=lcmuk;; (quanero) local_addres=130.75.105.107; local_host=lcmuk;; (scirocco) local_addres=172.20.25.41; local_host=lcmuk;; (sun1|sun2) local_addres=130.75.6.1; local_host=unics;; (tgg*) local_addres=172.17.75.161; local_host=lctit;; (vorias) local_addres=172.20.25.43; local_host=lcmuk;; (*) printf "\n +++ \"$local_host\" unknown"; printf "\n please inform S. Raasch!"; locat=parameter; exit;; esac # REMOTE HOST DEFAULTMAESSIG = LOCAL HOST SETZEN remote_host=$local_host # PROZEDUROPTIONEN EINLESEN while getopts :c:dDf:h:m:n:N:O:q:t:T:u:vX: option do case $option in (c) job_catalog=$OPTARG;; (d) delete_dayfile=true;; (D) no_submit=true;; (f) filetransfer_protocol=$OPTARG;; (h) remote_host=$OPTARG;; (m) memory=$OPTARG;; (n) job_name=$OPTARG;; (N) node_usage=$OPTARG;; (O) threads_per_task=$OPTARG;; (q) no_default_queue=$OPTARG;; (t) cputime=$OPTARG;; (T) tasks_per_node=$OPTARG;; (u) remote_user=$OPTARG;; (v) verify=false;; (X) numprocs=$OPTARG;; (\?) printf "\n +++ Option $OPTARG unknown \n"; locat=option; exit;; esac done # JOBDATEINAMEN ALS NAECHSTES ARGUMENT HOLEN shift OPTIND-1; file_to_send=$1 # KURZE AUFRUFBESCHREIBUNG WIRD HIER AUSGEGEBEN if [ "$1" = "?" ] then (printf "\n *** subjob can be called as follows:\n" printf "\n subjob -c.. -d -D -h.. -m.. -q.. -t.. -u.. -v \n" printf "\n Description of available options:\n" printf "\n Option Description Default-Value" printf "\n -c job-input- and output-catalog ~/job_queue" printf "\n -d no job-protocol will be created ---" printf "\n -D only the job-file will be created ---" printf "\n -f filetransfer protocol scp" printf "\n -h execution host, available hosts: $remote_host" printf "\n ibm, ibmb, ibmh, ibms, ibmy, lcmuk," printf "\n unics" printf "\n -m memory demand per process in MByte ---" printf "\n -n jobname " printf "\n -O threads per task (for OpenMP usage) 1" printf "\n -q job-queue to be used default" printf "\n -t allowed cpu-time in seconds ---" printf "\n -T tasks per node (on parallel hosts) ---" printf "\n -u username on execution host from .netrc" printf "\n -v no prompt for confirmation ---" printf "\n -X # of processors (on parallel hosts) 1" printf "\n " printf "\n The only possible positional parameter is :" printf "\n The complete NQS-job must be provided here." printf "\n =? creates this outline\n\n") | more exit fi # PRUEFEN, OB JOBDATEI ANGEGEBEN WURDE UND OB SIE AUCH EXISTIERT if [[ "$file_to_send" = "" ]] then printf "\n +++ job-file missing" locat=parameter; exit else if [[ -f $file_to_send ]] then true else printf "\n +++ job-file: " printf "\n $file_to_send" printf "\n does not exist" locat=parameter; exit fi fi # FALLS KEIN JOBNAME ANGEGEBEN WURDE, WIRD JOBNAME = JOBDATEINAME # GESETZT. VORAUSSETZUNG: JOBDATEINAME BEINHALTET KEINE PFADE if [[ $job_name = none ]] then job_name=$file_to_send fi if [[ $(echo $job_name | grep -c "/") != 0 ]] then printf "\n +++ job-file name: " printf "\n $job_name" printf "\n must not contain \"/\"-characters" locat=parameter; exit fi # HOSTSPEZIFISCHE GROESSEN VEREINBAREN BZW. ABBRUCH BEI UNZULAESSIGEM HOST # ODER WENN HOST NICHT ANGEGEBEN WURDE if [[ $remote_host = none ]] then printf "\n +++ host missing" locat=option; exit else case $remote_host in (ibm) queue=p690_standard; remote_addres=134.76.99.81; submcom=/usr/lpp/LoadL/full/bin/llsubmit;; (ibmb) queue=cpar; remote_addres=130.73.230.10; submcom=/usr/lpp/LoadL/full/bin/llsubmit;; (ibmh) queue=cpar; remote_addres=130.75.4.10; submcom=/usr/lpp/LoadL/full/bin/llsubmit;; (ibms) queue=p_normal; remote_addres=150.183.5.101; submcom=/usr/lpp/LoadL/full/bin/llsubmit;; (ibmy) queue=parallel; remote_addres=165.132.26.58; submcom=/usr/lpp/LoadL/full/bin/llsubmit;; (lctit) queue=test; remote_addres=172.17.75.161; submcom=/n1ge/TITECH_GRID/tools/bin/n1ge;; (nech) qsubmem=memsz_job; qsubtime=cputim_job; remote_addres=136.172.44.147; submcom="/usr/local/bin/qsub";; (vpp) qsubmem=m; qsubtime=t; queue=vpp; remote_addres=130.75.4.130;; (unics) qsubmem=d; qsubtime=t; queue=unics; remote_addres=130.75.6.1;; (*) printf "\n +++ hostname \"$remote_host\" not allowed"; locat=parameter; exit;; esac fi # EVTL. PRUEFEN, OB ANGEGEBENE QUEUE ZULAESSIG IST if [[ $no_default_queue != none ]] then error=false ndq=$no_default_queue case $remote_host in (ibm) case $ndq in (p690_express|p690_standard|p690_long) error=false;; (*) error=true;; esac;; (ibmb) case $ndq in (cdata|cdev|cexp|c1|cshare|csolo|cspec) error=false;; (*) error=true;; esac;; (ibmh) case $ndq in (cdata|cdev|cexp|channi|cxxl|c1|cshare|csolo|cspec) error=false;; (*) error=true;; esac;; (ibms) case $ndq in (express|normal|p_express|p_normal|p_normal_1.3|p_normal_1.7|grand) error=false;; (*) error=true;; esac;; (ibmy) case $ndq in (parallel) error=false;; (*) error=true;; esac;; (lctit) case $ndq in (cs|default|high|test) error=false;; (*) error=true;; esac;; (t3eb) case $ndq in (berte|p50|p100|p392|forfree|p25himem) error=false;; (*) error=true;; esac;; (t3eh) case $ndq in (para_t3e|em|k|l|lm|comp_t3e|c|p|ht) error=false;; (*) error=true;; esac;; (t3ej2|t3ej5) case $ndq in (low|normal|high) error=false;; (*) error=true;; esac;; (t3es) case $ndq in (batch|serial-4|pe4|p48|pe16|pe32|pe64|pe128) error=false;; (*) error=true;; esac;; (unics) case $ndq in (unics|ht) error=false;; (*) error=true;; esac;; esac if [[ $error = true ]] then printf "\n +++ queue \"$no_default_queue\" on host \"$remote_host\" not allowed" locat=parameter; exit else queue=$no_default_queue fi fi # KNOTENNUTZUNG IN ENTWICKLERQUEUE MUSS SHARED SEIN if [[ $node_usage != shared && $queue = cdev ]] then node_usage=shared fi # PRUEFEN DER CPU-ZEIT, ZEIT NACH STUNDEN, MINUTEN UND SEKUNDEN # AUFTEILEN done=false while [[ $done = false ]] do if (( $cputime <= 0 )) then printf "\n +++ wrong cpu-time or cpu-time missing" printf "\n >>> Please type cpu-time in seconds as INTEGER:" printf "\n >>> " read cputime 1>/dev/null 2>&1 else done=true fi done if [[ $remote_host = nech ]] then if (( tasks_per_node != 0 )) then (( cputime = cputime * tasks_per_node )) elif [[ $numprocs != 0 ]] then (( cputime = cputime * numprocs )) fi fi (( stunden = cputime / 3600 )) (( resttime = cputime - stunden * 3600 )) (( minuten = resttime / 60 )) (( sekunden = resttime - minuten * 60 )) timestring=${stunden}:${minuten}:${sekunden} # PRUEFEN DER KERNSPEICHERANFORDERUNG done=false while [[ $done = false ]] do if (( memory <= 0 )) then printf "\n +++ wrong memory demand or memory demand missing" printf "\n >>> Please type memory in MByte per process as INTEGER:" printf "\n >>> " read memory 1>/dev/null 2>&1 else done=true fi done if [[ $remote_host = nech ]] then if (( tasks_per_node != 0 )) then (( Memory = memory * tasks_per_node / 1000 )) elif [[ $numprocs != 0 ]] then (( Memory = memory * numprocs / 1000 )) else (( Memory = memory / 1000 )) fi fi # SPEICHERBERECHNUNG BEI OPENMP-NUTZUNG if [[ $(echo $remote_host | cut -c1-3) = ibm ]] then (( memory = memory * threads_per_task )) fi # BERECHNUNG DER ANZAHL DER ZU VERWENDENDEN KNOTEN if (( tasks_per_node != 0 )) then (( nodes = numprocs / ( tasks_per_node * threads_per_task ) )) fi # HEADER-AUSGABE if [[ $verify = true ]] then printf "\n\n" printf "#--------------------------------------------------------------# \n" spalte1=SUBJOB;spalte2=$(date) printf "| $spalte1$spalte2 | \n" printf "| | \n" printf "| values of parameters/options: | \n" spalte1=local_host$punkte; spalte2=$punkte$local_host printf "| $spalte1$spalte2 | \n" spalte1=remote_host$punkte; spalte2=$punkte$remote_host printf "| $spalte1$spalte2 | \n" spalte1=queue$punkte; spalte2=$punkte$queue printf "| $spalte1$spalte2 | \n" spalte1=memory$punkte; spalte2="$punkte$memory mb" printf "| $spalte1$spalte2 | \n" spalte1=cputime$punkte; spalte2="$punkte$cputime sec" printf "| $spalte1$spalte2 | \n" spalte1=job_name$punkte; spalte2="$punkte$job_name" printf "| $spalte1$spalte2 | \n" printf "#--------------------------------------------------------------# \n\n" # KONTROLLABFRAGE, OB ALLES O.K. antwort="dummy" while [[ $antwort != y && $antwort != Y && $antwort != n && $antwort != N ]] do read antwort?" >>> continue (y/n) ? " done if [[ $antwort = n || $antwort = N ]] then locat=verify; exit fi printf "\n" fi # ZUFALLSKENNUNG GENERIEREN UND JOBNAMEN AUF ZIELRECHNER BESTIMMEN kennung=$RANDOM job_on_remhost=${job_name}_${kennung}_$local_host job_to_send=job_to_send_$kennung if [[ $delete_dayfile = false ]] then remote_dayfile=${local_host}_${job_name}_result_$kennung local_dayfile=${remote_host}_${job_name} else remote_dayfile=/dev/null if [[ $(echo $remote_host | cut -c1-3) = ibm ]] then notification='# @ notification = never' fi fi # QSUB- ODER LL-KOMMANDOS BZW. SKRIPTE GENERIEREN if [[ $(echo $remote_host | cut -c1-3) = ibm && $numprocs != 0 ]] then if [[ $remote_host = ibmy ]] then consumable_memory="" else consumable_memory="ConsumableMemory($memory mb)" fi if [[ $queue = cdev ]] then data_limit="# @ data_limit = 1.76gb" network_to_use="# @ network.mpi = sn_all,shared,ip" else if [[ $remote_host = ibms ]] then network_to_use="# @ network.mpi = csss,shared,us" elif [[ $remote_host = ibmy ]] then network_to_use="" else network_to_use="# @ network.mpi = sn_all,shared,us" data_limit="# @ data_limit = 1.76gb" fi fi cat > $job_to_send << %%END%% #!/bin/ksh # @ job_type = parallel # @ job_name = palm # @ wall_clock_limit = ${timestring},$timestring # @ resources = ConsumableCpus($threads_per_task) $consumable_memory # @ output = $remote_dayfile # @ error = $remote_dayfile # @ image_size = 50 # @ class = $queue # @ environment = OMP_NUM_THREADS=$threads_per_task; MP_SHARED_MEMORY=yes $network_to_use $data_limit $notification %%END%% if (( nodes > 0 )) then cat >> $job_to_send << %%END%% # @ node = $nodes # @ tasks_per_node = $tasks_per_node # @ node_usage = $node_usage # @ queue %%END%% else if [[ $remote_host != ibmy ]] then cat >> $job_to_send << %%END%% # @ blocking = unlimited # @ total_tasks = $numprocs # @ node_usage = $node_usage # @ queue %%END%% else cat >> $job_to_send << %%END%% # @ node = 1 # @ total_tasks = $numprocs # @ queue %%END%% fi fi elif [[ $(echo $remote_host | cut -c1-3) = ibm && $numprocs = 0 ]] then cat > $job_to_send << %%END%% #!/bin/ksh # @ job_type = serial # @ node_usage = $node_usage # @ job_name = palm # @ wall_clock_limit = ${timestring},$timestring # @ resources = ConsumableCpus(1) ConsumableMemory(1 gb) # @ output = $remote_dayfile # @ error = $remote_dayfile # @ class = $queue $notification # @ queue %%END%% elif [[ $remote_host = nech ]] then if (( nodes > 1 )) then cat > $job_to_send << %%END%% #!/bin/ksh #PBS -l cpunum_prc=$tasks_per_node,cputim_job=$cputime #PBS -l ${qsubmem}=${Memory}gb #PBS -b $nodes #PBS -o $remote_dayfile #PBS -N palm #PBS -j o #PBS -T mpisx %%END%% elif [[ $numprocs != 0 ]] then cat > $job_to_send << %%END%% #!/bin/ksh #PBS -l cpunum_prc=$tasks_per_node,cputim_job=$cputime #PBS -l ${qsubmem}=${Memory}gb #PBS -o $remote_dayfile #PBS -N palm #PBS -j o %%END%% else cat > $job_to_send << %%END%% #!/bin/ksh #PBS -l ${qsubmem}=${Memory}gb,${qsubtime}=$cputime #PBS -o $remote_dayfile #PBS -j o %%END%% fi elif [[ $remote_host = lctit ]] then cat > $job_to_send << %%END%% #!/bin/bash #$ -S /bin/bash cd $job_catalog PATH=$job_catalog:${job_catalog}/../pub:\$PATH export PATH %%END%% # OPTIONEN FUER SUBMIT-KOMMANDO ZUSAMMENSTELLEN submcom="$submcom -N $job_name -sgeout $remote_dayfile -q default" else cat > $job_to_send << %%END%% # @\$-q ${queue} # @\$-l${qsubtime} $timestring # @\$-l${qsubmem} ${memory}mb # @\$-o $remote_dayfile # @\$-eo %%END%% fi # BEI RECHNUNG AUF REMOTE-MASCHINEN RUECKTRANSFER DES DAYFILES PER TRAP # BEI EXIT VERANLASSEN # VEKTORRECHNER MUSS EIGENEN JOB STARTEN, DA DORT NOHUP NICHT FUNKTIONIERT # AUF IBM IN SEOUL IST RUECKTRANSFER ZUR ZEIT GENERELL NICHT MOEGLICH if [[ $delete_dayfile = false && $remote_host != $local_host ]] then echo "set +vx" >> $job_to_send echo "trap '" >> $job_to_send echo "set +vx" >> $job_to_send if [[ $(echo $remote_host | cut -c1-3) = ibm || $remote_host = nech || $remote_host = lctit ]] then if [[ $remote_host = ibmb || $remote_host = ibmh ]] then return_queue=c1 elif [[ $remote_host = ibms ]] then return_queue=p_normal elif [[ $remote_host = ibmy ]] then return_queue=serial elif [[ $remote_host = lctit ]] then return_queue=default elif [[ $remote_host = t3eb ]] then return_queue=berte elif [[ $remote_host = t3ej2 || $remote_host = t3ej5 ]] then return_queue=normal elif [[ $remote_host = t3es ]] then return_queue=batch else return_queue=unknown fi if [[ $(echo $remote_host | cut -c1-3) = ibm ]] then echo "echo \"#!/bin/ksh\" >> scpjob.$kennung" >> $job_to_send echo "echo \"# @ job_type = serial\" >> scpjob.$kennung" >> $job_to_send echo "echo \"# @ job_name = transfer\" >> scpjob.$kennung" >> $job_to_send echo "echo \"# @ resources = ConsumableCpus(1) ConsumableMemory(1 gb)\" >> scpjob.$kennung" >> $job_to_send echo "echo \"# @ wall_clock_limit = 00:10:00,00:10:00\" >> scpjob.$kennung " >> $job_to_send echo "echo \"# @ output = job_queue/last_job_transfer_protocol\" >> scpjob.$kennung" >> $job_to_send echo "echo \"# @ error = job_queue/last_job_transfer_protocol\" >> scpjob.$kennung" >> $job_to_send echo "echo \"# @ class = $return_queue\" >> scpjob.$kennung" >> $job_to_send echo "echo \"# @ image_size = 10\" >> scpjob.$kennung" >> $job_to_send echo "echo \"# @ notification = never\" >> scpjob.$kennung" >> $job_to_send echo "echo \"# @ queue\" >> scpjob.$kennung" >> $job_to_send echo "echo \" \" >> scpjob.$kennung" >> $job_to_send echo "echo \"set -x\" >> scpjob.$kennung" >> $job_to_send echo "echo \"batch_scp -d -w 10 -u $local_user $local_addres ${job_catalog}/$remote_dayfile \\\"$job_catalog\\\" $local_dayfile\" >> scpjob.$kennung" >> $job_to_send echo "echo \"exit\" >> scpjob.$kennung" >> $job_to_send elif [[ $remote_host = nech ]] then echo "cd /pf/b/${remote_user}/job_queue" >> $job_to_send echo "cat > scpjob.$kennung << %%END%%" >> $job_to_send echo "#PBS -l ${qsubmem}=1GB,${qsubtime}=100" >> $job_to_send echo "#PBS -o last_job_transfer_protocol" >> $job_to_send echo "#PBS -j o" >> $job_to_send echo " " >> $job_to_send echo "set -x" >> $job_to_send echo "cd /pf/b/${remote_user}/job_queue" >> $job_to_send echo "batch_scp -d -w 10 -u $local_user $local_addres $remote_dayfile \"$job_catalog\" $local_dayfile" >> $job_to_send echo "[[ \"\$for_subjob_to_do\" != \"\" ]] && eval \$for_subjob_to_do" >> $job_to_send echo "%%END%%" >> $job_to_send elif [[ $remote_host = lctit ]] then echo "cat > scpjob.$kennung << %%END%%" >> $job_to_send echo "set -x" >> $job_to_send echo "PATH=\$PATH:$job_catalog/../pub" >> $job_to_send echo "cd $job_catalog" >> $job_to_send echo "batch_scp -d -w 10 -u $local_user $local_addres $remote_dayfile \"$job_catalog\" $local_dayfile" >> $job_to_send echo "[[ \"\$for_subjob_to_do\" != \"\" ]] && eval \$for_subjob_to_do" >> $job_to_send echo "%%END%%" >> $job_to_send else echo "cat > scpjob.$kennung << %%END%%" >> $job_to_send echo "# @\\\$-q $return_queue" >> $job_to_send echo "# @\\\$-l${qsubtime} 10" >> $job_to_send echo "# @\\\$-l${qsubmem} 10mb" >> $job_to_send if [[ $remote_host = t3ej2 || $remote_host = t3ej5 || $remote_host = t3es ]] then echo "# @\$-l mpp_p=0" >> $job_to_send fi echo '# @\$-lF 10mb' >> $job_to_send # echo '# @\$-o /dev/null' >> $job_to_send echo '# @\$-o job_queue/last_job_transfer_protocol' >> $job_to_send echo '# @\\\$-eo' >> $job_to_send echo " " >> $job_to_send if [[ $remote_host = t3ej2 || $remote_host = t3ej5 ]] then echo "set +vx" >> $job_to_send echo ". .profile" >> $job_to_send fi echo "set -x" >> $job_to_send echo "batch_scp -d -w 10 -u $local_user $local_addres ${job_catalog}/$remote_dayfile \"$job_catalog\" $local_dayfile > /dev/null" >> $job_to_send echo "[[ \"\$for_subjob_to_do\" != \"\" ]] && eval \$for_subjob_to_do" >> $job_to_send echo "%%END%%" >> $job_to_send fi if [[ $(echo $remote_host | cut -c1-3) = ibm ]] then echo "llsubmit scpjob.$kennung" >> $job_to_send elif [[ $remote_host = lctit ]] then echo "chmod u+x scpjob.$kennung" >> $job_to_send echo "rm -rf ${job_catalog}/last_job_transfer_protocol" >> $job_to_send echo "n1ge -N jobtransfer -q $return_queue -sgeout ${job_catalog}/last_job_transfer_protocol scpjob.$kennung" >> $job_to_send echo "sleep 10" >> $job_to_send elif [[ $remote_host = t3eb || $remote_host = t3eh || $remote_host = t3ej2 || $remote_host = t3ej5 ]] then echo "qsub -J n scpjob.$kennung" >> $job_to_send elif [[ $remote_host = t3es ]] then echo "qsub -J n -s /bin/ksh scpjob.$kennung" >> $job_to_send else echo "qsub scpjob.$kennung" >> $job_to_send fi echo "rm scpjob.$kennung" >> $job_to_send if [[ $remote_host = nech ]] then echo "cd -" >> $job_to_send fi else # echo "ftpcopy -d $local_addres ${job_catalog}/$remote_dayfile \"$job_catalog\" $local_dayfile" >> $job_to_send echo "nohup ftpcopy -d -w 15 $local_addres ${job_catalog}/$remote_dayfile \"$job_catalog\" $local_dayfile > /dev/null &" >> $job_to_send fi echo "set -x" >> $job_to_send echo " ' exit" >> $job_to_send echo "set -x" >> $job_to_send fi # EIGENTLICHE JOB-DATEI AN QSUB-KOMMANDOS ANHAENGEN cat $file_to_send >> $job_to_send if [[ $remote_host = ibm ]] then echo " " >> $job_to_send echo "exit" >> $job_to_send fi # USER-NAME AUF ZIELRECHNER AUS .NETRC-DATEI ERMITTELN if [[ -z $remote_user ]] then if [[ $remote_host = t3eb || $remote_host = t3eh || $remote_host = t3ej2 || $remote_host = t3ej5 || $remote_host = t3es || $remote_host = vpp ]] then grep $remote_addres ~/.netrc | read dum dum dum remote_user dum dum fi fi # JOB AUF ZIELRECHNER TRANSFERIEREN BZW. INS JOBVERZEICHNIS KOPIEREN if [[ $no_submit = false ]] then if [[ $remote_host != $local_host ]] then [[ $verify = true ]] && printf "\n >>> transfering job to \"$remote_host\"..." if [[ $filetransfer_protocol = scp ]] then if [[ $remote_host = ibms || $remote_host = ibmy ]] # ssh on ibms cannot handle "~/" then job_catalog_save=$job_catalog job_catalog=job_queue elif [[ $remote_host = nech ]] then job_catalog_save=$job_catalog job_catalog=/hpf/b/${remote_user}/job_queue fi if [[ $local_host = decalpha ]] then # VERWENDUNG VON SCP AUF DECALPHA FRAGT FEHLERHAFTERWEISE # PASSWORT AB /bin/scp $job_to_send ${remote_user}@${remote_addres}:${job_catalog}/$job_on_remhost elif [[ $remote_host = nech ]] then # DATEIEN KOENNEN NUR UEBER DEN ARCHIVE-SERVER DES DKRZ # TRANSFERIERT WERDEN scp $job_to_send ${remote_user}@136.172.44.205:${job_catalog}/$job_on_remhost else scp $job_to_send ${remote_user}@${remote_addres}:${job_catalog}/$job_on_remhost fi if [[ $? = 1 ]] then locat=scp; exit fi if [[ $remote_host = ibms ]] then job_catalog=$job_catalog_save fi else ftpcopy -s -o $remote_addres $job_to_send "$job_catalog" $job_on_remhost if [[ $? = 1 ]] then locat=ftpcopy; exit fi fi [[ $verify = true ]] && printf "\n >>> finished\n" else eval job_catalog=$job_catalog cp $job_to_send ${job_catalog}/$job_on_remhost fi # NQS- BZW. LOADLEVELER-JOB STARTEN if [[ $remote_host != $local_host ]] then [[ $verify = true ]] && printf "\n >>> submitting job using \"qsub\"...\n" if [[ $filetransfer_protocol = scp ]] then if [[ $remote_host != lctit ]] then ssh $remote_addres -l $remote_user "cd $job_catalog; $submcom $job_on_remhost; rm $job_on_remhost" else # TIT ERLAUBT NUR DIE AUSFÜHRUNG GANZ BESTIMMTER KOMMANDOS # MIT SSH, DESHALB AUFRUF PER PIPE # UEBERGANGSWEISE CHECK, OB N1GE ENVIRONMENT WIRKLICH VERFUEGBAR print "cd $job_catalog; chmod u+x $job_on_remhost" | ssh $remote_addres -l $remote_user > /dev/null 2>&1 echo "first try" > send_protocol while [[ $(cat send_protocol | grep -c "Forwarding to N1GE") = 0 ]] do if [[ $(cat send_protocol | grep -c "first try") = 1 ]] then printf "\n trying to submit job to TIT cluster..." else printf "\n +++ failed ... trying to submit again ..." fi print "cd $job_catalog; $submcom $job_on_remhost" | ssh $remote_addres -l $remote_user > send_protocol 2>&1 cat send_protocol done sleep 10 print "cd $job_catalog; rm $job_on_remhost" | ssh $remote_addres -l $remote_user > /dev/null 2>&1 echo "$submcom $job_on_remhost" rm send_protocol fi else if [[ $remote_host = ibms ]] then password=`cat ~/.netrc | grep $remote_addres | awk '{print $6}'` echo "echo \"$remote_user\" " > telnet_script echo "sleep 5" >> telnet_script echo "echo \"$password\" " >> telnet_script echo "sleep 10" >> telnet_script echo "echo \"\" " >> telnet_script echo "sleep 2" >> telnet_script echo "echo \"cd $job_catalog; $submcom $job_on_remhost; rm -rf $job_on_remhost\" " >> telnet_script echo "sleep 10" >> telnet_script echo "echo \"exit\" " >> telnet_script chmod u+x telnet_script telnet_script | telnet $remote_addres 2>&1 | grep "llsubmit:" rm telnet_script elif [[ $remote_host = t3es ]] then password=`cat ~/.netrc | grep $remote_addres | awk '{print $6}'` echo "printf \"$remote_user\\\n\" " > telnet_script echo "sleep 10" >> telnet_script echo "printf \"$password\\\n\" " >> telnet_script echo "sleep 10" >> telnet_script echo "printf \"\\\n\" " >> telnet_script echo "sleep 5" >> telnet_script echo "printf \"\\\n\" " >> telnet_script echo "sleep 5" >> telnet_script echo "printf \"cd $job_catalog; $submcom $job_on_remhost; rm -f $job_on_remhost\\\n\" " >> telnet_script echo "sleep 10" >> telnet_script echo "printf \"exit\\\n\" " >> telnet_script chmod u+x telnet_script cat telnet_script telnet_script | telnet $remote_addres | grep $remote_user rm telnet_script else remcom.x $remote_addres "cd $job_catalog; $submcom $job_on_remhost; rm $job_on_remhost" fi fi [[ $verify = true ]] && printf " >>> o.k.\n" else cd $job_catalog if [[ $(echo $local_host | cut -c1-3) = ibm ]] then eval $submcom $job_on_remhost elif [[ $local_host = lctit ]] then eval $submcom $job_on_remhost echo "$submcom $job_on_remhost" chmod u+x $job_on_remhost sleep 5 # WEIL N1GE IM HINTERGRUND ARBEITET UND DATEI SONST EVTL. # SCHON WIEDER GELOESCT IST elif [[ $local_host = nech ]] then if [[ $queue = default ]] then eval $submcom $job_on_remhost else eval $submcom -q $queue $job_on_remhost fi else qsub $job_on_remhost fi rm $job_on_remhost cd - > /dev/null fi fi # ABSCHLUSSARBEITEN if [[ $no_submit = false ]] then rm $job_to_send fi [[ $verify = true ]] && printf "\n\n *** SUBJOB finished \n\n"