Skip to content

Commit 7c68370

Browse files
DaGeReDaGeRe
committed
Start working on elastic apm
1 parent fb68935 commit 7c68370

File tree

4 files changed

+286
-0
lines changed

4 files changed

+286
-0
lines changed

‎frameworks/elasticapm-java/benchmark.sh

+152
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,152 @@
1+
#!/bin/bash
2+
3+
#
4+
# Kieker benchmark script
5+
#
6+
# Usage: benchmark.sh
7+
8+
# configure base dir
9+
BASE_DIR=$(cd "$(dirname "$0")"; pwd)
10+
MAIN_DIR="${BASE_DIR}/../.."
11+
12+
# Hotfix for ASPECTJ
13+
# https://stackoverflow.com/questions/70411097/instrument-java-17-with-aspectj
14+
JAVA_VERSION=$(java -version 2>&1 | grep version | sed 's/^.* "\([0-9\.]*\).*/\1/g')
15+
if [ "${JAVA_VERSION}" != "1.8.0" ] ; then
16+
export JAVA_OPTS="--add-opens java.base/java.lang=ALL-UNNAMED"
17+
echo "Setting \$JAVA_OPTS, since Java version is bigger than 8"
18+
fi
19+
20+
#
21+
# source functionality
22+
#
23+
24+
if [ ! -d "${BASE_DIR}" ] ; then
25+
echo "Base directory ${BASE_DIR} does not exist."
26+
exit 1
27+
fi
28+
29+
if [ -f "${MAIN_DIR}/common-functions.sh" ] ; then
30+
source "${MAIN_DIR}/common-functions.sh"
31+
else
32+
echo "Missing library: ${MAIN_DIR}/common-functions.sh"
33+
exit 1
34+
fi
35+
36+
# load configuration and common functions
37+
if [ -f "${BASE_DIR}/config.rc" ] ; then
38+
source "${BASE_DIR}/config.rc"
39+
else
40+
echo "Missing configuration: ${BASE_DIR}/config.rc"
41+
exit 1
42+
fi
43+
44+
if [ -f "${BASE_DIR}/functions.sh" ] ; then
45+
source "${BASE_DIR}/functions.sh"
46+
else
47+
echo "Missing: ${BASE_DIR}/functions.sh"
48+
exit 1
49+
fi
50+
if [ -f "${BASE_DIR}/labels.sh" ] ; then
51+
source "${BASE_DIR}/labels.sh"
52+
else
53+
echo "Missing file: ${BASE_DIR}/labels.sh"
54+
exit 1
55+
fi
56+
57+
if [ -z "$MOOBENCH_CONFIGURATIONS" ]
58+
then
59+
MOOBENCH_CONFIGURATIONS="0 1 2 4 5"
60+
echo "Setting default configuration $MOOBENCH_CONFIGURATIONS (without TextLogStreamHandler)"
61+
fi
62+
echo "Running configurations: $MOOBENCH_CONFIGURATIONS"
63+
64+
#
65+
# Setup
66+
#
67+
68+
info "----------------------------------"
69+
info "Setup..."
70+
info "----------------------------------"
71+
72+
cd "${BASE_DIR}"
73+
74+
# load agent
75+
getAgent
76+
77+
checkDirectory data-dir "${DATA_DIR}" create
78+
checkFile log "${DATA_DIR}/kieker.log" clean
79+
cleanupResults
80+
mkdir -p $RESULTS_DIR
81+
PARENT=`dirname "${RESULTS_DIR}"`
82+
checkDirectory result-base "${PARENT}"
83+
84+
checkFile AspectJ-Agent "${AGENT}"
85+
86+
checkExecutable java "${JAVA_BIN}"
87+
checkExecutable moobench "${MOOBENCH_BIN}"
88+
checkFile R-script "${RSCRIPT_PATH}"
89+
90+
showParameter
91+
92+
TIME=`expr ${METHOD_TIME} \* ${TOTAL_NUM_OF_CALLS} / 1000000000 \* 4 \* ${RECURSION_DEPTH} \* ${NUM_OF_LOOPS} + ${SLEEP_TIME} \* 4 \* ${NUM_OF_LOOPS} \* ${RECURSION_DEPTH} + 50 \* ${TOTAL_NUM_OF_CALLS} / 1000000000 \* 4 \* ${RECURSION_DEPTH} \* ${NUM_OF_LOOPS} `
93+
info "Experiment will take circa ${TIME} seconds."
94+
95+
# general server arguments
96+
JAVA_ARGS="-Xms1G -Xmx2G"
97+
98+
LTW_ARGS="-javaagent:elastic-apm-agent.jar"
99+
100+
KIEKER_ARGS="-Dlog4j.configuration=log4j.cfg -Dkieker.monitoring.name=KIEKER-BENCHMARK -Dkieker.monitoring.adaptiveMonitoring.enabled=false -Dkieker.monitoring.periodicSensorsExecutorPoolSize=0"
101+
102+
# JAVA_ARGS used to configure and setup a specific writer
103+
declare -a WRITER_CONFIG
104+
# Receiver setup if necessary
105+
declare -a RECEIVER
106+
# Title
107+
declare -a TITLE
108+
109+
#
110+
# Different writer setups
111+
#
112+
WRITER_CONFIG[0]=""
113+
WRITER_CONFIG[1]="-Delastic.apm.service_name=moobench-benchmark -Delastic.apm.application_packages=moobench.application -Delastic.apm.server_url=http://127.0.0.1:8200"
114+
115+
116+
117+
writeConfiguration
118+
checkMoobenchConfiguration
119+
#
120+
# Run benchmark
121+
#
122+
123+
info "----------------------------------"
124+
info "Running benchmark..."
125+
info "----------------------------------"
126+
127+
for ((i=1;i<=${NUM_OF_LOOPS};i+=1))
128+
do
129+
info "## Starting iteration ${i}/${NUM_OF_LOOPS}"
130+
echo "## Starting iteration ${i}/${NUM_OF_LOOPS}" >> "${DATA_DIR}/kieker.log"
131+
132+
executeBenchmark
133+
printIntermediaryResults "${i}"
134+
done
135+
136+
# Create R labels
137+
LABELS=$(createRLabels)
138+
runStatistics
139+
140+
cleanupResults
141+
142+
mv "${DATA_DIR}/kieker.log" "${RESULTS_DIR}/kieker.log"
143+
[ -f "${RESULTS_DIR}/hotspot-1-${RECURSION_DEPTH}-1.log" ] && grep "<task " "${RESULTS_DIR}/"hotspot-*.log > "${RESULTS_DIR}/java.log"
144+
[ -f "${DATA_DIR}/errorlog.txt" ] && mv "${DATA_DIR}/errorlog.txt" "${RESULTS_DIR}"
145+
146+
checkFile results.yaml "${RESULTS_DIR}/results.yaml"
147+
checkFile results.yaml "${RESULTS_DIR}/results.zip"
148+
149+
info "Done."
150+
151+
exit 0
152+
# end

