execute-analysis-4-resource-monitoring.sh

#!/bin/bash

# run privacy analysis based on observed and logged events.
# Requires
# - PRIVACY_ANALYSIS
# - REPLAYER
# - Collected data from a simulated or real JPetStore run

# Parameter
# $1 = experiment id
# $2 = number representing the experiment run

# execute setup

BASE_DIR=$(cd "$(dirname "$0")"; pwd)

if [ -f $BASE_DIR/config ] ; then
	. $BASE_DIR/config
else
	echo "Missing configuration"
	exit 1
fi

. $BASE_DIR/common-functions.sh

if [ "$1" == "" ] ; then
	error "Missing experiment id"
	exit 1
else
	EXPERIMENT_ID="$1"
fi

if [ "$2" == "" ] ; then
	error "Missing iteration number"
	exit 1
else
	ITERATION="$2"
fi

information "Running analysis for experiment $EXPERIMENT_ID, iteration $ITERATION"

###################################
# setup paths

EXECUTION_DIR="${BASE_DIR}/executions/${EXPERIMENT_ID}/${ITERATION}"
PRIVACY_MEASUREMENTS_DIR="${EXECUTION_DIR}/privacy-result"

INPUT_DIR="${DATA_DIR}/input/${EXPERIMENT_ID}"

checkExecutable "service privacy violation" "${SERVICE_PRIVACY_VIOLATION}"
checkExecutable "replayer" "${REPLAYER}"
checkDirectory "input directory" "${INPUT_DIR}"

###################################

information "Starting privacy analysis"

PRIVACY_KIEKER_PROPERTIES="${EXECUTION_DIR}/privacy.kieker.properties"
PRIVACY_CONFIG="${EXECUTION_DIR}/privacy.config"

mkdir -p "${EXECUTION_DIR}"
mkdir "${EXECUTION_DIR}/db"
mkdir "${PRIVACY_MEASUREMENTS_DIR}"

##
## configuration for monitoring the privacy analysis
##
cat << EOF > "${PRIVACY_KIEKER_PROPERTIES}"
kieker.monitoring.name=KIEKER
kieker.monitoring.debug=false
kieker.monitoring.enabled=true
kieker.monitoring.hostname=
kieker.monitoring.initialExperimentId=${EXPERIMENT_ID}
kieker.monitoring.metadata=true
kieker.monitoring.setLoggingTimestamp=true
kieker.monitoring.useShutdownHook=true
kieker.monitoring.jmx=false

#######    TIMER    #######
kieker.monitoring.timer=kieker.monitoring.timer.SystemNanoTimer
kieker.monitoring.timer.SystemMilliTimer.unit=0
kieker.monitoring.timer.SystemNanoTimer.unit=0

#######    WRITER   #######
kieker.monitoring.writer=kieker.monitoring.writer.filesystem.FileWriter
kieker.monitoring.core.controller.WriterController.RecordQueueFQN=org.jctools.queues.MpscArrayQueue
kieker.monitoring.core.controller.WriterController.RecordQueueSize=10000
kieker.monitoring.core.controller.WriterController.RecordQueueInsertBehavior=1

kieker.monitoring.writer.filesystem.FileWriter.customStoragePath=$PRIVACY_MEASUREMENTS_DIR
kieker.monitoring.writer.filesystem.FileWriter.charsetName=UTF-8
kieker.monitoring.writer.filesystem.FileWriter.maxEntriesInFile=25000
kieker.monitoring.writer.filesystem.FileWriter.maxLogSize=-1
kieker.monitoring.writer.filesystem.FileWriter.maxLogFiles=-1
kieker.monitoring.writer.filesystem.FileWriter.mapFileHandler=kieker.monitoring.writer.filesystem.TextMapFileHandler
kieker.monitoring.writer.filesystem.TextMapFileHandler.flush=true
kieker.monitoring.writer.filesystem.TextMapFileHandler.compression=kieker.monitoring.writer.compression.NoneCompressionFilter
kieker.monitoring.writer.filesystem.FileWriter.logFilePoolHandler=kieker.monitoring.writer.filesystem.RotatingLogFilePoolHandler
kieker.monitoring.writer.filesystem.FileWriter.logStreamHandler=kieker.monitoring.writer.filesystem.TextLogStreamHandler
kieker.monitoring.writer.filesystem.FileWriter.flush=false
kieker.monitoring.writer.filesystem.BinaryFileWriter.bufferSize=8192
kieker.monitoring.writer.filesystem.BinaryFileWriter.compression=kieker.monitoring.writer.compression.NoneCompressionFilter
EOF


##
## configuration of the privacy analysis
##
cat << EOF > "${PRIVACY_CONFIG}"
## The name of the Kieker instance.
kieker.monitoring.name=EXP
kieker.monitoring.hostname=
kieker.monitoring.metadata=true

kieker.tools.source=kieker.tools.source.MultipleConnectionTcpSourceCompositeStage
kieker.tools.source.MultipleConnectionTcpSourceCompositeStage.port=9876
kieker.tools.source.MultipleConnectionTcpSourceCompositeStage.capacity=81920

# data storage
iobserve.analysis.model.pcm.databaseDirectory=$EXECUTION_DIR/db/
iobserve.analysis.model.pcm.initializationDirectory=$BASE_DIR/pcm/

# privacy configuration
iobserve.analysis.privacy.alarmFile=$EXECUTION_DIR/alarms.txt
iobserve.analysis.privacy.warningFile=$EXECUTION_DIR/warnings.txt
#iobserve.analysis.privacy.modelDumpDirectory=$EXECUTION_DIR/snapshots/

iobserve.analysis.privacy.policyList=NoPersonalDataInUSAPolicy
iobserve.analysis.privacy.packagePrefix=org.iobserve.service.privacy.violation.transformation.privacycheck.policies

iobserve.analysis.privacy.probeControls=localhost:4321
EOF

##
## running privacy analysis
##
export SERVICE_PRIVACY_VIOLATION_OPTS="-Dlog4j.configuration=file://$BASE_DIR/log4j.cfg -Dkieker.monitoring.configuration=${PRIVACY_KIEKER_PROPERTIES}"
${SERVICE_PRIVACY_VIOLATION} -c "${PRIVACY_CONFIG}" &
SERVICE_PRIVACY_VIOLATION_PID=$!

information "Wait for service to be started properly"
sleep 20

information "Starting replayer"

KIEKER=`ls "${INPUT_DIR}/" | grep "kieker-"`

##
## running event replayer
##
export REPLAYER_OPTS="-Dlog4j.configuration=file://$BASE_DIR/log4j-info.cfg"
LOOP=0
while [ $LOOP -le 100 ] ; do
	information "Replay loop $LOOP of 100 ..."
	${REPLAYER} -p 9876 -i "${INPUT_DIR}/${KIEKER}"  -h localhost -r -c 100 -d 4
	LOOP=`expr $LOOP + 1`
done

kill -TERM $SERVICE_PRIVACY_VIOLATION_PID
sleep 10
kill -9 $SERVICE_PRIVACY_VIOLATION_PID

##
rm "${PRIVACY_CONFIG}" "${PRIVACY_KIEKER_PROPERTIES}"

information "Experiment complete."

# end