From b61e5fffc42c98b49a18a95c297653fb0ba06b72 Mon Sep 17 00:00:00 2001
From: Rainer Gerhards <rgerhards@adiscon.com>
Date: Tue, 2 Jun 2009 13:11:18 +0200
Subject: strmsrv now supports KEEPALIVE socket option

---
 runtime/strmsrv.c | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

(limited to 'runtime/strmsrv.c')

diff --git a/runtime/strmsrv.c b/runtime/strmsrv.c
index 6c803ee2..3dc53a97 100644
--- a/runtime/strmsrv.c
+++ b/runtime/strmsrv.c
@@ -434,6 +434,10 @@ SessAccept(strmsrv_t *pThis, strmLstnPortList_t *pLstnInfo, strms_sess_t **ppSes
 		ABORT_FINALIZE(RS_RET_MAX_SESS_REACHED);
 	}
 
+	if(pThis->bUseKeepAlive) {
+		CHKiRet(netstrm.EnableKeepAlive(pNewStrm));
+	}
+
 	/* we found a free spot and can construct our session object */
 	CHKiRet(strms_sess.Construct(&pSess));
 	CHKiRet(strms_sess.SetStrmsrv(pSess, pThis));
@@ -756,6 +760,15 @@ SetUsrP(strmsrv_t *pThis, void *pUsr)
 	RETiRet;
 }
 
+static rsRetVal
+SetKeepAlive(strmsrv_t *pThis, int iVal)
+{
+	DEFiRet;
+	dbgprintf("keep-alive set to %d\n", iVal);
+	pThis->bUseKeepAlive = iVal;
+	RETiRet;
+}
+
 static rsRetVal
 SetOnCharRcvd(strmsrv_t *pThis, rsRetVal (*OnCharRcvd)(strms_sess_t*, uchar))
 {
@@ -864,6 +877,7 @@ CODESTARTobjQueryInterface(strmsrv)
 	pIf->create_strm_socket = create_strm_socket;
 	pIf->Run = Run;
 
+	pIf->SetKeepAlive = SetKeepAlive;
 	pIf->SetUsrP = SetUsrP;
 	pIf->SetInputName = SetInputName;
 	pIf->SetSessMax = SetSessMax;
-- 
cgit