Commit 9fad0ea6 authored by Florian Fittkau's avatar Florian Fittkau

toward trace reduction over multiple hosts

parent 53746684
......@@ -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;
......
......@@ -96,7 +96,8 @@ class TraceReconstructionBuffer {
if (beforeEvent.getRuntimeStatisticInformation().getAverage() < 0) {
final long time = abstractAfterEventRecord.getMethodDuration();
beforeEvent.getRuntimeStatisticInformation().set(1, time, time * time);
// beforeEvent.getRuntimeStatisticInformation().set(1,
// time, time * time);
}
}
} else if (event instanceof AbstractAfterFailedEventRecord) {
......@@ -106,7 +107,8 @@ class TraceReconstructionBuffer {
if (beforeEvent.getRuntimeStatisticInformation().getAverage() < 0) {
final long time = abstractAfterFailedEventRecord.getMethodDuration();
beforeEvent.getRuntimeStatisticInformation().set(1, time, time * time);
// beforeEvent.getRuntimeStatisticInformation().set(1,
// time, time * time);
}
}
}
......
......@@ -32,18 +32,22 @@ class TracesSummarizationBuffer {
for (int i = 0; i < aggregatedRecords.size(); i++) {
final AbstractEventRecord event = aggregatedRecords.get(i);
final AbstractEventRecord event2 = records.get(i);
event.getHostApplicationMetadataList().addAll(
event2.getHostApplicationMetadataList());
if (event instanceof AbstractBeforeEventRecord) {
final AbstractBeforeEventRecord abstractBeforeEventRecord = (AbstractBeforeEventRecord) event;
final AbstractBeforeEventRecord abstractBeforeEventRecord2 = (AbstractBeforeEventRecord) records
.get(i);
final AbstractBeforeEventRecord abstractBeforeEventRecord2 = (AbstractBeforeEventRecord) event2;
if (abstractBeforeEventRecord2 instanceof AbstractBeforeOperationEventRecord) {
final AbstractBeforeOperationEventRecord abstractBeforeOperationEventRecord = (AbstractBeforeOperationEventRecord) abstractBeforeEventRecord2;
abstractBeforeEventRecord
.getRuntimeStatisticInformation()
.merge(abstractBeforeOperationEventRecord
.getRuntimeStatisticInformation(),
abstractBeforeOperationEventRecord.getObjectId());
.getRuntimeStatisticInformation()
.merge(abstractBeforeOperationEventRecord
.getRuntimeStatisticInformation(),
abstractBeforeOperationEventRecord.getObjectId());
} else {
abstractBeforeEventRecord.getRuntimeStatisticInformation().merge(
abstractBeforeEventRecord2.getRuntimeStatisticInformation(), 0);
......
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