Commit da94647e authored by Florian Fittkau's avatar Florian Fittkau

interface monitoring

parent b0df88f8
......@@ -301,13 +301,15 @@ class TCPReaderOneClient extends Thread {
final int objectId = buffer.getInt();
final int operationId = buffer.getInt();
final int clazzId = buffer.getInt();
final int interfaceId = buffer.getInt();
try {
final String operation = stringRegistry.getStringFromId(operationId);
final String clazz = stringRegistry.getStringFromId(clazzId);
final String implementedInterface = stringRegistry.getStringFromId(interfaceId);
putInRingBuffer(new BeforeOperationEventRecord(timestamp, traceId, orderIndex,
objectId, operation, clazz, hostApplicationMetadata));
objectId, operation, clazz, implementedInterface, hostApplicationMetadata));
} catch (final IdNotAvailableException e) {
putInWaitingMessages(buffer, BeforeOperationEventRecord.COMPRESSED_BYTE_LENGTH + 1);
}
......@@ -354,13 +356,15 @@ class TCPReaderOneClient extends Thread {
final int objectId = buffer.getInt();
final int operationId = buffer.getInt();
final int clazzId = buffer.getInt();
final int interfaceId = buffer.getInt();
try {
final String operation = stringRegistry.getStringFromId(operationId);
final String clazz = stringRegistry.getStringFromId(clazzId);
final String implementedInterface = stringRegistry.getStringFromId(interfaceId);
putInRingBuffer(new BeforeConstructorEventRecord(timestamp, traceId, orderIndex,
objectId, operation, clazz, hostApplicationMetadata));
objectId, operation, clazz, implementedInterface, hostApplicationMetadata));
} catch (final IdNotAvailableException e) {
putInWaitingMessages(buffer,
BeforeConstructorEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID);
......@@ -409,13 +413,15 @@ class TCPReaderOneClient extends Thread {
final int orderIndex = buffer.getInt();
final int operationId = buffer.getInt();
final int clazzId = buffer.getInt();
final int interfaceId = buffer.getInt();
try {
final String operation = stringRegistry.getStringFromId(operationId);
final String clazz = stringRegistry.getStringFromId(clazzId);
final String implementedInterface = stringRegistry.getStringFromId(interfaceId);
putInRingBuffer(new BeforeStaticOperationEventRecord(timestamp, traceId, orderIndex,
operation, clazz, hostApplicationMetadata));
operation, clazz, implementedInterface, hostApplicationMetadata));
} catch (final IdNotAvailableException e) {
putInWaitingMessages(buffer,
BeforeStaticOperationEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID);
......
......@@ -13,8 +13,8 @@ public class TraceReconstructionBufferTest {
public void testInsertEvent() throws Exception {
final TraceReconstructionBuffer traceReconstructionBuffer = new TraceReconstructionBuffer();
traceReconstructionBuffer.insertEvent(new BeforeOperationEventRecord(1000, 1, 0, 0, "test",
"TestClazz", new HostApplicationMetaDataRecord("testSystem", "testIp", "testHost",
"testApp")));
"TestClazz", "", new HostApplicationMetaDataRecord("testSystem", "testIp",
"testHost", "testApp")));
assertTrue(true); // TODO
}
......
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