diff --git a/src/explorviz/live_trace_processing/connector/TCPConnector.java b/src/explorviz/live_trace_processing/connector/TCPConnector.java index dbe4bc9770e4394f3132254e8c394b76336e1efb..baf9121ef8c10a12354edd9447898fd64cff5916 100644 --- a/src/explorviz/live_trace_processing/connector/TCPConnector.java +++ b/src/explorviz/live_trace_processing/connector/TCPConnector.java @@ -20,6 +20,8 @@ public class TCPConnector extends AbstractSink implements IWriter { private final Configuration configuration; + private ByteBuffer byteBuffer; + public TCPConnector(final String hostname, final int port, final Configuration configuration) { this.configuration = configuration; try { @@ -65,7 +67,10 @@ public class TCPConnector extends AbstractSink implements IWriter { @Override protected void processRecord(final IRecord record, final HostApplicationMetaDataRecord hostApplicationMetaData) { - // send(); TODO + if (record.getRecordSizeInBytes() > byteBuffer.remaining()) { + send(byteBuffer); + } + record.putIntoByteBuffer(byteBuffer); } private void send(final ByteBuffer buffer) {