From: Jiří Filipovič Date: Fri, 25 Feb 2011 13:30:55 +0000 (+0000) Subject: test sandbox collections X-Git-Tag: glite-lb-client-java_R_1_1_1_1~25 X-Git-Url: http://scientific.zcu.cz/git/?a=commitdiff_plain;h=33624fc1c35c10511fb6826490d37a040b3effb0;p=jra1mw.git test sandbox collections --- diff --git a/org.glite.testsuites.ctb/LB/tests/lb-test-sandbox-transfer.sh b/org.glite.testsuites.ctb/LB/tests/lb-test-sandbox-transfer.sh index 63cc07d..40fb58c 100755 --- a/org.glite.testsuites.ctb/LB/tests/lb-test-sandbox-transfer.sh +++ b/org.glite.testsuites.ctb/LB/tests/lb-test-sandbox-transfer.sh @@ -308,8 +308,335 @@ else fi - - + #******************************* Test sandbox collection ********************************* + + # Register job: + printf "Registering testing job " + + ${LBJOBREG} -m ${GLITE_WMS_QUERY_SERVER} -s application > sbtestjob.$$.out + + jobid=`$SYS_CAT sbtestjob.$$.out | $SYS_GREP "new jobid" | ${SYS_AWK} '{ print $3 }'` + seqcode=`$SYS_CAT sbtestjob.$$.out | $SYS_GREP "EDG_WL_SEQUENCE" | ${SYS_SED} 's/EDG_WL_SEQUENCE=//' | ${SYS_SED} 's/"//g'` + + $SYS_RM sbtestjob.$$.out + + if [ -z $jobid ]; then + test_failed + print_error "Failed to register job" + else + test_done + + # register sandbox collection + + printf "Registering input SandBox collection... " + + $LBREGSANDBOX --jobid $jobid --input --from http://users.machine/path/to/sandbox.file --to file://where/it/is/sandbox.file --sequence $seqcode -n 2 > sbtestjob.$$.out + + isbjobid=`$SYS_CAT sbtestjob.$$.out | $SYS_GREP "GLITE_LB_ISB_JOBID" | ${SYS_SED} 's/GLITE_LB_ISB_JOBID=//' | ${SYS_SED} 's/"//g'` + isbseqcode=`$SYS_CAT sbtestjob.$$.out | $SYS_GREP "GLITE_LB_ISB_SEQUENCE" | ${SYS_SED} 's/GLITE_LB_ISB_SEQUENCE=//' | ${SYS_SED} 's/"//g'` + seqcode=`$SYS_CAT sbtestjob.$$.out | $SYS_GREP "GLITE_WMS_SEQUENCE_CODE" | ${SYS_SED} 's/GLITE_WMS_SEQUENCE_CODE=//' | ${SYS_SED} 's/"//g'` + isbsubjobid0=`$SYS_CAT sbtestjob.$$.out | $SYS_GREP "EDG_WL_SUB_JOBID\[0\]" | ${SYS_SED} 's/EDG_WL_SUB_JOBID\[0\]=//' | ${SYS_SED} 's/"//g'` + isbsubjobid1=`$SYS_CAT sbtestjob.$$.out | $SYS_GREP "EDG_WL_SUB_JOBID\[1\]" | ${SYS_SED} 's/EDG_WL_SUB_JOBID\[1\]=//' | ${SYS_SED} 's/"//g'` + + printf "Subjobs: " $isbsubjobid0 $isbsubjobid1 + + $SYS_RM sbtestjob.$$.out + + if [ -z $isbjobid ]; then + test_failed + print_error "Failed to register job" + else + printf "$isbjobid" + test_done + + # Check relations + + printf "Check ISB transfer JobID for computing job... " + isbjobidreported=`$LBJOBSTATUS $jobid | $SYS_GREP -m 1 "isb_transfer :" | ${SYS_AWK} '{print $3}'` + printf "$isbjobidreported" + + if [ "$isbjobidreported" = "$isbjobid" ]; then + test_done + else + test_failed + print_error "Not returned or no match" + fi + + printf "Check computing Job ID for ISB... " + jobidreported=`$LBJOBSTATUS $isbjobid | $SYS_GREP -m 1 "ft_compute_job :" | ${SYS_AWK} '{print $3}'` + printf "$jobidreported" + + if [ "$jobidreported" = "$jobid" ]; then + test_done + else + test_failed + print_error "Not returned or no match" + fi + + printf "Check computing Job ID for subjob 0... " + jobidreported=`$LBJOBSTATUS $isbsubjobid0 | $SYS_GREP "ft_compute_job :" | ${SYS_AWK} '{print $3}'` + printf "$jobidreported" + + if [ "$jobidreported" = "$jobid" ]; then + test_done + else + test_failed + print_error "Not returned or no match" + fi + + printf "Check transfer Job ID for subjob 0... " + jobidreported=`$LBJOBSTATUS $isbsubjobid0 | $SYS_GREP "parent_job :" | ${SYS_AWK} '{print $3}'` + printf "$jobidreported" + + if [ "$jobidreported" = "$isbjobid" ]; then + test_done + else + test_failed + print_error "Not returned or no match" + fi + + + # Check states + + isbjobstate=`$LBJOBSTATUS $isbjobid | $SYS_GREP -m 1 "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbjobid... $isbjobstate" + + if [ "${isbjobstate}" = "Submitted" ]; then + test_done + else + test_failed + print_error "'Submitted' was expected" + fi + + isbjobstate=`$LBJOBSTATUS $isbsubjobid0 | $SYS_GREP "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbsubjobid0... $isbjobstate" + + if [ "${isbjobstate}" = "Submitted" ]; then + test_done + else + test_failed + print_error "'Submitted' was expected" + fi + + isbjobstate=`$LBJOBSTATUS $isbsubjobid1 | $SYS_GREP "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbsubjobid1... $isbjobstate" + + if [ "${isbjobstate}" = "Submitted" ]; then + test_done + else + test_failed + print_error "'Submitted' was expected" + fi + + # log START for subjob 1 + printf "Subjob 1 transfer starting... " + isbseqcode=`$LBLOGEVENT --source LRMS --jobid $isbsubjobid1 --sequence $osbseqcode --event FileTransfer --result START` + + if [ -z $isbseqcode ]; then + test_failed + print_error "LogEvent failed" + else + test_done + fi + + # Check states + sleep 10 + + isbjobstate=`$LBJOBSTATUS $isbjobid | $SYS_GREP -m 1 "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbjobid... $isbjobstate" + + if [ "${isbjobstate}" = "Running" ]; then + test_done + else + test_failed + print_error "'Running' was expected" + fi + + isbjobstate=`$LBJOBSTATUS $isbsubjobid1 | $SYS_GREP "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbsubjobid1... $isbjobstate" + + if [ "${isbjobstate}" = "Running" ]; then + test_done + else + test_failed + print_error "'Running' was expected" + fi + + # log OK for subjob 1 + printf "Subjob 1 transfer ending... " + isbseqcode=`$LBLOGEVENT --source LRMS --jobid $isbsubjobid1 --sequence $osbseqcode --event FileTransfer --result OK` + + if [ -z $isbseqcode ]; then + test_failed + print_error "LogEvent failed" + else + test_done + fi + + # Check states + sleep 10 + + isbjobstate=`$LBJOBSTATUS $isbjobid | $SYS_GREP -m 1 "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbjobid... $isbjobstate" + + if [ "${isbjobstate}" = "Waiting" ]; then + test_done + else + test_failed + print_error "'Waiting' was expected" + fi + + isbjobstate=`$LBJOBSTATUS $isbsubjobid1 | $SYS_GREP "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbsubjobid1... $isbjobstate" + + if [ "${isbjobstate}" = "Done" ]; then + test_done + else + test_failed + print_error "'Done' was expected" + fi + + isbjobstate=`$LBJOBSTATUS $isbsubjobid1 | $SYS_GREP "done_code :" | ${SYS_AWK} '{print $3}'` + printf "Checking Done Code... $isbjobstate" + + if [ "${isbjobstate}" = "DONE_CODE_OK" ]; then + test_done + else + test_failed + print_error "'DONE_CODE_OK' was expected" + fi + + # log START for subjob 0 + printf "Subjob 0 transfer starting... " + isbseqcode=`$LBLOGEVENT --source LRMS --jobid $isbsubjobid0 --sequence $osbseqcode --event FileTransfer --result START` + + if [ -z $isbseqcode ]; then + test_failed + print_error "LogEvent failed" + else + test_done + fi + + # Check states + sleep 10 + + isbjobstate=`$LBJOBSTATUS $isbjobid | $SYS_GREP -m 1 "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbjobid... $isbjobstate" + + if [ "${isbjobstate}" = "Running" ]; then + test_done + else + test_failed + print_error "'Running' was expected" + fi + + isbjobstate=`$LBJOBSTATUS $isbsubjobid0 | $SYS_GREP "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbsubjobid0... $isbjobstate" + + if [ "${isbjobstate}" = "Running" ]; then + test_done + else + test_failed + print_error "'Running' was expected" + fi + + # log FAIL for subjob 0 + printf "Subjob 0 transfer ending... " + isbseqcode=`$LBLOGEVENT --source LRMS --jobid $isbsubjobid0 --sequence $osbseqcode --event FileTransfer --result FAIL` + + if [ -z $isbseqcode ]; then + test_failed + print_error "LogEvent failed" + else + test_done + fi + + # Check states + sleep 10 + + isbjobstate=`$LBJOBSTATUS $isbjobid | $SYS_GREP -m 1 "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbjobid... $isbjobstate" + + if [ "${isbjobstate}" = "Waiting" ]; then + test_done + else + test_failed + print_error "'Waiting' was expected" + fi + + isbjobstate=`$LBJOBSTATUS $isbsubjobid0 | $SYS_GREP "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbsubjobid0... $isbjobstate" + + if [ "${isbjobstate}" = "Done" ]; then + test_done + else + test_failed + print_error "'Done' was expected" + fi + + isbjobstate=`$LBJOBSTATUS $isbsubjobid0 | $SYS_GREP "done_code :" | ${SYS_AWK} '{print $3}'` + printf "Checking Done Code... $isbjobstate" + + if [ "${isbjobstate}" = "DONE_CODE_FAILED" ]; then + test_done + else + test_failed + print_error "'DONE_CODE_FAILED' was expected" + fi + + # START and OK subjob 0 + + printf "Subjob 0 starting and ending..." + isbseqcode=`$LBLOGEVENT --source LRMS --jobid $isbsubjobid0 --sequence $osbseqcode --event FileTransfer --result START` + isbseqcode=`$LBLOGEVENT --source LRMS --jobid $isbsubjobid0 --sequence $osbseqcode --event FileTransfer --result OK` + + # Check states + sleep 10 + + isbjobstate=`$LBJOBSTATUS $isbjobid | $SYS_GREP -m 1 "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbjobid... $isbjobstate" + + if [ "${isbjobstate}" = "Done" ]; then + test_done + else + test_failed + print_error "'Done' was expected" + fi + + isbjobstate=`$LBJOBSTATUS $isbjobid | $SYS_GREP -m 1 "done_code :" | ${SYS_AWK} '{print $3}'` + printf "Checking Done Code... $isbjobstate" + + if [ "${isbjobstate}" = "DONE_CODE_OK" ]; then + test_done + else + test_failed + print_error "'DONE_CODE_OK' was expected" + fi + + isbjobstate=`$LBJOBSTATUS $isbsubjobid0 | $SYS_GREP "state :" | ${SYS_AWK} '{print $3}'` + printf "Checking state of $isbsubjobid... $isbjobstate" + + if [ "${isbjobstate}" = "Done" ]; then + test_done + else + test_failed + print_error "'Done' was expected" + fi + + isbjobstate=`$LBJOBSTATUS $isbsubjobid0 | $SYS_GREP "done_code :" | ${SYS_AWK} '{print $3}'` + printf "Checking Done Code... $isbjobstate" + + if [ "${isbjobstate}" = "DONE_CODE_OK" ]; then + test_done + else + test_failed + print_error "'DONE_CODE_OK' was expected" + fi + + + fi + + fi fi fi