mirror of
https://github.com/rsyslog/rsyslog.git
synced 2026-06-20 07:32:57 +02:00
e05f69793e
* New functionality for omuxsock This builds on "PR#6121 net: Add NetworkNamespace APIS" to add Network Namespace support for omuxsock. In addition, new functionality is added to support abstract socket names, as well as connected sockets. Changes are isolated to omuxsock to provide the new functionality: a. Abstract unix socket names (including network namespaces) b. Connected socket support (SOCK_STREAM, SOCK_SEQPACKET) c. Support for load, and action configuration d. Bug fix related to closing/reopening sockets This bug would cause the socket to be closed and reopened for every message sent. New tests are added as follows: a. uxsock_multiple.sh tests basic functionality with multiple output instances. b. uxsock_multiple_netns.sh is similar but using multiple namespaces. c. uxsock_simple_abstract.sh mirrors the existing uxsock_simple.sh but tests with abstract socket names. The uxsockrcvr test program was modified to support these new tests. Signed-off-by: Billie Alsup <balsup@cisco.com>
96 lines
2.5 KiB
Bash
Executable File
96 lines
2.5 KiB
Bash
Executable File
#!/bin/bash
|
|
# This tests basic omuxsock functionality. Multiple socket receivers are started
|
|
# which sends all data to an output file, then a rsyslog instance is started which
|
|
# generates messages and sends them to multiple unix sockets. Datagram sockets are
|
|
# being used.
|
|
# Based on uxsock_simple.sh added 2010-08-06 by Rgerhards
|
|
# Updated 2025-04-16 for abstract sockets
|
|
. ${srcdir:=.}/diag.sh init
|
|
check_command_available timeout
|
|
|
|
uname
|
|
if [ $(uname) != "Linux" ] ; then
|
|
echo "This test requires Linux (AF_UNIX abstract addresses)"
|
|
exit 77
|
|
fi
|
|
|
|
SOCKET_NAMES=(
|
|
"$RSYSLOG_DYNNAME-testbench-dgram-uxsock.0"
|
|
"$RSYSLOG_DYNNAME-testbench-dgram-uxsock.DGRAM"
|
|
"$RSYSLOG_DYNNAME-testbench-dgram-uxsock.STREAM"
|
|
"$RSYSLOG_DYNNAME-testbench-dgram-uxsock.SEQPACKET"
|
|
)
|
|
|
|
# create the pipe and start a background process that copies data from
|
|
# it to the "regular" work file
|
|
generate_conf
|
|
for name in "${SOCKET_NAMES[@]}"; do
|
|
ext=${name##*.}
|
|
if [ ${ext} == "0" ]; then
|
|
add_conf '
|
|
|
|
$template outfmt,"%msg:F,58:2%\n"
|
|
|
|
module(
|
|
load = "../plugins/omuxsock/.libs/omuxsock"
|
|
template = "outfmt"
|
|
SocketName = "'${name}'"
|
|
abstract = "1"
|
|
)
|
|
:msg, contains, "msgnum:" {
|
|
action(
|
|
type = "omuxsock"
|
|
)
|
|
'
|
|
else
|
|
add_conf '
|
|
action(
|
|
type = "omuxsock"
|
|
SocketName = "'$name'"
|
|
abstract = "1"
|
|
SocketType = "'$ext'"
|
|
)
|
|
'
|
|
fi
|
|
done
|
|
add_conf '
|
|
}
|
|
'
|
|
BGPROCESS=()
|
|
for name in "${SOCKET_NAMES[@]}"; do
|
|
ext=${name##*.}
|
|
if [ "${ext}" == "0" ]; then
|
|
type=""
|
|
else
|
|
type="-T${ext}"
|
|
fi
|
|
timeout 30s ./uxsockrcvr -a -s$name ${type} -o ${RSYSLOG_OUT_LOG}.${ext} -t 60 &
|
|
PID=($!)
|
|
BGPROCESS+=($PID)
|
|
echo background uxsockrcvr ${name} process id is $PID
|
|
done
|
|
|
|
# now do the usual run
|
|
startup
|
|
# 10000 messages should be enough
|
|
injectmsg 0 10000
|
|
shutdown_when_empty # shut down rsyslogd when done processing messages
|
|
wait_shutdown
|
|
|
|
# wait for the cp process to finish, do pipe-specific cleanup
|
|
echo shutting down uxsockrcvr...
|
|
# TODO: we should do this more reliable in the long run! (message counter? timeout?)
|
|
for pid in ${BGPROCESS[@]}; do
|
|
kill $pid
|
|
wait $pid
|
|
done
|
|
echo background processes have terminated, continue test...
|
|
|
|
# and continue the usual checks
|
|
BASE=${RSYSLOG_OUT_LOG}
|
|
for name in "${SOCKET_NAMES[@]}"; do
|
|
RSYSLOG_OUT_LOG=${BASE}.${name##*.}
|
|
seq_check 0 9999
|
|
done
|
|
exit_test
|