Added extra tests for acq/rel/opaque/volatile. (#331)

aeron-io · Feb 24, 2025 · 26ec8fd · 26ec8fd
1 parent 9926237
commit 26ec8fd
Showing 1 changed file with 30 additions and 0 deletions.
diff --git a/agrona/src/test/java/org/agrona/concurrent/status/UnsafeBufferStatusIndicatorTest.java b/agrona/src/test/java/org/agrona/concurrent/status/UnsafeBufferStatusIndicatorTest.java
@@ -36,4 +36,34 @@ void canWrapDifferentKindsOfBuffers()
         unsafeBufferStatusIndicator.setVolatile(value);
         assertEquals(value, unsafeBufferStatusIndicator.getVolatile());
     }
+
+    @Test
+    public void testVolatile(){
+        final int counterId = 2;
+        final UnsafeBuffer buffer = new UnsafeBuffer(allocateDirect(5 * COUNTER_LENGTH));
+        final UnsafeBufferStatusIndicator statusIndicator = new UnsafeBufferStatusIndicator(buffer, counterId);
+        assertEquals(0, statusIndicator.getVolatile());
+        statusIndicator.setVolatile(10);
+        assertEquals(10, statusIndicator.getVolatile());
+    }
+
+    @Test
+    public void testReleaseAcquire(){
+        final int counterId = 2;
+        final UnsafeBuffer buffer = new UnsafeBuffer(allocateDirect(5 * COUNTER_LENGTH));
+        final UnsafeBufferStatusIndicator statusIndicator = new UnsafeBufferStatusIndicator(buffer, counterId);
+        assertEquals(0, statusIndicator.getAcquire());
+        statusIndicator.setRelease(10);
+        assertEquals(10, statusIndicator.getAcquire());
+    }
+
+    @Test
+    public void testOpaque(){
+        final int counterId = 2;
+        final UnsafeBuffer buffer = new UnsafeBuffer(allocateDirect(5 * COUNTER_LENGTH));
+        final UnsafeBufferStatusIndicator statusIndicator = new UnsafeBufferStatusIndicator(buffer, counterId);
+        assertEquals(0, statusIndicator.getOpaque());
+        statusIndicator.setOpaque(10);
+        assertEquals(10, statusIndicator.getOpaque());
+    }
 }