diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2010-06-08 12:46:24 +0200 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2010-06-08 12:46:24 +0200 |
commit | 3e49a1075ab6750135e1a38cf0c213579fa30b4a (patch) | |
tree | c986e10161f93f751a1d6a116cf53c1080844450 /action.h | |
parent | 220c57e7ebc49a56cc91fa31308b1563f83a95fb (diff) | |
download | rsyslog-3e49a1075ab6750135e1a38cf0c213579fa30b4a.tar.gz rsyslog-3e49a1075ab6750135e1a38cf0c213579fa30b4a.tar.xz rsyslog-3e49a1075ab6750135e1a38cf0c213579fa30b4a.zip |
performance enhancement: implemented stage 1 firehose mode for actions
... plus some other tests, namely string generation in parallel to action
processing. The code is not yet solid and not fully compatible to
older versions. But it is good enough for an early commit and some
early testing/gaining of experience.
The optimization was done based on the fine-grained partitioning
paradigm worked on the past couple of weeks -- seems to work out
really great :)
Diffstat (limited to 'action.h')
-rw-r--r-- | action.h | 2 |
1 files changed, 1 insertions, 1 deletions
@@ -69,6 +69,7 @@ struct action_s { struct modInfo_s *pMod;/* pointer to output module handling this selector */ void *pModData; /* pointer to module data - content is module-specific */ sbool bRepMsgHasMsg; /* "message repeated..." has msg fragment in it (0-no, 1-yes) */ + sbool bSubmitFirehoseMode;/* fast submission to action q in phase 1 possible? */ short f_ReduceRepeated;/* reduce repeated lines 0 - no, 1 - yes */ int f_prevcount; /* repetition cnt of prevline */ int f_repeatcount; /* number of "repeated" msgs */ @@ -86,7 +87,6 @@ struct action_s { pthread_mutex_t mutActExec; /* mutex to guard actual execution of doAction for single-threaded modules */ uchar *pszName; /* action name (for documentation) */ int *pbShutdownImmediate;/* to facilitate shutdown, if var is 1, shut down immediately */ - //uchar **ppMsgs; /* pointer to action-calling parameters (kept in structure to save alloc() time!) */ void *ppMsgs; /* pointer to action-calling parameters (kept in structure to save alloc() time!) */ size_t *lenMsgs; /* length of message in ppMsgs */ }; |