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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
#!/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
|
