diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-10-27 17:31:27 +0100 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-10-27 17:31:27 +0100 |
| commit | 1ada506e2d90377c2475e103340d8986bf8847f9 (patch) | |
| tree | 214d2276fbfcff39d025eaf114cf5813e5a445cd /dirty.h | |
| parent | f3134f89211ea6a65e72bca1dd2f91bf0a0ae894 (diff) | |
| download | rsyslog-1ada506e2d90377c2475e103340d8986bf8847f9.tar.gz rsyslog-1ada506e2d90377c2475e103340d8986bf8847f9.tar.xz rsyslog-1ada506e2d90377c2475e103340d8986bf8847f9.zip | |
added the capability to have ruleset-specific main message queues
This offers considerable additional flexibility AND superior performance
(in cases where multiple inputs now can avoid lock contention)
Diffstat (limited to 'dirty.h')
| -rw-r--r-- | dirty.h | 2 |
1 files changed, 2 insertions, 0 deletions
@@ -35,6 +35,7 @@ int parseRFCSyslogMsg(msg_t *pMsg, int flags); int parseLegacySyslogMsg(msg_t *pMsg, int flags); rsRetVal diagGetMainMsgQSize(int *piSize); /* for imdiag */ char* getFIOPName(unsigned iFIOP); +rsRetVal createMainQueue(qqueue_t **ppQueue, uchar *pszQueueName); /* Intervals at which we flush out "message repeated" messages, * in seconds after previous message is logged. After each flush, @@ -46,6 +47,7 @@ extern int iActExecOnceInterval; extern int MarkInterval; extern int repeatinterval[2]; extern int bReduceRepeatMsgs; +extern qqueue_t *pMsgQueue; /* the main message queue */ #define MAXREPEAT ((int)((sizeof(repeatinterval) / sizeof(repeatinterval[0])) - 1)) #define REPEATTIME(f) ((f)->f_time + repeatinterval[(f)->f_repeatcount]) #define BACKOFF(f) { if (++(f)->f_repeatcount > MAXREPEAT) \ |