Skip to content
Snippets Groups Projects
Commit b1b8e899 authored by Florian Fittkau's avatar Florian Fittkau
Browse files

UnsafeBits try

parent 8e71ed59
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
src/explorviz/hpc_monitoring/reader/TCPReader.java
+ 21
− 21
View file @ b1b8e899
......@@ -30,7 +30,7 @@ import kieker.common.configuration.Configuration;
import kieker.common.logging.Log;
import kieker.common.logging.LogFactory;
import kieker.common.record.IMonitoringRecord;
import explorviz.hpc_monitoring.Bits;
import explorviz.hpc_monitoring.UnsafeBits;
import explorviz.hpc_monitoring.record.Trace;
import explorviz.hpc_monitoring.record.events.*;
......@@ -210,7 +210,7 @@ public final class TCPReader extends AbstractReaderPlugin {
return createUnreadBytesArray(b, readSize, offset, false);
}
final int clazzId = Bits.getInt(b, offset);
final int clazzId = UnsafeBits.getInt(b, offset);
offset += 4;
switch (clazzId) {
......@@ -245,13 +245,13 @@ public final class TCPReader extends AbstractReaderPlugin {
switch (clazzId) {
case 0: {
final long traceId = Bits.getLong(b, offset);
final long traceId = UnsafeBits.getLong(b, offset);
offset += 8;
final Integer hostnameId = Bits.getInt(b, offset);
final Integer hostnameId = UnsafeBits.getInt(b, offset);
offset += 4;
final long parentTraceId = Bits.getLong(b, offset);
final long parentTraceId = UnsafeBits.getLong(b, offset);
offset += 8;
final int parentOrderId = Bits.getInt(b, offset);
final int parentOrderId = UnsafeBits.getInt(b, offset);
offset += 4;
record = new Trace(traceId,
......@@ -260,13 +260,13 @@ public final class TCPReader extends AbstractReaderPlugin {
break;
}
case 1: {
final long timestamp = Bits.getLong(b, offset);
final long timestamp = UnsafeBits.getLong(b, offset);
offset += 8;
final long traceId = Bits.getLong(b, offset);
final long traceId = UnsafeBits.getLong(b, offset);
offset += 8;
final int orderIndex = Bits.getInt(b, offset);
final int orderIndex = UnsafeBits.getInt(b, offset);
offset += 4;
final Integer operationId = Bits.getInt(b, offset);
final Integer operationId = UnsafeBits.getInt(b, offset);
offset += 4;
record = new BeforeOperationEvent(timestamp, traceId,
......@@ -274,15 +274,15 @@ public final class TCPReader extends AbstractReaderPlugin {
break;
}
case 2: {
final long timestamp = Bits.getLong(b, offset);
final long timestamp = UnsafeBits.getLong(b, offset);
offset += 8;
final long traceId = Bits.getLong(b, offset);
final long traceId = UnsafeBits.getLong(b, offset);
offset += 8;
final int orderIndex = Bits.getInt(b, offset);
final int orderIndex = UnsafeBits.getInt(b, offset);
offset += 4;
final Integer operationId = Bits.getInt(b, offset);
final Integer operationId = UnsafeBits.getInt(b, offset);
offset += 4;
final Integer causeId = Bits.getInt(b, offset);
final Integer causeId = UnsafeBits.getInt(b, offset);
offset += 4;
record = new AfterFailedOperationEvent(timestamp, traceId,
......@@ -291,13 +291,13 @@ public final class TCPReader extends AbstractReaderPlugin {
break;
}
case 3: {
final long timestamp = Bits.getLong(b, offset);
final long timestamp = UnsafeBits.getLong(b, offset);
offset += 8;
final long traceId = Bits.getLong(b, offset);
final long traceId = UnsafeBits.getLong(b, offset);
offset += 8;
final int orderIndex = Bits.getInt(b, offset);
final int orderIndex = UnsafeBits.getInt(b, offset);
offset += 4;
final Integer operationId = Bits.getInt(b, offset);
final Integer operationId = UnsafeBits.getInt(b, offset);
offset += 4;
record = new AfterOperationEvent(timestamp, traceId,
......@@ -305,9 +305,9 @@ public final class TCPReader extends AbstractReaderPlugin {
break;
}
case 4: {
final Integer mapId = Bits.getInt(b, offset);
final Integer mapId = UnsafeBits.getInt(b, offset);
offset += 4;
final int stringLength = Bits.getInt(b, offset);
final int stringLength = UnsafeBits.getInt(b, offset);
offset += 4;
if ((readSize - offset) < stringLength) {
......
src/explorviz/worker/main/WorkerController.xtend
+ 14
− 12
View file @ b1b8e899
......@@ -19,24 +19,26 @@ class WorkerController {
analysisInstance = new AnalysisController()
val tcpReader = initTCPReader()
val eventTraceReconstructionFilter = initEventRecordTraceReconstructionFilter()
val aggregationFilter = initAggregationFilter()
val timer = initTimer()
val tcpConnector = initTCPConnector()
analysisInstance.connect(tcpReader, TCPReader::OUTPUT_PORT_NAME_RECORDS, eventTraceReconstructionFilter,
EventRecordTraceReconstructionFilter::INPUT_PORT_NAME_TRACE_RECORDS)
val countingThroughputFilter = initCountingThroughputFilter()
val teeFilter = initTeeFilter()
analysisInstance.connect(tcpReader, TCPReader::OUTPUT_PORT_NAME_RECORDS, countingThroughputFilter,
CountingThroughputFilter::INPUT_PORT_NAME_OBJECTS)
analysisInstance.connect(countingThroughputFilter,
CountingThroughputFilter::OUTPUT_PORT_NAME_THROUGHPUT, teeFilter,
TeeFilter::INPUT_PORT_NAME_EVENTS)
analysisInstance.connect(eventTraceReconstructionFilter,
EventRecordTraceReconstructionFilter::OUTPUT_PORT_NAME_TRACE_VALID, aggregationFilter,
TraceEventRecordAggregationFilter::INPUT_PORT_NAME_TRACES)
// analysisInstance.connect(eventTraceReconstructionFilter,
// EventRecordTraceReconstructionFilter::OUTPUT_PORT_NAME_TRACE_VALID, aggregationFilter,
// TraceEventRecordAggregationFilter::INPUT_PORT_NAME_TRACES)
// analysisInstance.connect(eventTraceReconstructionFilter,
// EventRecordTraceReconstructionFilter::OUTPUT_PORT_NAME_TRACE_INVALID, tcpConnector,
// RabbitMQConnector::INPUT_PORT_NAME_INVALID_TRACES)
analysisInstance.connect(timer, TimeReader::OUTPUT_PORT_NAME_TIMESTAMPS, aggregationFilter,
TraceEventRecordAggregationFilter::INPUT_PORT_NAME_TIME_EVENT)
//
// analysisInstance.connect(timer, TimeReader::OUTPUT_PORT_NAME_TIMESTAMPS, aggregationFilter,
// TraceEventRecordAggregationFilter::INPUT_PORT_NAME_TIME_EVENT)
// analysisInstance.connect(aggregationFilter,
// TraceEventRecordAggregationFilter::OUTPUT_PORT_NAME_TRACES, tcpConnector,
// RabbitMQConnector::INPUT_PORT_NAME_VALID_TRACES)
......
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