Sign Up
Log In
Log In
or
Sign Up
Places
All Projects
Status Monitor
Collapse sidebar
SUSE:SLE-12-SP3:Update
rsyslog.5379
rsyslog-8.17.x-imuxsock-add-support-for-ruleset...
Overview
Repositories
Revisions
Requests
Users
Attributes
Meta
File rsyslog-8.17.x-imuxsock-add-support-for-rulesets.patch of Package rsyslog.5379
From 16db662d9fac0f9636eea873d690a629641be5bc Mon Sep 17 00:00:00 2001 From: Rainer Gerhards <rgerhards@adiscon.com> Date: Tue, 2 Feb 2016 08:52:31 +0100 Subject: [PATCH] imuxsock: add support for rulesets ruleset parameter is added at listener level implements https://github.com/rsyslog/rsyslog/issues/765 --- plugins/imuxsock/imuxsock.c | 32 ++++++++++++++++++++++++--- tests/Makefile.am | 3 +++ tests/imuxsock_logger_ruleset.sh | 20 +++++++++++++++++ tests/testsuites/imuxsock_logger_ruleset.conf | 13 +++++++++++ 4 files changed, 65 insertions(+), 3 deletions(-) create mode 100755 tests/imuxsock_logger_ruleset.sh create mode 100644 tests/testsuites/imuxsock_logger_ruleset.conf diff --git a/plugins/imuxsock/imuxsock.c b/plugins/imuxsock/imuxsock.c index d99bed8..140ec68 100644 --- a/plugins/imuxsock/imuxsock.c +++ b/plugins/imuxsock/imuxsock.c @@ -50,6 +50,7 @@ #include "parser.h" #include "prop.h" #include "debug.h" +#include "ruleset.h" #include "unlimited_select.h" #include "sd-daemon.h" #include "statsobj.h" @@ -98,6 +99,7 @@ DEFobjCurrIf(net) DEFobjCurrIf(parser) DEFobjCurrIf(datetime) DEFobjCurrIf(statsobj) +DEFobjCurrIf(ruleset) statsobj_t *modStats; @@ -146,6 +148,7 @@ typedef struct lstn_s { sbool bDiscardOwnMsgs; /* discard messages that originated from ourselves */ sbool bUseSysTimeStamp; /* use timestamp from system (instead of from message) */ sbool bUnlink; /* unlink&re-create socket at start and end of processing */ + ruleset_t *pRuleset; } lstn_t; static lstn_t *listeners; @@ -204,6 +207,9 @@ struct instanceConf_s { int bParseTrusted; /* parse trusted properties */ sbool bDiscardOwnMsgs; /* discard messages that originated from our own pid? */ sbool bUnlink; + uchar *pszBindRuleset; /* name of ruleset to bind to */ + ruleset_t *pBindRuleset; /* ruleset to bind listener to (use system default if unspecified) */ + struct instanceConf_s *next; }; @@ -263,6 +269,7 @@ static struct cnfparamdescr inppdescr[] = { { "usesystimestamp", eCmdHdlrBinary, 0 }, { "annotate", eCmdHdlrBinary, 0 }, { "usepidfromsystem", eCmdHdlrBinary, 0 }, + { "ruleset", eCmdHdlrString, 0 }, { "ratelimit.interval", eCmdHdlrInt, 0 }, { "ratelimit.burst", eCmdHdlrInt, 0 }, { "ratelimit.severity", eCmdHdlrInt, 0 } @@ -273,8 +280,7 @@ static struct cnfparamblk inppblk = inppdescr }; -/* we do not use this, because we do not bind to a ruleset so far - * enable when this is changed: #include "im-helper.h" */ /* must be included AFTER the type definitions! */ +#include "im-helper.h" /* must be included AFTER the type definitions! */ static int bLegacyCnfModGlobalsPermitted;/* are legacy module-global config parameters permitted? */ @@ -290,6 +296,8 @@ createInstance(instanceConf_t **pinst) CHKmalloc(inst = MALLOC(sizeof(instanceConf_t))); inst->sockName = NULL; inst->pLogHostName = NULL; + inst->pszBindRuleset = NULL; + inst->pBindRuleset = NULL; inst->ratelimitInterval = DFLT_ratelimitInterval; inst->ratelimitBurst = DFLT_ratelimitBurst; inst->ratelimitSeverity = DFLT_ratelimitSeverity; @@ -405,6 +413,7 @@ addListner(instanceConf_t *inst) listeners[nfd].bUnlink = inst->bUnlink; listeners[nfd].bWritePid = inst->bWritePid; listeners[nfd].bUseSysTimeStamp = inst->bUseSysTimeStamp; + listeners[nfd].pRuleset = inst->pBindRuleset; CHKiRet(ratelimitNew(&listeners[nfd].dflt_ratelimiter, "imuxsock", NULL)); ratelimitSetLinuxLike(listeners[nfd].dflt_ratelimiter, listeners[nfd].ratelimitInterval, @@ -940,6 +949,7 @@ SubmitMsg(uchar *pRcv, int lenRcv, lstn_t *pLstn, struct ucred *cred, struct tim MsgSetRcvFrom(pMsg, pLstn->hostName == NULL ? glbl.GetLocalHostNameProp() : pLstn->hostName); CHKiRet(MsgSetRcvFromIP(pMsg, pLocalHostIP)); + MsgSetRuleset(pMsg, pLstn->pRuleset); ratelimitAddMsg(ratelimiter, NULL, pMsg); STATSCOUNTER_INC(ctrSubmit, mutCtrSubmit); finalize_it: @@ -1252,6 +1262,8 @@ CODESTARTnewInpInst inst->bAnnotate = (int) pvals[i].val.d.n; } else if(!strcmp(inppblk.descr[i].name, "usepidfromsystem")) { inst->bWritePid = (int) pvals[i].val.d.n; + } else if(!strcmp(inppblk.descr[i].name, "ruleset")) { + inst->pszBindRuleset = (uchar*)es_str2cstr(pvals[i].val.d.estr, NULL); } else if(!strcmp(inppblk.descr[i].name, "ratelimit.interval")) { inst->ratelimitInterval = (int) pvals[i].val.d.n; } else if(!strcmp(inppblk.descr[i].name, "ratelimit.burst")) { @@ -1295,8 +1307,22 @@ CODESTARTendCnfLoad ENDendCnfLoad +/* function to generate error message if framework does not find requested ruleset */ +static void +std_checkRuleset_genErrMsg(__attribute__((unused)) modConfData_t *modConf, instanceConf_t *inst) +{ + errmsg.LogError(0, NO_ERRCODE, "imuxsock: ruleset '%s' for socket %s not found - " + "using default ruleset instead", inst->pszBindRuleset, + inst->sockName); +} + + BEGINcheckCnf + instanceConf_t *inst; CODESTARTcheckCnf +for(inst = pModConf->root ; inst != NULL ; inst = inst->next) { + std_checkRuleset(pModConf, inst); + } ENDcheckCnf @@ -1351,6 +1377,7 @@ CODESTARTfreeCnf free(pModConf->pLogSockName); for(inst = pModConf->root ; inst != NULL ; ) { free(inst->sockName); + free(inst->pszBindRuleset); free(inst->pLogHostName); del = inst; inst = inst->next; @@ -1479,6 +1506,7 @@ CODESTARTmodExit objRelease(prop, CORE_COMPONENT); objRelease(statsobj, CORE_COMPONENT); objRelease(datetime, CORE_COMPONENT); + objRelease(ruleset, CORE_COMPONENT); ENDmodExit @@ -1540,6 +1568,7 @@ CODEmodInit_QueryRegCFSLineHdlr CHKiRet(objUse(statsobj, CORE_COMPONENT)); CHKiRet(objUse(datetime, CORE_COMPONENT)); CHKiRet(objUse(parser, CORE_COMPONENT)); + CHKiRet(objUse(ruleset, CORE_COMPONENT)); DBGPRINTF("imuxsock version %s initializing\n", PACKAGE_VERSION); diff --git a/tests/Makefile.am b/tests/Makefile.am index b5d6f53..0c722c1 100644 --- a/tests/Makefile.am +++ b/tests/Makefile.am @@ -58,6 +58,7 @@ TESTS += \ imuxsock_traillf_root.sh \ imuxsock_ccmiddle_root.sh \ udp-msgreduc-vg.sh \ + imuxsock_logger_ruleset.sh \ udp-msgreduc-orgmsg-vg.sh \ queue-persist.sh \ discard-rptdmsg.sh \ @@ -558,6 +559,8 @@ EXTRA_DIST= 1.rstest 2.rstest 3.rstest err1.rstest \ imuxsock_ccmiddle_root.sh \ testsuites/imuxsock_ccmiddle_root.conf \ resultdata/imuxsock_ccmiddle.log \ + imuxsock_logger_ruleset.sh \ + testsuites/imuxsock_logger_ruleset.conf \ testsuites/mysql-truncate.sql \ testsuites/mysql-select-msg.sql \ libdbi-basic.sh \ diff --git a/tests/imuxsock_logger_ruleset.sh b/tests/imuxsock_logger_ruleset.sh new file mode 100644 index 0000000..666eb34 --- /dev/null +++ b/tests/imuxsock_logger_ruleset.sh @@ -0,0 +1,20 @@ +#!/bin/bash +# rgerhards, 2016-02-02 released under ASL 2.0 +echo \[imuxsock_logger_ruleset.sh\]: test imuxsock with ruleset definition +. $srcdir/diag.sh init +. $srcdir/diag.sh startup imuxsock_logger_ruleset.conf +# send a message with trailing LF +logger -d -u testbench_socket test +# the sleep below is needed to prevent too-early termination of rsyslogd +./msleep 100 +. $srcdir/diag.sh shutdown-when-empty # shut down rsyslogd when done processing messages +. $srcdir/diag.sh wait-shutdown # we need to wait until rsyslogd is finished! +cmp rsyslog.out.log $srcdir/resultdata/imuxsock_logger.log + echo \"`cat rsyslog.out.log`\" +if [ ! $? -eq 0 ]; then + echo "imuxsock_logger.sh failed" + echo contents of rsyslog.out.log: + echo \"`cat rsyslog.out.log`\" + exit 1 +fi; +. $srcdir/diag.sh exit diff --git a/tests/testsuites/imuxsock_logger_ruleset.conf b/tests/testsuites/imuxsock_logger_ruleset.conf new file mode 100644 index 0000000..8a1760d --- /dev/null +++ b/tests/testsuites/imuxsock_logger_ruleset.conf @@ -0,0 +1,13 @@ +# rgerhards, 2016-02-02 +$IncludeConfig diag-common.conf + +module(load="../plugins/imuxsock/.libs/imuxsock" sysSock.use="off") +input( type="imuxsock" socket="testbench_socket" + useSpecialParser="off" + ruleset="testruleset" + parseHostname="on") +template(name="outfmt" type="string" string="%msg:%\n") + +ruleset(name="testruleset") { + ./rsyslog.out.log;outfmt +} -- 2.6.2
Locations
Projects
Search
Status Monitor
Help
OpenBuildService.org
Documentation
API Documentation
Code of Conduct
Contact
Support
@OBShq
Terms
openSUSE Build Service is sponsored by
The Open Build Service is an
openSUSE project
.
Sign Up
Log In
Places
Places
All Projects
Status Monitor
