Commit e36eaf0f authored by Florian Fittkau's avatar Florian Fittkau

...

parent 8615e1f0
......@@ -25,7 +25,7 @@ import explorviz.live_trace_processing.writer.IStringRecordSender;
import explorviz.live_trace_processing.writer.IWriter;
public class TCPConnector extends AbstractSink implements IWriter, IStringRecordSender,
IRecordSender {
IRecordSender {
private URL providerURL;
private SocketChannel socketChannel;
......@@ -85,12 +85,12 @@ public class TCPConnector extends AbstractSink implements IWriter, IStringRecord
@Override
public void sendOutStringRecord(final StringRegistryRecord record) {
while (!finishedSendingStrings) {
try {
Thread.sleep(1);
} catch (final InterruptedException e) {
}
}
// while (!finishedSendingStrings) {
// try {
// Thread.sleep(1);
// } catch (final InterruptedException e) {
// }
// }
if (record.getRecordSizeInBytes() > stringBuffer.remaining()) {
prioritizedSend(stringBuffer);
......@@ -181,7 +181,7 @@ public class TCPConnector extends AbstractSink implements IWriter, IStringRecord
}
} catch (final IOException e) {
System.out
.println("WARNING: Connection was closed during String sending - possible data loss");
.println("WARNING: Connection was closed during String sending - possible data loss");
try {
socketChannel.close();
} catch (final IOException e1) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment