Changeset 873

Timestamp:

06/11/13 14:59:11 (11 years ago)

Author:

sdipsl

Message:

• Send message related to end of job and end of simulation

File:

• trunk/libIGCM/libIGCM_config/libIGCM_config.ksh (modified) (2 diffs)

trunk/libIGCM/libIGCM_config/libIGCM_config.ksh

@@ -1184 +1184 @@
   echo
 
+  if ( $DEBUG_debug ) ; then
+    # Inform the rabbitMQ queue
+
+    # TO BE A FUNCTION BEGIN #
+
+    if [ X${ActivateBigBro} = Xtrue ] ; then
+      # Only cosmetics
+      decal=0
+      while [ ${decal} -lt ${IGCM_debug_LenStack} ]; do
+        printf ' ' >> ${StackFileLocation}/stack
+        (( decal = decal + 1 ))
+      done
+      # RabbitMQ message
+      code=1100
+      #
+      Body=$( echo "{\"code\":\"${code}\",\"simuid\":\"${simuid}\",\"jobid\":\"${jobid}\",\"status\":\"OK\",\"timestamp\":\"$( date +"%Y-%m-%d-%T" )\"}" )
+      encodedBody=$( echo "${Body}" | base64 -w 0 )
+      #
+      #sendAMQPMsg -h localhost -p 5672 -f ${SUBMIT_DIR}/config.card -b ${encodedBody}
+      echo sendAMQPMsg -h localhost -p 5672 -b "${Body}"      >> ${StackFileLocation}/stack
+      echo sendAMQPMsg -h localhost -p 5672 -b ${encodedBody} >> /tmp/send.AMQP.${jobid}.history.txt
+      sendAMQPMsg -h localhost -p 5672 -b ${encodedBody}
+      status=$?
+      if [ ${status} -gt 0 ] ; then
+        IGCM_debug_Print 2 "IGCM_debug_PopStack : command sendAMQPMsg failed error code ${status}"
+        echo  sendAMQPMsg -h localhost -p 5672 -b "${Body}"
+        exit
+      fi
+    fi
+
+    # TO BE A FUNCTION END #
+
+  fi
+
   if [ ${SimulationLengthInDays} -ge ${ExperienceLengthInDays} ] ; then
     #==========================#
@@ -1195 +1229 @@
     IGCM_card_WriteOption ${SUBMIT_DIR}/run.card Configuration PeriodState "Completed"
     IGCM_debug_Print 1 "Normal End of computation."
+
     if ( $DEBUG_debug ) ; then
+      # Inform the rabbitMQ queue
+
+      # TO BE A FUNCTION BEGIN #
+
+      if [ X${ActivateBigBro} = Xtrue ] ; then
+        # Only cosmetics
+        decal=0
+        while [ ${decal} -lt ${IGCM_debug_LenStack} ]; do
+          printf ' ' >> ${StackFileLocation}/stack
+          (( decal = decal + 1 ))
+        done
+        # RabbitMQ message
+        code=0100
+        #
+        Body=$( echo "{\"code\":\"${code}\",\"simuid\":\"${simuid}\",\"jobid\":\"${jobid}\",\"status\":\"OK\",\"timestamp\":\"$( date +"%Y-%m-%d-%T" )\"}" )
+        encodedBody=$( echo "${Body}" | base64 -w 0 )
+        #
+        #sendAMQPMsg -h localhost -p 5672 -f ${SUBMIT_DIR}/config.card -b ${encodedBody}
+        echo sendAMQPMsg -h localhost -p 5672 -b "${Body}"      >> ${StackFileLocation}/stack
+        echo sendAMQPMsg -h localhost -p 5672 -b ${encodedBody} >> /tmp/send.AMQP.${jobid}.history.txt
+        sendAMQPMsg -h localhost -p 5672 -b ${encodedBody}
+        status=$?
+        if [ ${status} -gt 0 ] ; then
+          IGCM_debug_Print 2 "IGCM_debug_PopStack : command sendAMQPMsg failed error code ${status}"
+          echo  sendAMQPMsg -h localhost -p 5672 -b "${Body}"
+          exit
+        fi
+      fi
+
+      # TO BE A FUNCTION END #
+
       echo
       IGCM_debug_Print 1 "Your files on ${R_SAVE} :"