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

moved object and opSig to before events

parent dcf3e5ba
No related branches found
No related tags found
No related merge requests found
...@@ -294,16 +294,13 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec ...@@ -294,16 +294,13 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
final long timestamp = buffer.getLong(); final long timestamp = buffer.getLong();
final long traceId = buffer.getLong(); final long traceId = buffer.getLong();
final int orderIndex = buffer.getInt(); final int orderIndex = buffer.getInt();
final int objectId = buffer.getInt();
final int operationId = buffer.getInt();
final int causeId = buffer.getInt(); final int causeId = buffer.getInt();
try { try {
final String operation = stringRegistry.getStringFromId(operationId);
final String cause = stringRegistry.getStringFromId(causeId); final String cause = stringRegistry.getStringFromId(causeId);
putInRingBuffer(new AfterFailedOperationEventRecord(timestamp, traceId, orderIndex, putInRingBuffer(new AfterFailedOperationEventRecord(timestamp, traceId, orderIndex,
objectId, operation, cause, hostApplicationMetadata)); cause, hostApplicationMetadata));
} catch (final IdNotAvailableException e) { } catch (final IdNotAvailableException e) {
putInWaitingMessages(buffer, putInWaitingMessages(buffer,
AfterFailedOperationEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID); AfterFailedOperationEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID);
...@@ -314,19 +311,8 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec ...@@ -314,19 +311,8 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
final long timestamp = buffer.getLong(); final long timestamp = buffer.getLong();
final long traceId = buffer.getLong(); final long traceId = buffer.getLong();
final int orderIndex = buffer.getInt(); final int orderIndex = buffer.getInt();
final int objectId = buffer.getInt(); putInRingBuffer(new AfterOperationEventRecord(timestamp, traceId, orderIndex,
final int operationId = buffer.getInt(); hostApplicationMetadata));
try {
final String operation = stringRegistry.getStringFromId(operationId);
putInRingBuffer(new AfterOperationEventRecord(timestamp, traceId, orderIndex, objectId,
operation, hostApplicationMetadata));
} catch (final IdNotAvailableException e) {
putInWaitingMessages(buffer,
AfterOperationEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID);
}
} }
private final void readInSystemMonitoringRecord(final ByteBuffer buffer) { private final void readInSystemMonitoringRecord(final ByteBuffer buffer) {
...@@ -360,16 +346,13 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec ...@@ -360,16 +346,13 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
final long timestamp = buffer.getLong(); final long timestamp = buffer.getLong();
final long traceId = buffer.getLong(); final long traceId = buffer.getLong();
final int orderIndex = buffer.getInt(); final int orderIndex = buffer.getInt();
final int objectId = buffer.getInt();
final int operationId = buffer.getInt();
final int causeId = buffer.getInt(); final int causeId = buffer.getInt();
try { try {
final String operation = stringRegistry.getStringFromId(operationId);
final String cause = stringRegistry.getStringFromId(causeId); final String cause = stringRegistry.getStringFromId(causeId);
putInRingBuffer(new AfterFailedConstructorEventRecord(timestamp, traceId, orderIndex, putInRingBuffer(new AfterFailedConstructorEventRecord(timestamp, traceId, orderIndex,
objectId, operation, cause, hostApplicationMetadata)); cause, hostApplicationMetadata));
} catch (final IdNotAvailableException e) { } catch (final IdNotAvailableException e) {
putInWaitingMessages(buffer, putInWaitingMessages(buffer,
AfterFailedConstructorEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID); AfterFailedConstructorEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID);
...@@ -380,19 +363,9 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec ...@@ -380,19 +363,9 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
final long timestamp = buffer.getLong(); final long timestamp = buffer.getLong();
final long traceId = buffer.getLong(); final long traceId = buffer.getLong();
final int orderIndex = buffer.getInt(); final int orderIndex = buffer.getInt();
final int objectId = buffer.getInt();
final int operationId = buffer.getInt();
try {
final String operation = stringRegistry.getStringFromId(operationId);
putInRingBuffer(new AfterConstructorEventRecord(timestamp, traceId, orderIndex,
objectId, operation, hostApplicationMetadata));
} catch (final IdNotAvailableException e) {
putInWaitingMessages(buffer,
AfterConstructorEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID);
}
putInRingBuffer(new AfterConstructorEventRecord(timestamp, traceId, orderIndex,
hostApplicationMetadata));
} }
private final void readInBeforeStaticOperationEvent(final ByteBuffer buffer) { private final void readInBeforeStaticOperationEvent(final ByteBuffer buffer) {
...@@ -416,15 +389,13 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec ...@@ -416,15 +389,13 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
final long timestamp = buffer.getLong(); final long timestamp = buffer.getLong();
final long traceId = buffer.getLong(); final long traceId = buffer.getLong();
final int orderIndex = buffer.getInt(); final int orderIndex = buffer.getInt();
final int operationId = buffer.getInt();
final int causeId = buffer.getInt(); final int causeId = buffer.getInt();
try { try {
final String operation = stringRegistry.getStringFromId(operationId);
final String cause = stringRegistry.getStringFromId(causeId); final String cause = stringRegistry.getStringFromId(causeId);
putInRingBuffer(new AfterFailedStaticOperationEventRecord(timestamp, traceId, putInRingBuffer(new AfterFailedStaticOperationEventRecord(timestamp, traceId,
orderIndex, operation, cause, hostApplicationMetadata)); orderIndex, cause, hostApplicationMetadata));
} catch (final IdNotAvailableException e) { } catch (final IdNotAvailableException e) {
putInWaitingMessages(buffer, putInWaitingMessages(buffer,
AfterFailedStaticOperationEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID); AfterFailedStaticOperationEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID);
...@@ -435,18 +406,9 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec ...@@ -435,18 +406,9 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
final long timestamp = buffer.getLong(); final long timestamp = buffer.getLong();
final long traceId = buffer.getLong(); final long traceId = buffer.getLong();
final int orderIndex = buffer.getInt(); final int orderIndex = buffer.getInt();
final int operationId = buffer.getInt();
try {
final String operation = stringRegistry.getStringFromId(operationId);
putInRingBuffer(new AfterStaticOperationEventRecord(timestamp, traceId, orderIndex,
operation, hostApplicationMetadata));
} catch (final IdNotAvailableException e) {
putInWaitingMessages(buffer,
AfterStaticOperationEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID);
}
putInRingBuffer(new AfterStaticOperationEventRecord(timestamp, traceId, orderIndex,
hostApplicationMetadata));
} }
private final void putInWaitingMessages(final ByteBuffer buffer, final int length) { private final void putInWaitingMessages(final ByteBuffer buffer, final int length) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment