Skip to content
Snippets Groups Projects
Commit ce9ccc3b authored by phillu's avatar phillu
Browse files

Merge branch 'master' into pst-bachelor

parents 5574fcae c34d3603
Branches
Tags
No related merge requests found
...@@ -12,7 +12,7 @@ import explorviz.live_trace_processing.StringRegistry; ...@@ -12,7 +12,7 @@ import explorviz.live_trace_processing.StringRegistry;
import explorviz.live_trace_processing.configuration.Configuration; import explorviz.live_trace_processing.configuration.Configuration;
import explorviz.live_trace_processing.filter.AbstractSink; import explorviz.live_trace_processing.filter.AbstractSink;
import explorviz.live_trace_processing.record.IRecord; import explorviz.live_trace_processing.record.IRecord;
import explorviz.live_trace_processing.record.ISerilizableRecord; import explorviz.live_trace_processing.record.ISerializableRecord;
import explorviz.live_trace_processing.record.misc.StringRegistryRecord; import explorviz.live_trace_processing.record.misc.StringRegistryRecord;
import explorviz.live_trace_processing.record.misc.TerminateRecord; import explorviz.live_trace_processing.record.misc.TerminateRecord;
import explorviz.live_trace_processing.record.misc.TimedPeriodRecord; import explorviz.live_trace_processing.record.misc.TimedPeriodRecord;
...@@ -72,12 +72,12 @@ public class TCPConnector extends AbstractSink implements IWriter, IStringRecord ...@@ -72,12 +72,12 @@ public class TCPConnector extends AbstractSink implements IWriter, IStringRecord
@Override @Override
protected void processRecord(final IRecord record) { protected void processRecord(final IRecord record) {
if (record instanceof ISerilizableRecord) { if (record instanceof ISerializableRecord) {
final ISerilizableRecord serilizableRecord = (ISerilizableRecord) record; final ISerializableRecord serializableRecord = (ISerializableRecord) record;
if (buffer.remaining() < serilizableRecord.getRecordSizeInBytes()) { if (buffer.remaining() < serializableRecord.getRecordSizeInBytes()) {
send(buffer); send(buffer);
} }
serilizableRecord.putIntoByteBuffer(buffer, stringRegistry); serializableRecord.putIntoByteBuffer(buffer, stringRegistry);
} else if (record instanceof TimedPeriodRecord) { } else if (record instanceof TimedPeriodRecord) {
if (buffer.hasRemaining()) { if (buffer.hasRemaining()) {
send(buffer); send(buffer);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment