diff --git a/aeron-samples/src/main/java/io/aeron/samples/LogInspector.java b/aeron-samples/src/main/java/io/aeron/samples/LogInspector.java index 1391fee19c..e5284475d7 100644 --- a/aeron-samples/src/main/java/io/aeron/samples/LogInspector.java +++ b/aeron-samples/src/main/java/io/aeron/samples/LogInspector.java @@ -80,11 +80,14 @@ public static void main(final String[] args) throws Exception for (int i = 0; i < PARTITION_COUNT; i++) { final UnsafeBuffer metaDataBuffer = atomicBuffers[i + PARTITION_COUNT]; + final long rawTail = metaDataBuffer.getLongVolatile(TERM_TAIL_COUNTER_OFFSET); + final int termOffset = (int)(rawTail & 0xFFFF_FFFFL); out.format( - "Index %d Term Meta Data status=%s tail=%d%n", + "Index %d Term Meta Data status=%s termOffset=%d termId=%d%n", i, termStatus(metaDataBuffer), - metaDataBuffer.getLong(TERM_TAIL_COUNTER_OFFSET) & 0xFFFF_FFFFL); + termOffset, + termId(rawTail)); } for (int i = 0; i < PARTITION_COUNT; i++)