[Java] Added ErrorLogReader.hasErrors().

real-logic · Jul 30, 2018 · dd87fab · dd87fab
1 parent fbf69ae
commit dd87fab
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/agrona/src/main/java/org/agrona/concurrent/errors/ErrorLogReader.java b/agrona/src/main/java/org/agrona/concurrent/errors/ErrorLogReader.java
@@ -27,6 +27,17 @@
  */
 public class ErrorLogReader
 {
+    /**
+     * Has the error buffer any recorded errors?
+     *
+     * @param buffer containing the {@link DistinctErrorLog}.
+     * @return true if there is at least one error.
+     */
+    public static boolean hasErrors(final AtomicBuffer buffer)
+    {
+        return 0 != buffer.getIntVolatile(LENGTH_OFFSET);
+    }
+
     /**
      * Read all the errors in a log since the creation of the log.
      *

diff --git a/agrona/src/test/java/org/agrona/concurrent/errors/ErrorLogReaderTest.java b/agrona/src/test/java/org/agrona/concurrent/errors/ErrorLogReaderTest.java
@@ -119,9 +119,12 @@ public void shouldReadOneObservationSinceTimestamp()
 
         when(clock.time()).thenReturn(timestampOne).thenReturn(timestampTwo);
 
+        assertFalse(ErrorLogReader.hasErrors(buffer));
+
         log.record(errorOne);
         log.record(errorTwo);
 
+        assertTrue(ErrorLogReader.hasErrors(buffer));
         assertThat(ErrorLogReader.read(buffer, consumer, timestampTwo), is(1));
 
         verify(consumer).accept(eq(1), eq(timestampTwo), eq(timestampTwo), any(String.class));