‎frameworks/elasticapm-java/config.rc

+21
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
##
2+
# MooBench configuration parameter
3+
4+
source ${MAIN_DIR}/config.rc
5+
6+
# path setup
7+
JAVA_BIN=`which java`
8+
9+
RSCRIPT_PATH="${BASE_DIR}/../statistics.r"
10+
11+
MAIN_DIR="${BASE_DIR}/../.."
12+
13+
MOOBENCH_BIN="${MAIN_DIR}/benchmark/bin/benchmark"
14+
15+
DATA_DIR="${BASE_DIR}/data"
16+
AGENT="${BASE_DIR}/kieker-2.0.2-SNAPSHOT-aspectj.jar"
17+
18+
# in-jar locations
19+
AOP="${BASE_DIR}/kieker.aop.xml"
20+
21+
# end

‎frameworks/elasticapm-java/functions.sh

+107
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,107 @@
1+
# Kieker specific functions
2+
3+
# ensure the script is sourced
4+
if [ "${BASH_SOURCE[0]}" -ef "$0" ]
5+
then
6+
echo "Hey, you should source this script, not execute it!"
7+
exit 1
8+
fi
9+
10+
11+
function getAgent() {
12+
info "Download the elastic agent ${AGENT}"
13+
# get agent
14+
curl -o 'elastic-apm-agent.jar' -L 'https://oss.sonatype.org/service/local/artifact/maven/redirect?r=releases&g=co.elastic.apm&a=elastic-apm-agent&v=LATEST'
15+
}
16+
17+
# experiment setups
18+
19+
#################################
20+
# function: execute an experiment
21+
#
22+
# $1 = i iterator
23+
# $2 = j iterator
24+
# $3 = k iterator
25+
# $4 = title
26+
# $5 = writer parameters
27+
function executeExperiment() {
28+
loop="$1"
29+
recursion="$2"
30+
index="$3"
31+
title="${TITLE[$index]}"
32+
kieker_parameters="${WRITER_CONFIG[$index]}"
33+
34+
info " # ${loop}.${recursion}.${index} ${title}"
35+
echo " # ${loop}.${recursion}.${index} ${title}" >> "${DATA_DIR}/kieker.log"
36+
37+
if [ "${kieker_parameters}" == "" ] ; then
38+
export BENCHMARK_OPTS="${JAVA_ARGS}"
39+
else
40+
export BENCHMARK_OPTS="${JAVA_ARGS} ${LTW_ARGS} ${KIEKER_ARGS} ${kieker_parameters}"
41+
fi
42+
43+
debug "Run options: ${BENCHMARK_OPTS}"
44+
45+
RESULT_FILE="${RAWFN}-${loop}-${recursion}-${index}.csv"
46+
LOG_FILE="${RESULTS_DIR}/output_${loop}_${RECURSION_DEPTH}_${index}.txt"
47+
48+
"${MOOBENCH_BIN}" \
49+
--application moobench.application.MonitoredClassSimple \
50+
--output-filename "${RESULT_FILE}" \
51+
--total-calls "${TOTAL_NUM_OF_CALLS}" \
52+
--method-time "${METHOD_TIME}" \
53+
--total-threads $THREADS \
54+
--recursion-depth "${recursion}"
55+
56+
if [ ! -f "${RESULT_FILE}" ] ; then
57+
info "---------------------------------------------------"
58+
cat "${LOG_FILE}"
59+
error "Result file '${RESULT_FILE}' is empty."
60+
else
61+
size=`wc -c "${RESULT_FILE}" | awk '{ print $1 }'`
62+
if [ "${size}" == "0" ] ; then
63+
info "---------------------------------------------------"
64+
cat "${LOG_FILE}"
65+
error "Result file '${RESULT_FILE}' is empty."
66+
fi
67+
fi
68+
rm -rf "${DATA_DIR}"/kieker-*
69+
70+
[ -f "${DATA_DIR}/hotspot.log" ] && mv "${DATA_DIR}/hotspot.log" "${RESULTS_DIR}/hotspot-${loop}-${recursion}-${index}.log"
71+
echo >> "${DATA_DIR}/kieker.log"
72+
echo >> "${DATA_DIR}/kieker.log"
73+
sync
74+
sleep "${SLEEP_TIME}"
75+
}
76+
77+
function executeBenchmarkBody() {
78+
index="$1"
79+
loop="$2"
80+
recursion="$3"
81+
if [[ "${RECEIVER[$index]}" ]] ; then
82+
debug "receiver ${RECEIVER[$index]}"
83+
${RECEIVER[$index]} >> "${DATA_DIR}/kieker.receiver-${loop}-${index}.log" &
84+
RECEIVER_PID=$!
85+
debug "PID ${RECEIVER_PID}"
86+
fi
87+
88+
executeExperiment "$loop" "$recursion" "$index"
89+
90+
if [[ "${RECEIVER_PID}" ]] ; then
91+
kill -TERM "${RECEIVER_PID}"
92+
unset RECEIVER_PID
93+
fi
94+
}
95+
96+
## Execute Benchmark
97+
function executeBenchmark() {
98+
recursion="${RECURSION_DEPTH}"
99+
100+
for index in $MOOBENCH_CONFIGURATIONS
101+
do
102+
executeBenchmarkBody $index $i $recursion
103+
done
104+
}
105+
106+
107+
# end

‎frameworks/elasticapm-java/labels.sh

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
TITLE[0]="No instrumentation"
2+
TITLE[1]="Deactivated probe"
3+
TITLE[2]="No logging"
4+
TITLE[3]="Text file"
5+
TITLE[4]="Binary file"
6+
TITLE[5]="Binary TCP"

0 commit comments

Comments
 (0)