diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2012-10-15 11:48:43 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2012-10-15 11:48:43 +0200 |
| commit | 25a8496a6ae79480e8601cbdab5b45ad613a8dcd (patch) | |
| tree | e37b46f83f1526b6f71ac94cd307381be5581517 /plugins/imptcp/imptcp.c | |
| parent | 3806643baa9fe0d50fb36080e4ab3a078b8a5952 (diff) | |
| download | rsyslog-25a8496a6ae79480e8601cbdab5b45ad613a8dcd.tar.gz rsyslog-25a8496a6ae79480e8601cbdab5b45ad613a8dcd.tar.bz2 rsyslog-25a8496a6ae79480e8601cbdab5b45ad613a8dcd.zip | |
imudp: add input batching & ratelimiter interface
Diffstat (limited to 'plugins/imptcp/imptcp.c')
| -rw-r--r-- | plugins/imptcp/imptcp.c | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/plugins/imptcp/imptcp.c b/plugins/imptcp/imptcp.c index 22d3ff25..8495b293 100644 --- a/plugins/imptcp/imptcp.c +++ b/plugins/imptcp/imptcp.c @@ -801,12 +801,11 @@ processDataRcvd(ptcpsess_t *pThis, char c, struct syslogTime *stTime, time_t ttG * we have just received a bunch of data! -- rgerhards, 2009-06-16 * EXTRACT from tcps_sess.c */ -#define NUM_MULTISUB 1024 static rsRetVal DataRcvd(ptcpsess_t *pThis, char *pData, size_t iLen) { multi_submit_t multiSub; - msg_t *pMsgs[NUM_MULTISUB]; + msg_t *pMsgs[CONF_NUM_MULTISUB]; struct syslogTime stTime; time_t ttGenTime; char *pEnd; @@ -817,7 +816,7 @@ DataRcvd(ptcpsess_t *pThis, char *pData, size_t iLen) datetime.getCurrTime(&stTime, &ttGenTime); multiSub.ppMsgs = pMsgs; - multiSub.maxElem = NUM_MULTISUB; + multiSub.maxElem = CONF_NUM_MULTISUB; multiSub.nElem = 0; /* We now copy the message to the session buffer. */ @@ -832,7 +831,6 @@ DataRcvd(ptcpsess_t *pThis, char *pData, size_t iLen) finalize_it: RETiRet; } -#undef NUM_MULTISUB /****************************************** --END-- TCP SUPPORT FUNCTIONS ***********************************/ |