summaryrefslogtreecommitdiffstats
path: root/tcpsrv.c
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2011-04-01 16:26:21 +0200
committerRainer Gerhards <rgerhards@adiscon.com>2011-04-01 16:26:21 +0200
commit0edf73f88096f3656da466027417d04ce7a2511c (patch)
treeca890d2481488afad0385c40b56a62ce6ec42a40 /tcpsrv.c
parent945bc9bd0d9de984ab11b9faf609b809a1f3cb90 (diff)
downloadrsyslog-0edf73f88096f3656da466027417d04ce7a2511c.tar.gz
rsyslog-0edf73f88096f3656da466027417d04ce7a2511c.tar.xz
rsyslog-0edf73f88096f3656da466027417d04ce7a2511c.zip
added new config directive $InputTCPFlowControl...
... to select if tcp received messages shall be flagged as light delayable or not.
Diffstat (limited to 'tcpsrv.c')
-rw-r--r--tcpsrv.c14
1 files changed, 14 insertions, 0 deletions
diff --git a/tcpsrv.c b/tcpsrv.c
index e8d79142..3060fe05 100644
--- a/tcpsrv.c
+++ b/tcpsrv.c
@@ -716,6 +716,7 @@ BEGINobjConstruct(tcpsrv) /* be sure to specify the object type also in END macr
pThis->addtlFrameDelim = TCPSRV_NO_ADDTL_DELIMITER;
pThis->bDisableLFDelim = 0;
pThis->OnMsgReceive = NULL;
+ pThis->bUseFlowControl = 1;
ENDobjConstruct(tcpsrv)
@@ -991,6 +992,18 @@ SetLstnMax(tcpsrv_t *pThis, int iMax)
}
+/* set if flow control shall be supported
+ */
+static rsRetVal
+SetUseFlowControl(tcpsrv_t *pThis, int bUseFlowControl)
+{
+ DEFiRet;
+ ISOBJ_TYPE_assert(pThis, tcpsrv);
+ pThis->bUseFlowControl = bUseFlowControl;
+ RETiRet;
+}
+
+
/* set max number of sessions
* this must be called before ConstructFinalize, or it will have no effect!
* rgerhards, 2009-04-09
@@ -1033,6 +1046,7 @@ CODESTARTobjQueryInterface(tcpsrv)
pIf->SetAddtlFrameDelim = SetAddtlFrameDelim;
pIf->SetbDisableLFDelim = SetbDisableLFDelim;
pIf->SetSessMax = SetSessMax;
+ pIf->SetUseFlowControl = SetUseFlowControl;
pIf->SetLstnMax = SetLstnMax;
pIf->SetDrvrMode = SetDrvrMode;
pIf->SetDrvrAuthMode = SetDrvrAuthMode;