mirror of
https://github.com/rsyslog/rsyslog.git
synced 2025-12-15 19:50:40 +01:00
86d99297f8
this test loses messages because of tcp unreliability, so this is expected. We are still investigating ways to improve test performance even in spite of this problem. As an interim solution against flakes, we at least temporarily increase permitted loss again.
46 lines
1.4 KiB
Bash
Executable File
46 lines
1.4 KiB
Bash
Executable File
#!/bin/bash
|
|
# added 2024-02-19 by rgerhards. Released under ASL 2.0
|
|
# This test is not meant to be executed independetly. It just permits
|
|
# to be called by different drivers with different io buffer sizes.
|
|
# This in turn is needed to test some edge cases.
|
|
. ${srcdir:=.}/diag.sh init
|
|
skip_platform "SunOS" "This test is currently not supported on solaris due to too-different timing"
|
|
generate_conf
|
|
export NUMMESSAGES=20000
|
|
|
|
# starting minitcpsrvr receivers so that we can obtain their port
|
|
# numbers
|
|
export MINITCPSRV_EXTRA_OPTS="-D900 -B2 -a -S3"
|
|
start_minitcpsrvr $RSYSLOG_OUT_LOG 1
|
|
|
|
add_conf '
|
|
$MainMsgQueueTimeoutShutdown 10000
|
|
$MainMsgQueueDequeueBatchSize 100
|
|
|
|
global(allMessagesToStderr="on")
|
|
|
|
template(name="outfmt" type="string" string="%msg:F,58:2%\n")
|
|
module(load="builtin:omfwd" template="outfmt" iobuffer.maxSize="'$OMFWD_IOBUF_SIZE'")
|
|
|
|
if $msg contains "msgnum:" then {
|
|
action(type="omfwd" target=["127.0.0.1"] port="'$MINITCPSRVR_PORT1'" protocol="tcp"
|
|
extendedConnectionCheck="off"
|
|
pool.resumeInterval="1"
|
|
action.resumeRetryCount="-1" action.resumeInterval="1")
|
|
}
|
|
'
|
|
|
|
# now do the usual run
|
|
startup
|
|
|
|
injectmsg
|
|
sleep 20 # This is just an experiment! TODO: remove or adjust after experiment.
|
|
shutdown_when_empty
|
|
wait_shutdown
|
|
# note: minitcpsrv shuts down automatically if the connection is closed!
|
|
|
|
export SEQ_CHECK_OPTIONS=-d
|
|
# permit message loss - note that TCP loses messages on disconnect, and we do some!
|
|
seq_check 0 $((NUMMESSAGES-1)) -m500
|
|
exit_test
|