diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-07 15:37:13 +0100 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-07 15:37:13 +0100 |
| commit | 3bec3ef53e6e54cc94d9ed0142a2304729092282 (patch) | |
| tree | aec4bbce517218abd5ddeb9b83fb6cbbe46c44de /action.c | |
| parent | 9035771b7dbea738b8a22949a7f0a6514525fafb (diff) | |
| download | rsyslog-3bec3ef53e6e54cc94d9ed0142a2304729092282.tar.gz rsyslog-3bec3ef53e6e54cc94d9ed0142a2304729092282.tar.bz2 rsyslog-3bec3ef53e6e54cc94d9ed0142a2304729092282.zip | |
emit warning message if output module with msg passing mode runs asynchronously
Diffstat (limited to 'action.c')
| -rw-r--r-- | action.c | 9 |
1 files changed, 8 insertions, 1 deletions
@@ -69,7 +69,7 @@ * beast. * rgerhards, 2011-06-15 * - * Copyright 2007-2011 Rainer Gerhards and Adiscon GmbH. + * Copyright 2007-2013 Rainer Gerhards and Adiscon GmbH. * * This file is part of rsyslog. * @@ -114,6 +114,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 */ @@ -475,6 +476,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(); |