diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-06-18 13:22:21 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-06-18 13:22:21 +0200 |
| commit | 8628312396b1535c41124e499d292f4d1e77d955 (patch) | |
| tree | d294b3fc3f9adc29b3b9137ce2bff55c21fdee81 /tcps_sess.c | |
| parent | f529e8b2c3bb2c087bfba3fc5610a66fdbe1a8ae (diff) | |
| download | rsyslog-8628312396b1535c41124e499d292f4d1e77d955.tar.gz rsyslog-8628312396b1535c41124e499d292f4d1e77d955.tar.xz rsyslog-8628312396b1535c41124e499d292f4d1e77d955.zip | |
cleaned up/optimized raw message handling in msg object
Diffstat (limited to 'tcps_sess.c')
| -rw-r--r-- | tcps_sess.c | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/tcps_sess.c b/tcps_sess.c index 9353571c..e0bec949 100644 --- a/tcps_sess.c +++ b/tcps_sess.c @@ -234,10 +234,8 @@ defaultDoSubmitMessage(tcps_sess_t *pThis, struct syslogTime *stTime, time_t ttG /* we now create our own message object and submit it to the queue */ CHKiRet(msgConstructWithTime(&pMsg, stTime, ttGenTime)); - /* first trim the buffer to what we have actually received */ - CHKmalloc(pMsg->pszRawMsg = malloc(sizeof(uchar) * pThis->iMsg)); - memcpy(pMsg->pszRawMsg, pThis->pMsg, pThis->iMsg); - pMsg->iLenRawMsg = pThis->iMsg; +dbgprintf("defaultDoSubmit, iMsg %d\n", pThis->iMsg); + MsgSetRawMsg(pMsg, (char*)pThis->pMsg, pThis->iMsg); MsgSetInputName(pMsg, pThis->pLstnInfo->pszInputName, pThis->pLstnInfo->lenInputName); MsgSetFlowControlType(pMsg, eFLOWCTL_LIGHT_DELAY); pMsg->msgFlags = NEEDS_PARSING | PARSE_HOSTNAME; |