diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2012-10-09 18:54:25 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2012-10-09 18:54:25 +0200 |
| commit | 4269e4578118f089021bc15cdd82bb0182a97aaf (patch) | |
| tree | 0b06ba329dcb9ace0c11b4f6764d9ce5dcd44de3 /plugins/imptcp/imptcp.c | |
| parent | bf092de0fb3a043dea59900ec9a7b34f7384ca46 (diff) | |
| download | rsyslog-4269e4578118f089021bc15cdd82bb0182a97aaf.tar.gz rsyslog-4269e4578118f089021bc15cdd82bb0182a97aaf.tar.bz2 rsyslog-4269e4578118f089021bc15cdd82bb0182a97aaf.zip | |
new ratelimit: interface plumbing added
no actual implementation yet done
Diffstat (limited to 'plugins/imptcp/imptcp.c')
| -rw-r--r-- | plugins/imptcp/imptcp.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/plugins/imptcp/imptcp.c b/plugins/imptcp/imptcp.c index 8150fc33..f804a70e 100644 --- a/plugins/imptcp/imptcp.c +++ b/plugins/imptcp/imptcp.c @@ -680,11 +680,11 @@ doSubmitMsg(ptcpsess_t *pThis, struct syslogTime *stTime, time_t ttGenTime, mult STATSCOUNTER_INC(pThis->pLstn->ctrSubmit, pThis->pLstn->mutCtrSubmit); if(pMultiSub == NULL) { - CHKiRet(submitMsg(pMsg)); + CHKiRet(submitMsg2(pMsg, NULL)); } else { pMultiSub->ppMsgs[pMultiSub->nElem++] = pMsg; if(pMultiSub->nElem == pMultiSub->maxElem) - CHKiRet(multiSubmitMsg(pMultiSub)); + CHKiRet(multiSubmitMsg2(pMultiSub, NULL)); } @@ -833,7 +833,7 @@ DataRcvd(ptcpsess_t *pThis, char *pData, size_t iLen) if(multiSub.nElem > 0) { /* submit anything that was not yet submitted */ - CHKiRet(multiSubmitMsg(&multiSub)); + CHKiRet(multiSubmitMsg2(&multiSub, NULL)); } finalize_it: |