Commit a53c12e0 authored by Florian Fittkau's avatar Florian Fittkau

minor

parent e54d394f
......@@ -19,7 +19,6 @@ import explorviz.live_trace_processing.record.ISerializableRecord;
import explorviz.live_trace_processing.record.misc.StringRegistryRecord;
import explorviz.live_trace_processing.record.misc.TerminateRecord;
import explorviz.live_trace_processing.record.misc.TimedPeriodRecord;
import explorviz.live_trace_processing.record.trace.Trace;
import explorviz.live_trace_processing.writer.IRecordSender;
import explorviz.live_trace_processing.writer.IStringRecordSender;
import explorviz.live_trace_processing.writer.IWriter;
......@@ -84,7 +83,7 @@ IRecordSender {
@Override
protected void processRecord(final IRecord record) {
if (record instanceof Trace) {
if (record instanceof ISerializableRecord) {
System.out.println(record);
final ISerializableRecord serializableRecord = (ISerializableRecord) record;
if (buffer.remaining() < serializableRecord.getRecordSizeInBytes()) {
......@@ -109,6 +108,7 @@ IRecordSender {
try {
buffer.flip();
while (buffer.hasRemaining()) {
System.out.println("writing... " + buffer.remaining());
socketChannel.write(buffer);
}
doDisconnectIfNessecary();
......
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