summaryrefslogtreecommitdiffstats
path: root/action.h
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2010-06-08 12:46:24 +0200
committerRainer Gerhards <rgerhards@adiscon.com>2010-06-08 12:46:24 +0200
commit3e49a1075ab6750135e1a38cf0c213579fa30b4a (patch)
treec986e10161f93f751a1d6a116cf53c1080844450 /action.h
parent220c57e7ebc49a56cc91fa31308b1563f83a95fb (diff)
downloadrsyslog-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.h2
1 files changed, 1 insertions, 1 deletions
diff --git a/action.h b/action.h
index ab7dfec7..43e6ae7d 100644
--- a/action.h
+++ b/action.h
@@ -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 */
};