// 
// Decompiled by Procyon v0.6.0
// 

package io.netty.util.internal;

import java.util.Objects;
import java.lang.invoke.MethodType;
import java.lang.invoke.MethodHandles;
import io.netty.util.internal.logging.InternalLoggerFactory;
import java.security.AccessController;
import java.security.PrivilegedAction;
import java.nio.ByteBuffer;
import io.netty.util.internal.logging.InternalLogger;
import java.lang.invoke.MethodHandle;

final class CleanerJava6 implements Cleaner
{
    private static final MethodHandle CLEAN_METHOD;
    private static final InternalLogger logger;
    
    static boolean isSupported() {
        return CleanerJava6.CLEAN_METHOD != null;
    }
    
    @Override
    public CleanableDirectBuffer allocate(final int capacity) {
        return new CleanableDirectBufferImpl(ByteBuffer.allocateDirect(capacity));
    }
    
    @Deprecated
    @Override
    public void freeDirectBuffer(final ByteBuffer buffer) {
        freeDirectBufferStatic(buffer);
    }
    
    private static void freeDirectBufferStatic(final ByteBuffer buffer) {
        if (!buffer.isDirect()) {
            return;
        }
        if (System.getSecurityManager() == null) {
            try {
                freeDirectBuffer0(buffer);
            }
            catch (final Throwable cause) {
                PlatformDependent0.throwException(cause);
            }
        }
        else {
            freeDirectBufferPrivileged(buffer);
        }
    }
    
    private static void freeDirectBufferPrivileged(final ByteBuffer buffer) {
        final Throwable cause = AccessController.doPrivileged((PrivilegedAction<Throwable>)new PrivilegedAction<Throwable>() {
            @Override
            public Throwable run() {
                try {
                    freeDirectBuffer0(buffer);
                    return null;
                }
                catch (final Throwable cause) {
                    return cause;
                }
            }
        });
        if (cause != null) {
            PlatformDependent0.throwException(cause);
        }
    }
    
    private static void freeDirectBuffer0(final ByteBuffer buffer) throws Throwable {
        CleanerJava6.CLEAN_METHOD.invokeExact(buffer);
    }
    
    static {
        logger = InternalLoggerFactory.getInstance(CleanerJava6.class);
        Throwable error = null;
        final ByteBuffer direct = ByteBuffer.allocateDirect(1);
        MethodHandle clean;
        try {
            final Object mayBeCleanerField = AccessController.doPrivileged((PrivilegedAction<Object>)new PrivilegedAction<Object>() {
                @Override
                public Object run() {
                    try {
                        final Class<?> cleanerClass = Class.forName("sun.misc.Cleaner");
                        final Class<?> directBufClass = Class.forName("sun.nio.ch.DirectBuffer");
                        final MethodHandles.Lookup lookup = MethodHandles.lookup();
                        MethodHandle clean = lookup.findVirtual(cleanerClass, "clean", MethodType.methodType(Void.TYPE));
                        final MethodHandle nullTest = lookup.findStatic(Objects.class, "nonNull", MethodType.methodType(Boolean.TYPE, Object.class));
                        clean = MethodHandles.guardWithTest(nullTest.asType(MethodType.methodType(Boolean.TYPE, cleanerClass)), clean, nullTest.asType(MethodType.methodType(Void.TYPE, cleanerClass)));
                        clean = MethodHandles.filterArguments(clean, 0, lookup.findVirtual(directBufClass, "cleaner", MethodType.methodType(cleanerClass)));
                        clean = MethodHandles.explicitCastArguments(clean, MethodType.methodType(Void.TYPE, ByteBuffer.class));
                        return clean;
                    }
                    catch (final Throwable cause) {
                        return cause;
                    }
                }
            });
            if (mayBeCleanerField instanceof Throwable) {
                throw (Throwable)mayBeCleanerField;
            }
            clean = (MethodHandle)mayBeCleanerField;
            clean.invokeExact(direct);
        }
        catch (final Throwable t) {
            clean = null;
            error = t;
        }
        if (error == null) {
            CleanerJava6.logger.debug("java.nio.ByteBuffer.cleaner(): available");
        }
        else {
            CleanerJava6.logger.debug("java.nio.ByteBuffer.cleaner(): unavailable", error);
        }
        CLEAN_METHOD = clean;
    }
    
    private static final class CleanableDirectBufferImpl implements CleanableDirectBuffer
    {
        private final ByteBuffer buffer;
        
        private CleanableDirectBufferImpl(final ByteBuffer buffer) {
            this.buffer = buffer;
        }
        
        @Override
        public ByteBuffer buffer() {
            return this.buffer;
        }
        
        @Override
        public void clean() {
            freeDirectBufferStatic(this.buffer);
        }
    }
}