BugID:1005

Checked in first version of the file scripts.

Modified consist of integration with SAS/MAC.

Appl/CEP/CS1/CS1_DelayCompensation/src/CS1_DelayCompensation.log_prop

-# add your custom loggers and appenders here
-#
 
-log4cplus.rootLogger=DEBUG, STDOUT, FILE
-
-log4cplus.logger.TRC=DEBUG
-log4cplus.additivity.TRC=false
+# Configure the loggers
+log4cplus.rootLogger=INFO, STDOUT, FILE
+#log4cplus.logger.TRC=INFO
+log4cplus.logger.TRC=INFO
+log4cplus.logger.LCS.Common=FATAL, STDOUT, FILE
 
+# Define the appenders
 log4cplus.appender.STDOUT=log4cplus::ConsoleAppender
 log4cplus.appender.STDOUT.layout=log4cplus::PatternLayout
-log4cplus.appender.STDOUT.layout.ConversionPattern=%D{%d-%m-%y %H:%M:%S.%q} %-5p %c{9} - %m [%.25l]%n
-log4cplus.appender.STDOUT.logToStdErr=false
+log4cplus.appender.STDOUT.layout.ConversionPattern=%D{%d-%m %H:%M:%S.%q} %-5p %c{9} - %m [%.25l]%n
+
+log4cplus.appender.STDERR=log4cplus::ConsoleAppender
+log4cplus.appender.STDERR.layout=log4cplus::PatternLayout
+log4cplus.appender.STDERR.layout.ConversionPattern=%D{%d-%m %H:%M:%S.%q} %-5p %c{3} - %m [%.25l]%n
+log4cplus.appender.STDERR.logToStdErr=true
 
 log4cplus.appender.FILE=log4cplus::RollingFileAppender
-log4cplus.appender.FILE.File=/dev/null
-log4cplus.appender.FILE.MaxFileSize=5MB
-log4cplus.appender.FILE.MaxBackupIndex=5
+log4cplus.appender.FILE.File=../log/%filename.log
+log4cplus.appender.FILE.MaxFileSize=10MB
+log4cplus.appender.FILE.MaxBackupIndex=2
 log4cplus.appender.FILE.layout=log4cplus::PatternLayout
-log4cplus.appender.FILE.layout.ConversionPattern=%D{%d-%m-%y %H:%M:%S.%q} %-5p %c{3} - %m [%.25l]%n
+log4cplus.appender.FILE.layout.ConversionPattern=%x %D{%d-%m %H:%M:%S.%q} %-5p %c{3} - %m [%.25l]%n
 
+log4cplus.appender.DUMP=log4cplus::NullAppender

Appl/CEP/CS1/CS1_DelayCompensation/src/DelayAppl.sh

+#!/bin/bash
+#
+# /DelayAppl: a start/stop/status script for swlevel
+#
+# Copyright (C) 2007
+# ASTRON (Netherlands Foundation for Research in Astronomy)
+# P.O.Box 2, 7990 AA Dwingeloo, The Netherlands, seg@astron.nl
+#
+# This program is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation; either version 2 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+#
+# Syntax: DelayAppl start|stop|status
+#
+# $Id$
+#
+
+#
+# SyntaxError msg
+#
+SyntaxError()
+{
+	Msg=$1
+
+	[ -z "${Msg}" ] || echo "ERROR: ${Msg}"
+	echo ""
+	echo "Syntax: $(basename $0) start | stop | status"
+	echo ""
+	exit 1
+}
+
+#
+# Start the program when it exists
+#
+start_prog()
+{
+	# put here your code to start your program
+	echo 'start_prog()'
+}
+
+#
+# Stop the program when it is running
+#
+stop_prog()
+{
+	# put here your code to stop your program
+	ps -ef | grep -v grep | grep -v ACDaemon[^\ ] | grep ACDaemon 2>&1 >/dev/null
+	if [ $? -ne 0 ]; then
+	  if [ -f ../etc/ACD.admin ]; then 	
+	    rm ../etc/ACD.admin
+	  fi
+	fi  
+	cexec killall -9 CS1_DelayCompensation 
+}
+
+#
+# show status of program
+#
+# arg1 = levelnr
+#
+status_prog()
+{
+	levelnr=$1
+
+	# put here code to figure out the status of your program and
+	# fill the variables prog and pid with the right information
+
+	# e.g.
+	prog=DelayAppl
+	pid=DOWN
+	cexec 'ps -ef | grep -v grep '| grep CS1_DelayCompensation| grep -v bash 2>$1 1>/dev/null
+	if [ $? -eq 0 ]; then
+	  cexec 'ps -ef | grep -v grep | grep CS1_DelayCompensation'| grep -v bash | awk -v levelnr=${levelnr} '{
+          if (substr($1,1,3) == "---") {
+            machine = substr($2,1,7)
+          }
+          else {
+            if (substr($1,1,3) != "***") {
+              fullname="DelayAppl@"machine
+              printf "%s : %-25.25s %s\n", levelnr,fullname,$2
+            }
+          }
+        }'
+	else
+          # this line should be left in, it shows the status in the right format
+	  echo ${levelnr} ${prog} ${pid} | awk '{ printf "%s : %-25s %s\n", $1, $2, $3 }'
+	fi
+}
+
+#
+# MAIN
+#
+
+# when no argument is given show syntax error.
+if [ -z "$1" ]; then
+	SyntaxError
+fi
+
+# first power down to this level
+case $1 in
+	start)	start_prog
+			;;
+	stop)	stop_prog
+			;;
+	status)	status_prog $2
+			;;
+	*)		SyntaxError
+			;;
+esac

