tests/segmented-diskqueue-corruption.sh - main - githubmirror/rsyslog

tests/segmented-diskqueue-corruption.sh
73 строки2 KB
Rainer Gerhards
tests: complete segmented DA coverage parity
14 июл 2026, 21:57
14 июл 2026, 21:570f35099
#!/bin/bash
# Shared record-corruption driver for payload CRC, framing, and codec failures.
# The inspector targets msgnum 200; every mode must skip that record and reach
# the final record without treating the queue as empty early.
# This file is part of the rsyslog project, released under ASL 2.0.
. ${srcdir:=.}/diag.sh init
check_command_available python3
export NUMMESSAGES=400
CORRUPTION_KIND=${CORRUPTION_KIND:-payload}
SPOOL_DIR="$PWD/${RSYSLOG_DYNNAME}.spool"

write_conf() {
	generate_conf
	add_conf '
module(load="../plugins/omtesting/.libs/omtesting")
global(workDirectory="'"$SPOOL_DIR"'")
main_queue(
	queue.type="segmentedDisk"
	queue.filename="mainq"
	queue.maxFileSize="256k"
	queue.dequeueBatchSize="32"
	queue.saveOnShutdown="on"
)

template(name="outfmt" type="string" string="%msg:F,58:2%\n")
'"$1"'
if ($msg contains "msgnum:") then
	action(type="omfile" file="'$RSYSLOG_OUT_LOG'" template="outfmt")
'
}

write_conf ':omtesting:sleep 10 0'
startup
injectmsg 0 "$NUMMESSAGES"
shutdown_immediate
. "$srcdir/diag.sh" kill-immediate
wait_shutdown

# The crash helper can interrupt the artificial sleep after the action has
# already appended the in-flight record. Discard phase-one output so the
# salvage oracle counts only the restarted queue; the uncommitted record must
# replay, while the deliberately damaged record must be the sole omission.
rm -f "$RSYSLOG_OUT_LOG"

case "$CORRUPTION_KIND" in
payload) mutation=--corrupt-message-number ;;
framing) mutation=--corrupt-record-framing ;;
codec) mutation=--corrupt-record-codec ;;
*) echo "FAIL: unknown corruption kind $CORRUPTION_KIND"; error_exit 1 ;;
esac
python3 "$srcdir/segdisk-inspect.py" "$SPOOL_DIR/mainq.segq" "$mutation" 200 \
	> "${RSYSLOG_DYNNAME}.segdisk-inspect.json"

write_conf '# no delay during salvage'
startup
shutdown_when_empty
wait_shutdown

line_count=$(wc -l < "$RSYSLOG_OUT_LOG")
if [ "$line_count" -ne $((NUMMESSAGES - 1)) ]; then
	echo "FAIL: expected $((NUMMESSAGES - 1)) records after corruption salvage, got $line_count"
	error_exit 1
fi
if grep -qx 00000200 "$RSYSLOG_OUT_LOG"; then
	echo "FAIL: payload-corrupt message 200 was emitted"
	error_exit 1
fi
if ! grep -qx 00000399 "$RSYSLOG_OUT_LOG"; then
	echo "FAIL: salvage did not continue to the final record"
	error_exit 1
fi
rm -rf "${RSYSLOG_DYNNAME}.spool"
exit_test