From e853e503e4419aa5e72d1964f6f4ef7641b5a4e0 Mon Sep 17 00:00:00 2001
From: Florian Fittkau <ffi@informatik.uni-kiel.de>
Date: Fri, 15 Nov 2013 19:38:04 +0100
Subject: [PATCH] working on tcp connector
---
.../live_trace_processing/connector/TCPConnector.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/src/explorviz/live_trace_processing/connector/TCPConnector.java b/src/explorviz/live_trace_processing/connector/TCPConnector.java
index dbe4bc9..baf9121 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) {
--
GitLab