diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-06-16 15:13:47 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-06-16 15:13:47 +0200 |
| commit | 6f0db63e9b962edf6305860b608500e8c650b71b (patch) | |
| tree | 142a4dc01419a08f46481d5ca5557da07f0474c7 /runtime | |
| parent | aef1a38fe8c7472362904b2f90c67113b21034ab (diff) | |
| download | rsyslog-6f0db63e9b962edf6305860b608500e8c650b71b.tar.gz rsyslog-6f0db63e9b962edf6305860b608500e8c650b71b.tar.xz rsyslog-6f0db63e9b962edf6305860b608500e8c650b71b.zip | |
milestone: input-side multiSubmit capability
... commit before I try to touch the queue side ;)
Diffstat (limited to 'runtime')
| -rw-r--r-- | runtime/rsyslog.h | 13 | ||||
| -rw-r--r-- | runtime/stream.c | 2 |
2 files changed, 14 insertions, 1 deletions
diff --git a/runtime/rsyslog.h b/runtime/rsyslog.h index e81c9eef..ea8a5222 100644 --- a/runtime/rsyslog.h +++ b/runtime/rsyslog.h @@ -127,6 +127,19 @@ typedef enum { } fiop_t; +/* multi-submit support. + * This is done via a simple data structure, which holds the number of elements + * as well as an array of to-be-submitted messages. + * rgerhards, 2009-06-16 + */ +typedef struct multi_submit_s multi_submit_t; +struct multi_submit_s { + short maxElem; /* maximum number of Elements */ + short nElem; /* current number of Elements, points to the next one FREE */ + msg_t **ppMsgs; +}; + + #ifndef _PATH_CONSOLE #define _PATH_CONSOLE "/dev/console" #endif diff --git a/runtime/stream.c b/runtime/stream.c index f13258b5..8cbe0297 100644 --- a/runtime/stream.c +++ b/runtime/stream.c @@ -188,7 +188,7 @@ finalize_it: static rsRetVal doPhysOpen(strm_t *pThis) { - int iFlags; + int iFlags = 0; DEFiRet; ISOBJ_TYPE_assert(pThis, strm); |