Use ByteBuffer for int serialization into bytes.

LambdAurora · LambdAurora · commit 236b7c9b912e · 2025-07-09T10:53:28.000+02:00
This proves to be more reliable than Agreno's UnsafeBuffers.
diff --git a/src/test/java/org/lmdbjava/DbiTest.java b/src/test/java/org/lmdbjava/DbiTest.java
@@ -62,7 +62,6 @@
 import java.util.concurrent.TimeoutException;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.*;
-import org.agrona.concurrent.UnsafeBuffer;
 import org.hamcrest.Matchers;
 import org.junit.After;
 import org.junit.Before;
@@ -381,7 +380,7 @@ public void putCommitGetByteArray() throws IOException {
       try (Txn<byte[]> txn = envBa.txnWrite()) {
         final byte[] found = db.get(txn, ba(5));
         assertNotNull(found);
-        assertThat(new UnsafeBuffer(txn.val()).getInt(0), is(5));
+        assertThat(fromBa(txn.val()), is(5));
       }
     }
   }
diff --git a/src/test/java/org/lmdbjava/TestUtils.java b/src/test/java/org/lmdbjava/TestUtils.java
@@ -36,14 +36,13 @@ final class TestUtils {
   private TestUtils() {}
 
   static byte[] ba(final int value) {
-    final MutableDirectBuffer b = new UnsafeBuffer(new byte[4]);
-    b.putInt(0, value);
-    return b.byteArray();
+    byte[] bytes = new byte[4];
+    ByteBuffer.wrap(bytes).putInt(value);
+    return bytes;
   }
 
   static int fromBa(final byte[] ba) {
-    final MutableDirectBuffer b = new UnsafeBuffer(ba);
-    return b.getInt(0);
+    return ByteBuffer.wrap(ba).getInt();
   }
 
   static ByteBuffer bb(final int value) {

Original file line number	Diff line number	Diff line change
`@@ -62,7 +62,6 @@`
`62`	`62`	`import java.util.concurrent.TimeoutException;`
`63`	`63`	`import java.util.concurrent.atomic.AtomicBoolean;`
`64`	`64`	`import java.util.function.*;`
`65`		`-import org.agrona.concurrent.UnsafeBuffer;`
`66`	`65`	`import org.hamcrest.Matchers;`
`67`	`66`	`import org.junit.After;`
`68`	`67`	`import org.junit.Before;`
`@@ -381,7 +380,7 @@ public void putCommitGetByteArray() throws IOException {`
`381`	`380`	`try (Txn<byte[]> txn = envBa.txnWrite()) {`
`382`	`381`	`final byte[] found = db.get(txn, ba(5));`
`383`	`382`	`assertNotNull(found);`
`384`		`- assertThat(new UnsafeBuffer(txn.val()).getInt(0), is(5));`
	`383`	`+ assertThat(fromBa(txn.val()), is(5));`
`385`	`384`	`}`
`386`	`385`	`}`
`387`	`386`	`}`