Appl/CEP/CS1/CS1_DelayCompensation/src/prepare_CS1_DelayCompensation.py

+#!/usr/bin/env python
+
+import math
+import time
+import datetime
+import os
+import sys
+import copy
+
+class CS1_Parset(object):
+
+    def __init__(self):
+        self.stationList = list()
+	self.parameters = dict()
+
+    def readFromFile(self, fileName):
+        lastline = ''
+        for line in open(fileName, 'r').readlines():
+            lastline = lastline + line.split('#')[0]
+            lastline = lastline.rstrip()
+            if len(lastline) > 0 and lastline[-1] == '\\':
+                lastline = lastline[:-1]
+            elif '=' in lastline:
+                key, value = lastline.split('=')
+                self.parameters[key.strip()] = value.strip()
+                lastline = ''
+
+    def writeToFile(self, fileName):
+        outf = open(fileName, 'w')
+        for key, value in sorted(self.parameters.iteritems()):
+            outf.write(key + ' = ' + str(value) + '\n')
+        outf.close()
+
+    def __contains__(self, key):
+        return key in self.parameters
+        
+    def __setitem__(self, key, value):
+        self.parameters[key] = value
+
+    def __getitem__(self, key):
+        return self.parameters[key]
+
+    def getInt32Vector(self, key):
+        ln = self.parameters[key]
+	ln_tmp = ln.split('[')
+        line = 	ln_tmp[1].split(']')
+        return [int(lp) for lp in line[0].split(',')]
+
+    def getInt32(self, key):
+        return int(self.parameters[key])
+
+    def getStringVector(self, key):
+        line = self.parameters[key]
+        line.strip('[').strip(']')
+        return line.split(',')
+
+    def getString(self, key):
+        return self.parameters[key]
+
+    def getFloat(self, key):
+        return float(self.parameters[key])
+
+	
+if __name__ == '__main__':
+
+    # create the parset
+    parset = CS1_Parset() 
+    stationList = list()
+    
+    if os.path.exists("../share/DelayCompensation.parset"):
+       
+        #read keys from parset file: Transpose.parset
+        parset.readFromFile('../share/DelayCompensation.parset')
+
+        '''
+        if parset.getString('OLAP.OLAP_Conn.station_Input_Transport') == 'NULL':
+            # Read from memory!
+            parset['Observation.startTime'] = datetime.datetime.fromtimestamp(1)
+        else:
+            start=int(time.time() + 90)
+            parset['Observation.startTime'] = datetime.datetime.fromtimestamp(start)
+	
+	duration = 300
+
+        parset['Observation.stopTime'] = datetime.datetime.fromtimestamp(start + duration) 
+        '''
+
+	if parset.getString('OLAP.OLAP_Conn.input_DelayComp_Transport') == 'Null':
+	    parset['OLAP.OLAP_Conn.input_DelayComp_Transport']	 = 'NULL'
+	    
+	if parset.getString('OLAP.OLAP_Conn.input_BGLProc_Transport') == 'Null':
+	    parset['OLAP.OLAP_Conn.input_BGLProc_Transport']	 = 'NULL'
+	    
+	if parset.getString('OLAP.OLAP_Conn.station_Input_Transport') == 'Null':
+	    parset['OLAP.OLAP_Conn.station_Input_Transport']	 = 'NULL'
+
+	if parset.getString('OLAP.OLAP_Conn.BGLProc_Storage_Transport') == 'Null':
+	    parset['OLAP.OLAP_Conn.BGLProc_Storage_Transport']	 = 'NULL'
+	
+	#get the stations
+	stationList = parset.getStringVector('OLAP.storageStationNames')
+	parset['OLAP.nrRSPboards'] = len(stationList)
+	
+        if parset.getInt32('Observation.sampleClock') == 160:
+	    parset['OLAP.BGLProc.integrationSteps'] = 608
+        elif parset.getInt32('Observation.sampleClock') == 200:
+	    parset['OLAP.BGLProc.integrationSteps'] = 768
+	
+	parset.writeToFile('../share/DelayCompensation.parset')
+	    
+    else:
+        print '../share/DelayCompensation.parset does not exist!'
+        sys.exit(0) 	
+	

Appl/CEP/CS1/CS1_DelayCompensation/src/startAP.sh

+# startAP.sh nodename procID executable paramfile
+#
+# $1 jobName             identifier for this job
+# $2 machinefile         procID.machinefile
+# $3 executable          processname
+# $4 parameterfile       procID.ps
+# $5 numberOfNodes
+#
+# start the given executable and creates a corresponding pid file for stopping the process.
+#
+
+# now all ACC processes expect to be started with "ACC" as first parameter
+
+./prepare_$3.py
+
+# start process
+# TODO: in future something like: rsh $1 start_script $2 $3 $4
+./$3 ACC $4 $1>>/opt/lofar/log/$3.log 2>&1 & 
+
+# get its pid
+pid=`echo $!`
+
+# construct pid file for stop shell
+echo "$pid" > $2.pid

Appl/CEP/CS1/CS1_DelayCompensation/src/stopAP.sh

+# stopAP.sh nodename procID 
+#
+# nodename		    hostname[.domain]
+# procID			processname<nr>
+#
+# Stops the given process by killing the process whose pid is in the
+# proces.pid file.
+
+kill -9 `cat $2.pid`
+rm -f $2.pid $2.ps