Delaying Outbound messages.

######################################################################
# Name: tps_msg_throttle
# Programmer: Scott R. Lee
# Purpose: Slow down messages going out to EDM.  Charges from Affinity
# can be sent too quickly for EDM to handle them and
# other messages (mainly ADTs) get queued up behind them.
#
# Edits: 6/4/07 – Scott R. Lee
# Changed sleep time from 1 second to .5 seconds.
# 6/6/07 – Scott R. Lee
# Changed sleep time back to 1 second.
#
# UPoC type: tps
# Args: tps keyedlist containing the following keys:
#       MODE    run mode (”start”, “run” or “time”)
#       MSGID   message handle
#       ARGS    user-supplied arguments:
#              
#
# Returns: tps disposition list:
#          
#

proc tps_msg_throttle { args } {
keylget args MODE mode               ;# Fetch mode

set dispList {} ;# Nothing to return

switch -exact — $mode {
start {
# Perform special init functions
# N.B.: there may or may not be a MSGID key in args
}

run {
# ‘run’ mode always has a MSGID; fetch and process it
keylget args MSGID mh
echo sleeping 1
sleep 1
lappend dispList “CONTINUE $mh”
}

time {
# Timer-based processing
# N.B.: there may or may not be a MSGID key in args
}
       
shutdown {
# Doing some clean-up work
}
}

return $dispList
}

#!/usr/bin/ksh

# Begin Module Header ==============================================================================
#
#
#——
# Name:
#——
#
#   resend_que.ksh
#
#———
# Purpose:
#———
#
#   will resend the next que file in name sorted order
#
#   the requirements are that the resend process is already running and the outbound thread is UP
#
#——-
# Notes:
#——-
#
# You need to at least manually start the resend process and confirm the resend_thread is up
# before invoking this script
#
# Have the calling script export/set these arguements before invoking this script.
#
# Here is an example:
#
#    export que_dir=”$HCISITEDIR/data/golive_archive”
#    export load_dir=”$HCISITEDIR/data/load_rxtfc_adt_9027″
#    export sent_dir=”$HCISITEDIR/data/golive_archive_resent”
#    export sent_log=$sent_dir/.log
#    export kill_file=”$que_dir/.kill”
#    export lock_file=”$que_dir/.lock”
#    export rs_proc=”resend_rxtfc_adt_9027″
#    export load_thread=”load_rxtfc_adt_9027″
#    export rs_thread=”rs_rxtfc_adt_9027″
#    resend_que.ksh
#
# Be sure to make an entry in /hci/cron/reminders.ksh as long as this script is scheduled to run via cron
#
#———
# History:
#———
#
#   2004.04.28 Russ Ross
#             – wrote intial version
#
#
#   2004.04.30 Russ Ross
#             – modified to only recycle the load thread instead of recycling the process
#             – modified so this script will not run unless the following conditions are true:
#
#                  the resend process is running
#                  the resend thread is UP
#
# End of Module Header =============================================================================

#—————————————-
# make sure the resend process is running
#—————————————-

   if [ ! -f $HCISITEDIR/exec/processes/$rs_proc/pid ]; then
       echo “”
       echo ”     STOPPING because the resend process is not running”
       echo ”     $rs_proc”
       echo “”
       exit
   fi

#———————————————–
# make sure the resend thread is UP=2 or INEOF=6
#———————————————–

   proto_status=`hcimsiutil -dd $rs_thread | grep “^Proto Status”     | awk -F: ‘{print $2}’ | tr -d ‘ ‘`
   if [[ “$proto_status” != “2” && “$proto_status” != “6” ]]; then
       echo “”
       echo ”     STOPPING because the resend thread is not UP or INEOF”
       echo ”     $rs_thread”
       echo “”
       exit
   fi

#—————————————-
# check if the necessary directories exit
#—————————————-

   if [ ! -d $que_dir ]; then
       echo “”
       echo ”     FATAL ERROR – directory does not exist”
       echo ”     $que_dir”
       echo “”
       exit
   fi

   if [ ! -d $load_dir ]; then
       echo “”
       echo ”     FATAL ERROR – directory does not exist”
       echo ”     $load_dir”
       echo “”
       exit
   fi

   if [ ! -d $sent_dir ]; then
       echo “”
       echo ”     FATAL ERROR – directory does not exist”
       echo ”     $sent_dir”
       echo “”
       exit
   fi

#——————————————
# check if this script has been toggled off
#——————————————

   if [ -f $kill_file ]; then
       echo “”
       echo ”     STOPPING because this script has been toggled off”
       echo ”     $kill_file”
       echo “”
       exit
   fi

#—————————————-
# check if this script is already running
#—————————————-

   if [ -f $lock_file ]; then
       echo “”
       echo ”     STOPPING because this script is already running”
       echo ”     $lock_file”
       echo “”
       exit
   fi

#————————————————————
# create lock file to prevent more than one occurance running
#————————————————————

   touch $lock_file

