diff --git a/src/explorviz/live_trace_processing/connector/TCPConnector.java b/src/explorviz/live_trace_processing/connector/TCPConnector.java index af953a283cc3ce23f9d29196d53110d166dab4ff..0ff9d3c5b67d10fb22584611d552e09498c18638 100644 --- a/src/explorviz/live_trace_processing/connector/TCPConnector.java +++ b/src/explorviz/live_trace_processing/connector/TCPConnector.java @@ -24,10 +24,7 @@ public class TCPConnector extends AbstractSink implements IWriter, IStringRecord private SocketChannel socketChannel; - private final StringRegistry stringRegistry = new StringRegistry(this); // TODO - // clear - // after - // disconnect? + private final StringRegistry stringRegistry = new StringRegistry(this); private final ByteBuffer buffer = ByteBuffer .allocateDirect(Constants.MONITORING_MESSAGE_BUFFER_SIZE); @@ -107,7 +104,6 @@ public class TCPConnector extends AbstractSink implements IWriter, IStringRecord doDisconnectIfNessecary(); } catch (final IOException e) { System.out.println("WARNING: Connection was closed - possible data loss"); - // TODO reconnect in non-load-balancing mode try { socketChannel.close(); } catch (final IOException e1) {