From 5b92adae1d5529010410d64644e6f039779fd718 Mon Sep 17 00:00:00 2001 From: Carsten Varming Date: Wed, 29 Jun 2016 13:17:22 -0400 Subject: [PATCH] Use reflection to call cleaner on direct byte buffers in JDK9. Motivation: Project Jigsaw in JDK9 has moved the direct byte buffer cleaner from sun.misc.Cleaner to java.lang.ref.Cleaner$Cleanable. This cause the current platform tests to throw a ClassNotFoundException, disabling the use of direct byte buffer cleaners. Modifications: I use reflection to find the clean method in either sun.misc.Cleaner or java.lang.ref.Cleaner$Cleanable. Result: Netty uses direct byte buffers on JDK9 as it already do on earlier JDKs. --- .../java/io/netty/util/internal/Cleaner0.java | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) diff --git a/common/src/main/java/io/netty/util/internal/Cleaner0.java b/common/src/main/java/io/netty/util/internal/Cleaner0.java index 0812c50531..e4a7188b02 100644 --- a/common/src/main/java/io/netty/util/internal/Cleaner0.java +++ b/common/src/main/java/io/netty/util/internal/Cleaner0.java @@ -17,40 +17,45 @@ package io.netty.util.internal; import io.netty.util.internal.logging.InternalLogger; import io.netty.util.internal.logging.InternalLoggerFactory; -import sun.misc.Cleaner; import java.lang.reflect.Field; +import java.lang.reflect.Method; import java.nio.ByteBuffer; /** - * Allows to free direct {@link ByteBuffer} by using {@link Cleaner}. This is encapsulated in an extra class to be able + * Allows to free direct {@link ByteBuffer} by using Cleaner. This is encapsulated in an extra class to be able * to use {@link PlatformDependent0} on Android without problems. * * For more details see #2604. */ final class Cleaner0 { private static final long CLEANER_FIELD_OFFSET; + private static final Method CLEAN_METHOD; private static final InternalLogger logger = InternalLoggerFactory.getInstance(Cleaner0.class); static { ByteBuffer direct = ByteBuffer.allocateDirect(1); Field cleanerField; long fieldOffset = -1; + Method clean = null; if (PlatformDependent0.hasUnsafe()) { try { cleanerField = direct.getClass().getDeclaredField("cleaner"); cleanerField.setAccessible(true); - Cleaner cleaner = (Cleaner) cleanerField.get(direct); - cleaner.clean(); + Object cleaner = cleanerField.get(direct); fieldOffset = PlatformDependent0.objectFieldOffset(cleanerField); + clean = cleaner.getClass().getDeclaredMethod("clean"); + clean.invoke(cleaner); } catch (Throwable t) { // We don't have ByteBuffer.cleaner(). fieldOffset = -1; + clean = null; } } logger.debug("java.nio.ByteBuffer.cleaner(): {}", fieldOffset != -1? "available" : "unavailable"); CLEANER_FIELD_OFFSET = fieldOffset; + CLEAN_METHOD = clean; // free buffer if possible freeDirectBuffer(direct); @@ -60,10 +65,11 @@ final class Cleaner0 { if (CLEANER_FIELD_OFFSET == -1 || !buffer.isDirect()) { return; } + assert CLEAN_METHOD != null : "CLEANER_FIELD_OFFSET != -1 implies CLEAN_METHOD != null"; try { - Cleaner cleaner = (Cleaner) PlatformDependent0.getObject(buffer, CLEANER_FIELD_OFFSET); + Object cleaner = PlatformDependent0.getObject(buffer, CLEANER_FIELD_OFFSET); if (cleaner != null) { - cleaner.clean(); + CLEAN_METHOD.invoke(cleaner); } } catch (Throwable t) { // Nothing we can do here.