From 3a111aa6043e204d49fa54a5168761355f5f2839 Mon Sep 17 00:00:00 2001
From: Chris Broekema <broekema@astron.nl>
Date: Tue, 13 Feb 2007 08:28:10 +0000
Subject: [PATCH] BugID: 1011 Add send and recv kernel buffer size to
constructor of TH_Socket.
---
Appl/CEP/CS1/CS1_InputSection/src/Connector.cc | 16 ++++++++++------
1 file changed, 10 insertions(+), 6 deletions(-)
diff --git a/Appl/CEP/CS1/CS1_InputSection/src/Connector.cc b/Appl/CEP/CS1/CS1_InputSection/src/Connector.cc
index 14b1e15f855..e95e1d9435e 100644
--- a/Appl/CEP/CS1/CS1_InputSection/src/Connector.cc
+++ b/Appl/CEP/CS1/CS1_InputSection/src/Connector.cc
@@ -67,7 +67,7 @@ namespace LOFAR {
theTH = new TH_Null();
} else if (transportType=="TCP") {
string service = ps.getString(key + ".port");
- if (!isReceiver) {
+ if (isReceiver) {
theTH = new TH_Socket(service,
true,
Socket::TCP,
@@ -83,20 +83,24 @@ namespace LOFAR {
}
} else if (transportType == "UDP") {
string service = ps.getString(key+".port");
- if (!isReceiver) {
+ if (isReceiver) {
theTH = new TH_Socket(service,
true,
Socket::UDP,
- false);
+ 5,
+ false,
+ 8 * 1024 * 1024,
+ -1);
+
} else {
string host = ps.getString(key+".host");
theTH = new TH_Socket(host,
service,
true,
Socket::UDP,
- false);
-
-
+ false,
+ -1,
+ 8 * 1024 * 1024);
}
} else {
ASSERTSTR(false, "TransportHolder " << transportType << " unknown to Connector");
--
GitLab