Changeset 983

Timestamp:

02/14/14 18:52:08 (10 years ago)

Author:

sdipsl

Message:

bypass firewalling difficulties. use mailing system to send AMQP message
see #176

Location:

trunk/libIGCM

Files:

• libIGCM_comp/libIGCM_comp.ksh (modified) (1 diff)
• libIGCM_debug/libIGCM_debug.ksh (modified) (2 diffs)
• libIGCM_sys/libIGCM_sys.ksh (modified) (1 diff)

trunk/libIGCM/libIGCM_comp/libIGCM_comp.ksh

@@ -790 +790 @@
             (( i=i+3 ))
           done
-
         else
           if [ X${FileName0} != XNONE ] ; then

trunk/libIGCM/libIGCM_debug/libIGCM_debug.ksh

@@ -142 +142 @@
 
 #D-#==================================================================
+#D-function IGCM_debug_send_AMQP_msg__MAILTUNNEL
+#D- * Purpose: Take over AMQP C client using mail as a message recipient
+#D- * One argument : base64 encoded message
+function IGCM_debug_send_AMQP_msg__MAILTUNNEL {
+
+  typeset b64_encoded_msg buffer mail_recipient send_messages mail_frequency last_mail_date__file
+  b64_encoded_msg=$1
+
+  buffer=/tmp/buffer.$$
+  mail_recipient="jerome.raciazek@ipsl.jussieu.fr"
+  send_messages=0
+  mail_frequency=3600 # in seconds
+  # use to keep track when was last mail sent (maybe to be replaced with global variable)
+  last_mail_date__file=/tmp/stamp.$$ 
+
+  # init
+  if [ ! -f "${buffer}" ]; then
+    touch "${buffer}"
+  fi
+
+  messages_count=$( wc -l ${buffer} ) # retrieve how many pending messages
+
+  if [ ! -f "${last_mail_date__file}" ]; then
+    # if we are here, it means no mail sent yet
+    if [ ${messages_count} -gt 0 ]; then
+      # send the first mail
+      send_messages=1
+    fi
+  else
+     # compute last time the file was changed (in seconds)
+    seconds_since_last_mail=$(( $(date +%s) - $(stat -c %Y ${last_mail_date__file}) ))
+
+    if [ ${seconds_since_last_mail} -gt ${mail_frequency} ]; then
+      send_messages=1
+    fi
+  fi
+
+  # send mail / add message in buffer
+  if [ ${send_messages} -eq 1 ]; then
+    cat ${buffer} | mail -s mail_recipient  # send buffer
+    > $buffer                               # clear buffer
+    touch ${last_mail_date__file}           # memorize last mail date
+  else
+    echo ${b64_encoded_msg} >> ${buffer}
+  fi
+  # Allways all good for now.
+  return 0
+}
+
+#D-#==================================================================
 #D-function IGCM_debug_SendAMQP
 #D- * Purpose: Send body; encoded body and config.card to rabbitMQ
@@ -167 +217 @@
     (( decal = decal + 1 ))
   done
-  # Log to stack file
+  # Log to stack file using human readable format
   echo sendAMQPMsg -h localhost -p 5672 ${additionnalOption} -b "${Body}"      >> ${StackFileLocation}/${StackFileName}
 
-  # Log separately AMQP send message command
+  # Log separately encoded AMQP message command for reuse in a mock up
   echo sendAMQPMsg -h localhost -p 5672 ${additionnalOption} -b ${encodedBody} >> /tmp/send.AMQP.${jobid}.history.txt
 
   # Send the message
-  sendAMQPMsg -h localhost -p 5672 ${additionnalOption} -b ${encodedBody}
+  if [ X${BigBrotherChannel} = XMAIL ] ; then
+    IGCM_debug_send_AMQP_msg__MAILTUNNEL "${encodedBody}"
+    status=$?
+  else
+    sendAMQPMsg -h localhost -p 5672 ${additionnalOption} -b ${encodedBody}
+    status=$?
+  fi
+
   status=$?
   if [ ${status} -gt 0 ] ; then

trunk/libIGCM/libIGCM_sys/libIGCM_sys.ksh

@@ -26 +26 @@
 # set BigBrother false by default
 BigBrother=false
+
+#====================================================
+# set BigBrother channel (AMQP or MAIL)
+# only MAIL working at present due to firewall constraint
+BigBrotherChannel=MAIL
 
 # variable that must have lower case value.