#————————————-
# make sure the last load file is done
#————————————-

   if [ -f $load_dir/* ]; then
       echo “”
       echo ”     STOPPING because not done resending last load file in directory”
       echo ”     $load_dir”
       echo “”
       rm -f $lock_file
       exit
   fi

#—————————————————————————
# make sure that no outbound messages are queued up over the next 60 seconds
#—————————————————————————

   let count=1

   while ((count <= 7)); do        ob_que_depth=`hcimsiutil -dd $rs_thread | grep "^OB Data QD" | awk -F: '{print $2}' | tr -d ' '`        if [[ $ob_que_depth > 0 ]]; then
           echo “”
           echo ”     STOPPING because outbound messages are still queued up”
           echo “”
           rm -f $lock_file
           exit
       fi

       sleep 10
       let count=count+1

   done

#————————————-
# stop thread if it is UP=2 or INEOF=6
#————————————-

   proto_status=`hcimsiutil -dd $load_thread | grep “^Proto Status”     | awk -F: ‘{print $2}’ | tr -d ‘ ‘`
   if [[ “$proto_status” = “2” || “$proto_status” = “6” ]]; then
       hcicmd -p $rs_proc -c “$load_thread pstop”
       sleep 5
   fi

#——————————————-
# zero out thread counts for the load thread
#——————————————-

   hcimsiutil -zt $load_thread >/dev/null
   sleep 5

#—————————————-
# get the name of the next file to resend
#—————————————-

   resend_file=””

   if [ -f $que_dir/* ]; then
       resend_file=`cd $que_dir; ls -1 * | sort | head -1`
   fi

   if [[ “$resend_file” = “” ]]; then
       echo “resend_que.ksh – no file found”
       rm -f $lock_file
       exit
   fi

#——————————–
# make entry into resend log file
#——————————–

   dts=`date “+%Y.%m.%d_%H:%M:%S”`
   echo “$dts   resending   $resend_file” >> $sent_log

#—————————————————–
# copy the next file to resend into the load directory
#—————————————————–

   cp -p   $que_dir/$resend_file   $load_dir

#——————————————————-
# move the next file to resend into the resent directory
#——————————————————-

   mv   $que_dir/$resend_file   $sent_dir

#———————-
# start the load thread
#———————-

   hcicmd -p $rs_proc -c “$load_thread pstart”
   sleep 5

#———————
# get rid of lock file
#———————

   rm -f $lock_file

#!/usr/bin/ksh

# Begin Module Header ==============================================================================
#
#
#——
# Name:
#——
#
#   rkr_xcelera_resend.ksh
#
#———
# Purpose:
#———
#
#   export/set the variables that get used by the generic script resend_que.ksh
#
#   will resend the next que file in name sorted order
#
#   if you schedule this in cron to run every 10 minutes
#   it will resend each que file one by one in name sorted order
#   by cycling the resend process and thread counts for each file sent before proceeding to the next file
#   plus will perpetually restartied every 10 minutes until all files have been resent
#   or until the kill_file has been touched
#
#——-
# Notes:
#——-
#
# Example of how to schedule this to run every minute in cron:
#
#   00-59 * * * * /bin/ksh -c ‘eval . ~/.profile.cron /quovadx/qdx5.2/integrator test_xcelera; rkr_xcelera_resend.ksh > /dev/null’
#
# Be sure to make an entry in /hci/cron/reminders.ksh as long as this script is scheduled to run via cron
#
#———
# History:
#———
#
#   2006.11.09 Russ Ross
#             – wrote intial version
#
# End of Module Header =============================================================================

#—————————————————————————–
# directory of the name sorted files to be sent
# (hidden file like .kill or .lock will not be a part of the sorted name list)
#—————————————————————————–

   export que_dir=”$HCISITEDIR/data/que_xcelera_adt”

#————————————————————————
# directory to move the next name sorted file to one by one for resending
#————————————————————————

   export load_dir=”$HCISITEDIR/data/load_xcelera_adt”

#—————————————————
# directory that will hold the files that got resent
#—————————————————

   export sent_dir=”$HCISITEDIR/data/sent_xcelera_adt”

#—————————-
# log file of what was resent
#—————————-

   export sent_log=$sent_dir/.log

#————————————————————————————————–
# toggle file that can be touched to gracefully prevent future invoking of this script from running
#————————————————————————————————–

   export kill_file=”$que_dir/.kill”

#—————————————————————————–
# file to prevent multiple invokations of this script running at the same time
#—————————————————————————–

   export lock_file=”$que_dir/.lock”

#—————————
# name of the resend process
#—————————

   export rs_proc=”resend_xcelera_adt”

#————————
# name of the load thread
#————————

   export load_thread=”load_xcelera_adt”

#————————–
# name of the resend thread
#————————–

   export rs_thread=”ob_xcelera_adt”

#—————————————-
# pass these arguements to resend_que.ksh
#—————————————-

   # resend_que.ksh >/dev/null
     resend_que.ksh