diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-13 13:15:15 +0100 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-13 13:15:15 +0100 |
commit | dc760e8c672c2c896bc0d001fa1f7d9e02fe111c (patch) | |
tree | 89609f09d667ab7db2f60139eb59524458a57f60 /action.c | |
parent | 23278699e35173f46effda964fd80b8f868e8b3e (diff) | |
parent | 45a4134a8b5c9111398be3458bd27b4aa2f0e5c2 (diff) | |
download | rsyslog-dc760e8c672c2c896bc0d001fa1f7d9e02fe111c.tar.gz rsyslog-dc760e8c672c2c896bc0d001fa1f7d9e02fe111c.tar.bz2 rsyslog-dc760e8c672c2c896bc0d001fa1f7d9e02fe111c.zip |
Merge branch 'master-ruleeng' into master-ruleeng-simd
Diffstat (limited to 'action.c')
-rw-r--r-- | action.c | 7 |
1 files changed, 7 insertions, 0 deletions
@@ -108,6 +108,7 @@ #include "unicode-helper.h" #include "atomic.h" #include "ruleset.h" +#include "parserif.h" #include "statsobj.h" #define NO_TIME_PROVIDED 0 /* indicate we do not provide any cached time */ @@ -467,6 +468,12 @@ actionConstructFinalize(action_t *pThis, struct nvlst *lst) qqueueDbgPrint(pThis->pQueue); DBGPRINTF("Action %p: queue %p created\n", pThis, pThis->pQueue); + + if(pThis->eParamPassing == ACT_MSG_PASSING && pThis->pQueue->qType != QUEUETYPE_DIRECT) { + parser_warnmsg("module %s with message passing mode uses " + "non-direct queue. This most probably leads to undesired " + "results", (char*)modGetName(pThis->pMod)); + } /* and now reset the queue params (see comment in its function header!) */ actionResetQueueParams(); |