Continue to use UNSAFE.[get|put]Long(..) (#97)

benalexau · benalexau · commit a5ef8b55cc4b · 2019-02-08T14:08:32.000+11:00
diff --git a/src/main/java/org/lmdbjava/ByteBufferProxy.java b/src/main/java/org/lmdbjava/ByteBufferProxy.java
@@ -277,20 +277,20 @@ private static final class UnsafeProxy extends AbstractByteBufferProxy {
     protected void in(final ByteBuffer buffer, final Pointer ptr,
                       final long ptrAddr) {
       UNSAFE.putLong(ptrAddr + STRUCT_FIELD_OFFSET_SIZE, buffer.remaining());
-      UNSAFE.putAddress(ptrAddr + STRUCT_FIELD_OFFSET_DATA, address(buffer));
+      UNSAFE.putLong(ptrAddr + STRUCT_FIELD_OFFSET_DATA, address(buffer));
     }
 
     @Override
     protected void in(final ByteBuffer buffer, final int size, final Pointer ptr,
                       final long ptrAddr) {
       UNSAFE.putLong(ptrAddr + STRUCT_FIELD_OFFSET_SIZE, size);
-      UNSAFE.putAddress(ptrAddr + STRUCT_FIELD_OFFSET_DATA, address(buffer));
+      UNSAFE.putLong(ptrAddr + STRUCT_FIELD_OFFSET_DATA, address(buffer));
     }
 
     @Override
     protected ByteBuffer out(final ByteBuffer buffer, final Pointer ptr,
                              final long ptrAddr) {
-      final long addr = UNSAFE.getAddress(ptrAddr + STRUCT_FIELD_OFFSET_DATA);
+      final long addr = UNSAFE.getLong(ptrAddr + STRUCT_FIELD_OFFSET_DATA);
       final long size = UNSAFE.getLong(ptrAddr + STRUCT_FIELD_OFFSET_SIZE);
       UNSAFE.putLong(buffer, ADDRESS_OFFSET, addr);
       UNSAFE.putInt(buffer, CAPACITY_OFFSET, (int) size);
diff --git a/src/main/java/org/lmdbjava/DirectBufferProxy.java b/src/main/java/org/lmdbjava/DirectBufferProxy.java
@@ -130,22 +130,22 @@ protected void in(final DirectBuffer buffer, final Pointer ptr,
                     final long ptrAddr) {
     final long addr = buffer.addressOffset();
     final long size = buffer.capacity();
-    UNSAFE.putAddress(ptrAddr + STRUCT_FIELD_OFFSET_DATA, addr);
+    UNSAFE.putLong(ptrAddr + STRUCT_FIELD_OFFSET_DATA, addr);
     UNSAFE.putLong(ptrAddr + STRUCT_FIELD_OFFSET_SIZE, size);
   }
 
   @Override
   protected void in(final DirectBuffer buffer, final int size, final Pointer ptr,
                     final long ptrAddr) {
     final long addr = buffer.addressOffset();
-    UNSAFE.putAddress(ptrAddr + STRUCT_FIELD_OFFSET_DATA, addr);
+    UNSAFE.putLong(ptrAddr + STRUCT_FIELD_OFFSET_DATA, addr);
     UNSAFE.putLong(ptrAddr + STRUCT_FIELD_OFFSET_SIZE, size);
   }
 
   @Override
   protected DirectBuffer out(final DirectBuffer buffer, final Pointer ptr,
                              final long ptrAddr) {
-    final long addr = UNSAFE.getAddress(ptrAddr + STRUCT_FIELD_OFFSET_DATA);
+    final long addr = UNSAFE.getLong(ptrAddr + STRUCT_FIELD_OFFSET_DATA);
     final long size = UNSAFE.getLong(ptrAddr + STRUCT_FIELD_OFFSET_SIZE);
     buffer.wrap(addr, (int) size);
     return buffer;
diff --git a/src/test/java/org/lmdbjava/ByteBufProxy.java b/src/test/java/org/lmdbjava/ByteBufProxy.java
@@ -121,23 +121,23 @@ protected byte[] getBytes(final ByteBuf buffer) {
   protected void in(final ByteBuf buffer, final Pointer ptr, final long ptrAddr) {
     UNSAFE.putLong(ptrAddr + STRUCT_FIELD_OFFSET_SIZE,
                    buffer.writerIndex() - buffer.readerIndex());
-    UNSAFE.putAddress(ptrAddr + STRUCT_FIELD_OFFSET_DATA,
-                      buffer.memoryAddress() + buffer.readerIndex());
+    UNSAFE.putLong(ptrAddr + STRUCT_FIELD_OFFSET_DATA,
+                   buffer.memoryAddress() + buffer.readerIndex());
   }
 
   @Override
   protected void in(final ByteBuf buffer, final int size, final Pointer ptr,
                     final long ptrAddr) {
     UNSAFE.putLong(ptrAddr + STRUCT_FIELD_OFFSET_SIZE,
                    size);
-    UNSAFE.putAddress(ptrAddr + STRUCT_FIELD_OFFSET_DATA,
-                      buffer.memoryAddress() + buffer.readerIndex());
+    UNSAFE.putLong(ptrAddr + STRUCT_FIELD_OFFSET_DATA,
+                   buffer.memoryAddress() + buffer.readerIndex());
   }
 
   @Override
   protected ByteBuf out(final ByteBuf buffer, final Pointer ptr,
                         final long ptrAddr) {
-    final long addr = UNSAFE.getAddress(ptrAddr + STRUCT_FIELD_OFFSET_DATA);
+    final long addr = UNSAFE.getLong(ptrAddr + STRUCT_FIELD_OFFSET_DATA);
     final long size = UNSAFE.getLong(ptrAddr + STRUCT_FIELD_OFFSET_SIZE);
     UNSAFE.putLong(buffer, ADDRESS_OFFSET, addr);
     UNSAFE.putInt(buffer, LENGTH_OFFSET, (int) size);
