summaryrefslogtreecommitdiffstats
path: root/tcps_sess.c
diff options
context:
space:
mode:
Diffstat (limited to 'tcps_sess.c')
-rw-r--r--tcps_sess.c6
1 files changed, 3 insertions, 3 deletions
diff --git a/tcps_sess.c b/tcps_sess.c
index e7149cb7..be06a4e1 100644
--- a/tcps_sess.c
+++ b/tcps_sess.c
@@ -265,11 +265,11 @@ defaultDoSubmitMessage(tcps_sess_t *pThis, struct syslogTime *stTime, time_t ttG
STATSCOUNTER_INC(pThis->pLstnInfo->ctrSubmit, pThis->pLstnInfo->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));
}
@@ -490,7 +490,7 @@ DataRcvd(tcps_sess_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: