diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2008-10-08 18:55:11 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2008-10-08 18:55:11 +0200 |
| commit | ace4f2f75202aec39449dac11b9eb1deca7428d7 (patch) | |
| tree | 86637d21fafb06b262a30ff2f57dee32cd6483df /runtime/msg.h | |
| parent | 82b583c4f99dd9beb30360f222c4d2a1152f75e1 (diff) | |
| download | rsyslog-ace4f2f75202aec39449dac11b9eb1deca7428d7.tar.gz rsyslog-ace4f2f75202aec39449dac11b9eb1deca7428d7.tar.xz rsyslog-ace4f2f75202aec39449dac11b9eb1deca7428d7.zip | |
reordered imudp processing.
Message parsing is now done as part of main message queue worker
processing (was part of the input thread) This should also improve
performance, as potentially more work is done in parallel.
Diffstat (limited to 'runtime/msg.h')
| -rw-r--r-- | runtime/msg.h | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/runtime/msg.h b/runtime/msg.h index d2fc2f30..98635f85 100644 --- a/runtime/msg.h +++ b/runtime/msg.h @@ -52,7 +52,10 @@ struct msg { BEGINobjInstance; /* Data to implement generic object - MUST be the first data element! */ pthread_mutexattr_t mutAttr; pthread_mutex_t mut; - int iRefCount; /* reference counter (0 = unused) */ + flowControl_t flowCtlType; /**< type of flow control we can apply, for enqueueing, needs not to be persisted because + once data has entered the queue, this property is no longer needed. */ + short iRefCount; /* reference counter (0 = unused) */ + short bIsParsed; /* is message parsed? (0=no, 1=yes), 0 means parser needs to be called */ short bParseHOSTNAME; /* should the hostname be parsed from the message? */ /* background: the hostname is not present on "regular" messages * received via UNIX domain sockets from the same machine. However, @@ -60,8 +63,6 @@ struct msg { * sockets. All in all, the parser would need parse templates, that would * resolve all these issues... rgerhards, 2005-10-06 */ - flowControl_t flowCtlType; /**< type of flow control we can apply, for enqueueing, needs not to be persisted because - once data has entered the queue, this property is no longer needed. */ short iSeverity; /* the severity 0..7 */ uchar *pszSeverity; /* severity as string... */ int iLenSeverity; /* ... and its length. */ |