diff options
Diffstat (limited to 'plugins/imptcp/imptcp.c')
| -rw-r--r-- | plugins/imptcp/imptcp.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/plugins/imptcp/imptcp.c b/plugins/imptcp/imptcp.c index 70bd9993..a568e5fe 100644 --- a/plugins/imptcp/imptcp.c +++ b/plugins/imptcp/imptcp.c @@ -820,11 +820,10 @@ processDataRcvd(ptcpsess_t *pThis, char c, struct syslogTime *stTime, time_t ttG * EXTRACT from tcps_sess.c */ static rsRetVal -DataRcvdUncompressed(ptcpsess_t *pThis, char *pData, size_t iLen, time_t ttGenTime) +DataRcvdUncompressed(ptcpsess_t *pThis, char *pData, size_t iLen, struct syslogTime *stTime, time_t ttGenTime) { multi_submit_t multiSub; msg_t *pMsgs[CONF_NUM_MULTISUB]; - struct syslogTime stTime; char *pEnd; DEFiRet; @@ -838,7 +837,7 @@ for(i=0;i<iLen;++i) dbgprintf("'\n"); } if(ttGenTime == 0) - datetime.getCurrTime(&stTime, &ttGenTime); + datetime.getCurrTime(stTime, &ttGenTime); multiSub.ppMsgs = pMsgs; multiSub.maxElem = CONF_NUM_MULTISUB; multiSub.nElem = 0; @@ -847,8 +846,7 @@ dbgprintf("'\n"); pEnd = pData + iLen; /* this is one off, which is intensional */ while(pData < pEnd) { -dbgprintf("DDDDD: processing char[%x] '%c'\n", *pData, *pData); - CHKiRet(processDataRcvd(pThis, *pData++, &stTime, ttGenTime, &multiSub)); + CHKiRet(processDataRcvd(pThis, *pData++, stTime, ttGenTime, &multiSub)); } iRet = multiSubmitFlush(&multiSub); @@ -904,7 +902,7 @@ dbgprintf("DDDD; inside zlib init code\n"); if(outavail != 0) { outtotal += outavail; pThis->pLstn->rcvdDecompressed += outavail; - CHKiRet(DataRcvdUncompressed(pThis, (char*)zipBuf, outavail, ttGenTime)); + CHKiRet(DataRcvdUncompressed(pThis, (char*)zipBuf, outavail, &stTime, ttGenTime)); } } while (pThis->zstrm.avail_out == 0); @@ -916,12 +914,13 @@ finalize_it: static rsRetVal DataRcvd(ptcpsess_t *pThis, char *pData, size_t iLen) { + struct syslogTime stTime; DEFiRet; pThis->pLstn->rcvdBytes += iLen; if(pThis->compressionMode >= COMPRESS_STREAM_ALWAYS) iRet = DataRcvdCompressed(pThis, pData, iLen); else - iRet = DataRcvdUncompressed(pThis, pData, iLen, 0); + iRet = DataRcvdUncompressed(pThis, pData, iLen, &stTime, 0); RETiRet; } @@ -1096,6 +1095,7 @@ doZipFinish(ptcpsess_t *pSess) int zRet; /* zlib return state */ DEFiRet; unsigned outavail; + struct syslogTime stTime; uchar zipBuf[32*1024]; // TODO: use "global" one from pSess if(!pSess->bzInitDone) @@ -1112,7 +1112,7 @@ doZipFinish(ptcpsess_t *pSess) outavail = sizeof(zipBuf) - pSess->zstrm.avail_out; if(outavail != 0) { pSess->pLstn->rcvdDecompressed += outavail; - CHKiRet(DataRcvdUncompressed(pSess, (char*)zipBuf, outavail, 0)); // TODO: query time! + CHKiRet(DataRcvdUncompressed(pSess, (char*)zipBuf, outavail, &stTime, 0)); // TODO: query time! } } while (pSess->zstrm.avail_out == 0); |