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/imfile/imfile.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/imfile/imfile.c')
| -rw-r--r-- | plugins/imfile/imfile.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/plugins/imfile/imfile.c b/plugins/imfile/imfile.c index 453b6b05..64a7e032 100644 --- a/plugins/imfile/imfile.c +++ b/plugins/imfile/imfile.c @@ -191,7 +191,7 @@ static rsRetVal enqLine(fileInfo_t *pInfo, cstr_t *cstrLine) MsgSetRuleset(pMsg, pInfo->pRuleset); pInfo->multiSub.ppMsgs[pInfo->multiSub.nElem++] = pMsg; if(pInfo->multiSub.nElem == pInfo->multiSub.maxElem) - CHKiRet(multiSubmitMsg(&pInfo->multiSub)); + CHKiRet(multiSubmitMsg2(&pInfo->multiSub, NULL)); finalize_it: RETiRet; } @@ -306,7 +306,7 @@ static rsRetVal pollFile(fileInfo_t *pThis, int *pbHadFileData) finalize_it: if(pThis->multiSub.nElem > 0) { /* submit everything that was not yet submitted */ - CHKiRet(multiSubmitMsg(&pThis->multiSub)); + CHKiRet(multiSubmitMsg2(&pThis->multiSub, NULL)); } ; /*EMPTY STATEMENT - needed to keep compiler happy - see below! */ /* Note: the problem above is that pthread:cleanup_pop() is a macro which |