mirror of
https://github.com/rsyslog/rsyslog.git
synced 2026-06-19 15:12:56 +02:00
11933498f9
Not all imfile tests have state file directories or a global working directory defined. This results in usage of the default location. While state file names should be sufficiently different, there is still some riks of using the same name in different tests. That becomes problematic if tests are run in parallel (and they are run in parallel inside the regular CI).
148 lines
4.2 KiB
Bash
Executable File
148 lines
4.2 KiB
Bash
Executable File
#!/bin/bash
|
|
# This is part of the rsyslog testbench, licensed under ASL 2.0
|
|
# This test tests imfile endmsg.regex.
|
|
. ${srcdir:=.}/diag.sh init
|
|
. $srcdir/diag.sh check-inotify
|
|
export USE_VALGRIND="YES"
|
|
|
|
mkdir $RSYSLOG_DYNNAME.statefiles
|
|
generate_conf
|
|
add_conf '
|
|
module(load="../plugins/imfile/.libs/imfile")
|
|
module(load="../plugins/mmnormalize/.libs/mmnormalize")
|
|
|
|
input(type="imfile"
|
|
statefile.directory="'${RSYSLOG_DYNNAME}'.statefiles"
|
|
File="./'$RSYSLOG_DYNNAME'.*.input"
|
|
Tag="file:" addMetadata="on" escapelf="off"
|
|
endmsg.regex="(^[^ ]+ (stdout|stderr) F )|(\\n\"}$)")
|
|
|
|
if $msg startswith "{" then {
|
|
action(type="mmnormalize" rulebase="'$srcdir/imfile-endmsg.regex.json.rulebase'")
|
|
foreach ($.ii in $!multilinejson) do {
|
|
if strlen($!@timestamp) == 0 then {
|
|
set $!@timestamp = $.ii!time;
|
|
}
|
|
if strlen($!stream) == 0 then {
|
|
set $!stream = $.ii!stream;
|
|
}
|
|
if strlen($!log) == 0 then {
|
|
set $!log = $.ii!log;
|
|
} else {
|
|
reset $!log = $!log & $.ii!log;
|
|
}
|
|
}
|
|
unset $!multilinejson;
|
|
} else {
|
|
action(type="mmnormalize" rulebase="'$srcdir/imfile-endmsg.regex.crio.rulebase'")
|
|
foreach ($.ii in $!multilinecrio) do {
|
|
if strlen($!@timestamp) == 0 then {
|
|
set $!@timestamp = $.ii!time;
|
|
}
|
|
if strlen($!stream) == 0 then {
|
|
set $!stream = $.ii!stream;
|
|
}
|
|
if strlen($!log) == 0 then {
|
|
set $!log = $.ii!log;
|
|
} else {
|
|
reset $!log = $!log & $.ii!log;
|
|
}
|
|
}
|
|
unset $!multilinecrio;
|
|
}
|
|
|
|
template(name="outfmt" type="list") {
|
|
property(name="$!all-json-plain")
|
|
constant(value="\n")
|
|
}
|
|
|
|
if $msg contains "msgnum:" then
|
|
action(
|
|
type="omfile"
|
|
file=`echo $RSYSLOG_OUT_LOG`
|
|
template="outfmt"
|
|
)
|
|
'
|
|
startup
|
|
if [ -n "${USE_GDB:-}" ] ; then
|
|
echo attach gdb here
|
|
sleep 54321 || :
|
|
fi
|
|
|
|
# write the beginning of the file
|
|
echo 'date stdout P msgnum:0' > $RSYSLOG_DYNNAME.crio.input
|
|
echo '{"time":"date", "stream":"stdout", "log":"msgnum:0"}' > $RSYSLOG_DYNNAME.json.input
|
|
echo 'date stdout F msgnum:1' >> $RSYSLOG_DYNNAME.crio.input
|
|
echo '{"time":"date", "stream":"stdout", "log":"msgnum:1\n"}' >> $RSYSLOG_DYNNAME.json.input
|
|
echo 'date stdout F msgnum:2' >> $RSYSLOG_DYNNAME.crio.input
|
|
echo '{"time":"date", "stream":"stdout", "log":"msgnum:2\n"}' >> $RSYSLOG_DYNNAME.json.input
|
|
|
|
if [ -n "${USE_GDB:-}" ] ; then
|
|
sleep 54321 || :
|
|
fi
|
|
|
|
wait_file_lines $RSYSLOG_OUT_LOG 4
|
|
|
|
echo 'date stdout P msgnum:3' >> $RSYSLOG_DYNNAME.crio.input
|
|
echo '{"time":"date", "stream":"stdout", "log":"msgnum:3"}' >> $RSYSLOG_DYNNAME.json.input
|
|
echo 'date stdout P msgnum:4' >> $RSYSLOG_DYNNAME.crio.input
|
|
echo '{"time":"date", "stream":"stdout", "log":"msgnum:4"}' >> $RSYSLOG_DYNNAME.json.input
|
|
echo 'date stdout P msgnum:5' >> $RSYSLOG_DYNNAME.crio.input
|
|
echo '{"time":"date", "stream":"stdout", "log":"msgnum:5"}' >> $RSYSLOG_DYNNAME.json.input
|
|
|
|
# give it time to finish
|
|
if [ -n "${USE_GDB:-}" ] ; then
|
|
sleep 54321 || :
|
|
else
|
|
sleep 1 # of course, this is racy
|
|
fi
|
|
# so we do at least wait for the queue to be empty - this should work in hopefully most cases
|
|
wait_queueempty
|
|
|
|
echo 'date stdout F msgnum:6' >> $RSYSLOG_DYNNAME.crio.input
|
|
echo '{"time":"date", "stream":"stdout", "log":"msgnum:6\n"}' >> $RSYSLOG_DYNNAME.json.input
|
|
echo 'date stdout P msgnum:7' >> $RSYSLOG_DYNNAME.crio.input
|
|
echo '{"time":"date", "stream":"stdout", "log":"msgnum:7"}' >> $RSYSLOG_DYNNAME.json.input
|
|
|
|
wait_file_lines $RSYSLOG_OUT_LOG 6
|
|
|
|
shutdown_when_empty
|
|
wait_shutdown
|
|
|
|
|
|
## check if we have the correct number of messages
|
|
|
|
NUMLINES=$(wc -l $RSYSLOG_OUT_LOG | awk '{print $1}' 2>/dev/null)
|
|
|
|
rc=0
|
|
if [ ! $NUMLINES -eq 6 ]; then
|
|
echo "ERROR: expecting 6 lines, got $NUMLINES"
|
|
cat -n $RSYSLOG_OUT_LOG
|
|
rc=1
|
|
fi
|
|
|
|
## check if all the data we expect to get in the file is there
|
|
|
|
for string in "metadata.*filename.*json[.]input.*msgnum:0msgnum:1" \
|
|
"metadata.*filename.*crio[.]input.*msgnum:0msgnum:1" \
|
|
"metadata.*filename.*json[.]input.*msgnum:2" \
|
|
"metadata.*filename.*crio[.]input.*msgnum:2" \
|
|
"metadata.*filename.*json[.]input.*msgnum:3msgnum:4msgnum:5msgnum:6" \
|
|
"metadata.*filename.*crio[.]input.*msgnum:3msgnum:4msgnum:5msgnum:6" ; do
|
|
if grep "$string" $RSYSLOG_OUT_LOG > /dev/null 2>&1 ; then
|
|
: # ok
|
|
else
|
|
echo "Error: the expected string '$string' not found"
|
|
rc=1
|
|
fi
|
|
done
|
|
|
|
if [ $rc -ne 0 ]; then
|
|
cat $RSYSLOG_OUT_LOG
|
|
error_exit 1
|
|
fi
|
|
|
|
## if we got here, all is good :)
|
|
|
|
exit_test
|