|
 |
ba8166 |
diff -up rsyslog-8.37.0/plugins/imptcp/imptcp.c.orig rsyslog-8.37.0/plugins/imptcp/imptcp.c
|
|
|
ba8166 |
--- rsyslog-8.37.0/plugins/imptcp/imptcp.c.orig 2022-05-09 12:22:59.050623119 +0200
|
|
|
ba8166 |
+++ rsyslog-8.37.0/plugins/imptcp/imptcp.c 2022-05-09 12:34:39.979854853 +0200
|
|
|
ba8166 |
@@ -1032,7 +1032,10 @@ processDataRcvd(ptcpsess_t *const __rest
|
|
|
ba8166 |
if(pThis->iOctetsRemain <= 200000000) {
|
|
|
ba8166 |
pThis->iOctetsRemain = pThis->iOctetsRemain * 10 + c - '0';
|
|
|
ba8166 |
}
|
|
|
ba8166 |
- *(pThis->pMsg + pThis->iMsg++) = c;
|
|
|
ba8166 |
+ // *(pThis->pMsg + pThis->iMsg++) = c;
|
|
|
ba8166 |
+ if(pThis->iMsg < iMaxLine) {
|
|
|
ba8166 |
+ *(pThis->pMsg + pThis->iMsg++) = c;
|
|
|
ba8166 |
+ }
|
|
|
ba8166 |
} else { /* done with the octet count, so this must be the SP terminator */
|
|
|
ba8166 |
DBGPRINTF("TCP Message with octet-counter, size %d.\n", pThis->iOctetsRemain);
|
|
|
ba8166 |
prop.GetString(pThis->peerName, &propPeerName, &lenPeerName);
|
|
|
ba8166 |
diff -up rsyslog-8.37.0/runtime/tcps_sess.c.orig rsyslog-8.37.0/runtime/tcps_sess.c
|
|
|
ba8166 |
--- rsyslog-8.37.0/runtime/tcps_sess.c.orig 2022-05-09 12:23:12.789627661 +0200
|
|
|
ba8166 |
+++ rsyslog-8.37.0/runtime/tcps_sess.c 2022-05-09 12:36:51.426898549 +0200
|
|
|
ba8166 |
@@ -389,7 +389,10 @@ processDataRcvd(tcps_sess_t *pThis,
|
|
|
ba8166 |
if(pThis->iOctetsRemain <= 200000000) {
|
|
|
ba8166 |
pThis->iOctetsRemain = pThis->iOctetsRemain * 10 + c - '0';
|
|
|
ba8166 |
}
|
|
|
ba8166 |
- *(pThis->pMsg + pThis->iMsg++) = c;
|
|
|
ba8166 |
+ // *(pThis->pMsg + pThis->iMsg++) = c;
|
|
|
ba8166 |
+ if(pThis->iMsg < iMaxLine) {
|
|
|
ba8166 |
+ *(pThis->pMsg + pThis->iMsg++) = c;
|
|
|
ba8166 |
+ }
|
|
|
ba8166 |
} else { /* done with the octet count, so this must be the SP terminator */
|
|
|
ba8166 |
DBGPRINTF("TCP Message with octet-counter, size %d.\n", pThis->iOctetsRemain);
|
|
|
ba8166 |
prop.GetString(pThis->fromHost, &propPeerName, &lenPeerName);
|