Skip to content
Snippets Groups Projects
Commit 221d61f9 authored by John Romein's avatar John Romein
Browse files

BugID: 225

Use BGL_Connection to achieve higher bandwidth.
parent 6e043c2a
No related branches found
No related tags found
No related merge requests found
...@@ -22,7 +22,7 @@ ...@@ -22,7 +22,7 @@
#include <CS1_Interface/Stub_BGL.h> #include <CS1_Interface/Stub_BGL.h>
#include <Transport/TH_Socket.h> #include <Transport/TH_Socket.h>
#include <Transport/Connection.h> #include <Transport/BGLConnection.h>
namespace LOFAR { namespace LOFAR {
...@@ -84,10 +84,10 @@ void Stub_BGL::connect(unsigned cellNr, unsigned nodeNr, TinyDataManager &dm, un ...@@ -84,10 +84,10 @@ void Stub_BGL::connect(unsigned cellNr, unsigned nodeNr, TinyDataManager &dm, un
itsTHs[index] = itsIAmOnBGL ? newClientTH(cellNr, nodeNr) : newServerTH(cellNr, nodeNr); itsTHs[index] = itsIAmOnBGL ? newClientTH(cellNr, nodeNr) : newServerTH(cellNr, nodeNr);
if (itsIsInput) { if (itsIsInput) {
itsConnections[index] = new Connection("output", 0, dm.getGeneralInHolder(channel), itsTHs[index], true); itsConnections[index] = new BGLConnection("output", 0, dm.getGeneralInHolder(channel), itsTHs[index]);
dm.setInConnection(channel, itsConnections[index]); dm.setInConnection(channel, itsConnections[index]);
} else { } else {
itsConnections[index] = new Connection("input", dm.getGeneralOutHolder(channel), 0, itsTHs[index], true); itsConnections[index] = new BGLConnection("input", dm.getGeneralOutHolder(channel), 0, itsTHs[index]);
dm.setOutConnection(channel, itsConnections[index]); dm.setOutConnection(channel, itsConnections[index]);
} }
}; };
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment