Skip to content

Modify UnsafeUtil to be able to run in Java 17 #76

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
xerial merged 1 commit into from
Nov 25, 2022
Merged

Modify UnsafeUtil to be able to run in Java 17 #76

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
71 changes: 57 additions & 14 deletions larray-buffer/src/main/java/xerial/larray/buffer/UnsafeUtil.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,19 +29,28 @@ public static Unsafe getUnsafe() {

public static Unsafe unsafe = getUnsafe();

private static Constructor<?> findDirectByteBufferConstructor() {
private static ByteBufferCreator findDirectByteBufferConstructor() {
try {
return Class.forName("java.nio.DirectByteBuffer").getDeclaredConstructor(Long.TYPE, Integer.TYPE, Object.class);
return constructorWithAttStrategy();
}
catch(ClassNotFoundException e) {
throw new IllegalStateException(String.format("Failed to find java.nio.DirectByteBuffer: $s", e.getMessage()));
throw new IllegalStateException(
String.format("Failed to find java.nio.DirectByteBuffer: $s", e.getMessage()));
}
catch(NoSuchMethodException e) {
throw new IllegalStateException(String.format("Failed to find constructor f java.nio.DirectByteBuffer: $s", e.getMessage()));
try {
return constructorWithoutAttStrategy();
} catch (NoSuchMethodException e2) {
throw new IllegalStateException(
String.format("Failed to find constructor f java.nio.DirectByteBuffer: $s", e2.getMessage()), e2);
} catch (ClassNotFoundException e2) {
throw new IllegalStateException(
String.format("Failed to find constructor f java.nio.DirectByteBuffer: $s", e2.getMessage()), e2);
}
}
}

private static Constructor<?> dbbCC = findDirectByteBufferConstructor();
private static ByteBufferCreator byteBufferCreator = findDirectByteBufferConstructor();

/**
* Create a new DirectByteBuffer from a given address and size.
Expand All @@ -55,15 +64,49 @@ private static Constructor<?> findDirectByteBufferConstructor() {
* @return
*/
public static ByteBuffer newDirectByteBuffer(long addr, int size, Object att) {
dbbCC.setAccessible(true);
Object b = null;
try {
b = dbbCC.newInstance(new Long(addr), new Integer(size), att);
return ByteBuffer.class.cast(b);
}
catch(Exception e) {
throw new IllegalStateException(String.format("Failed to create DirectByteBuffer: %s", e.getMessage()));
}
return byteBufferCreator.newDirectByteBuffer(addr, size, att);
}

private static ByteBufferCreator constructorWithAttStrategy()
throws ClassNotFoundException, NoSuchMethodException {
final Constructor<? extends ByteBuffer> dbbCC =
(Constructor<? extends ByteBuffer>) Class.forName("java.nio.DirectByteBuffer")
.getDeclaredConstructor(Long.TYPE, Integer.TYPE, Object.class);
return new ByteBufferCreator() {
@Override
public ByteBuffer newDirectByteBuffer(long addr, int size, Object att) {
dbbCC.setAccessible(true);
try {
return dbbCC.newInstance(Long.valueOf(addr), Integer.valueOf(size), att);
} catch (Exception e) {
throw new IllegalStateException(
String.format("Failed to create DirectByteBuffer: %s", e.getMessage()), e);
}
}
};
}

private static ByteBufferCreator constructorWithoutAttStrategy()
throws ClassNotFoundException, NoSuchMethodException {
final Constructor<? extends ByteBuffer> dbbCC =
(Constructor<? extends ByteBuffer>) Class.forName("java.nio.DirectByteBuffer")
.getDeclaredConstructor(Long.TYPE, Integer.TYPE);
return new ByteBufferCreator() {
@Override
public ByteBuffer newDirectByteBuffer(long addr, int size, Object att) {
dbbCC.setAccessible(true);
try {
return dbbCC.newInstance(Long.valueOf(addr), Integer.valueOf(size));
} catch (Exception e) {
throw new IllegalStateException(
String.format("Failed to create DirectByteBuffer: %s", e.getMessage()), e);
}
}
};
}

private interface ByteBufferCreator {
ByteBuffer newDirectByteBuffer(long addr, int size, Object att);
}


Expand Down