Skip to content
Snippets Groups Projects
Commit 3a111aa6 authored by Chris Broekema's avatar Chris Broekema
Browse files

BugID: 1011

Add send and recv kernel buffer size to constructor of TH_Socket.
parent b19ac6fe
No related branches found
No related tags found
No related merge requests found
...@@ -67,7 +67,7 @@ namespace LOFAR { ...@@ -67,7 +67,7 @@ namespace LOFAR {
theTH = new TH_Null(); theTH = new TH_Null();
} else if (transportType=="TCP") { } else if (transportType=="TCP") {
string service = ps.getString(key + ".port"); string service = ps.getString(key + ".port");
if (!isReceiver) { if (isReceiver) {
theTH = new TH_Socket(service, theTH = new TH_Socket(service,
true, true,
Socket::TCP, Socket::TCP,
...@@ -83,20 +83,24 @@ namespace LOFAR { ...@@ -83,20 +83,24 @@ namespace LOFAR {
} }
} else if (transportType == "UDP") { } else if (transportType == "UDP") {
string service = ps.getString(key+".port"); string service = ps.getString(key+".port");
if (!isReceiver) { if (isReceiver) {
theTH = new TH_Socket(service, theTH = new TH_Socket(service,
true, true,
Socket::UDP, Socket::UDP,
false); 5,
false,
8 * 1024 * 1024,
-1);
} else { } else {
string host = ps.getString(key+".host"); string host = ps.getString(key+".host");
theTH = new TH_Socket(host, theTH = new TH_Socket(host,
service, service,
true, true,
Socket::UDP, Socket::UDP,
false); false,
-1,
8 * 1024 * 1024);
} }
} else { } else {
ASSERTSTR(false, "TransportHolder " << transportType << " unknown to Connector"); ASSERTSTR(false, "TransportHolder " << transportType << " unknown to Connector");
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment