blob: 076c7715a783144c5874f593bbc03404acb13668 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
#!/bin/bash
# added 2020-04-10 by alorbach, released under ASL 2.0
. ${srcdir:=.}/diag.sh init
export NUMMESSAGES=1000000
export USE_VALGRIND="YES"
# TODO remote leak check skip and fix memory leaks caused by session break
export RS_TESTBENCH_LEAK_CHECK=no
mkdir $RSYSLOG_DYNNAME.workdir
generate_conf
add_conf '
module(load="../plugins/imrelp/.libs/imrelp")
global(
workDirectory="'$RSYSLOG_DYNNAME.workdir'"
maxMessageSize="256k"
)
main_queue(queue.type="Direct")
$LocalHostName test
$AbortOnUncleanConfig on
$PreserveFQDN on
input( type="imrelp"
name="imrelp"
port="'$TCPFLOOD_PORT'"
ruleset="spool"
MaxDataSize="256k"
KeepAlive="on"
)
template(name="outfmt" type="string" string="%msg:F,58:2%\n")
ruleset(name="spool" queue.type="direct") {
if $msg contains "msgnum:" then {
action(type="omfile" file=`echo $RSYSLOG_OUT_LOG` template="outfmt")
}
}
'
startup
# How many tcpfloods we run at the same tiem
for ((i=1;i<=5;i++)); do
# How many times tcpflood runs in each threads
./tcpflood -Trelp-plain -p$TCPFLOOD_PORT -m$NUMMESSAGES -s &
tcpflood_pid=$!
echo "started tcpflood instance $i (PID $tcpflood_pid)"
# Give it time to actually connect
./msleep 500;
kill -9 $tcpflood_pid # >/dev/null 2>&1;
echo "killed tcpflood instance $i (PID $tcpflood_pid)"
done;
wait_queueempty
netstatresult=$(netstat --all --program 2>&1 | grep "ESTABLISHED" | grep $(cat $RSYSLOG_PIDBASE.pid) | grep $TCPFLOOD_PORT)
openfd=$(ls -l "/proc/$(cat $RSYSLOG_PIDBASE$1.pid)/fd" | wc -l)
shutdown_when_empty
wait_shutdown
if [[ "$netstatresult" == "" ]]
then
echo "OK!"
else
echo "STILL OPENED Connections: "
echo $netstatresult
echo "Open files at the end: "
echo $openfd
error_exit 1
fi
exit_test
|
