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

package io.netty.util.internal;

import sun.misc.Unsafe;
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 java.lang.invoke.MethodHandle;
import io.netty.util.internal.logging.InternalLogger;

final class CleanerJava9 implements Cleaner
{
    private static final InternalLogger logger;
    private static final MethodHandle INVOKE_CLEANER;
    
    static boolean isSupported() {
        return CleanerJava9.INVOKE_CLEANER != 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 (System.getSecurityManager() == null) {
            try {
                CleanerJava9.INVOKE_CLEANER.invokeExact(buffer);
            }
            catch (final Throwable cause) {
                PlatformDependent0.throwException(cause);
            }
        }
        else {
            freeDirectBufferPrivileged(buffer);
        }
    }
    
    private static void freeDirectBufferPrivileged(final ByteBuffer buffer) {
        final Throwable error = AccessController.doPrivileged((PrivilegedAction<Throwable>)new PrivilegedAction<Throwable>() {
            @Override
            public Throwable run() {
                try {
                    CleanerJava9.INVOKE_CLEANER.invokeExact(buffer);
                }
                catch (final Throwable e) {
                    return e;
                }
                return null;
            }
        });
        if (error != null) {
            PlatformDependent0.throwException(error);
        }
    }
    
    static {
        logger = InternalLoggerFactory.getInstance(CleanerJava9.class);
        MethodHandle method;
        Throwable error;
        if (PlatformDependent0.hasUnsafe()) {
            final ByteBuffer buffer = ByteBuffer.allocateDirect(1);
            final Object maybeInvokeMethod = AccessController.doPrivileged((PrivilegedAction<Object>)new PrivilegedAction<Object>() {
                final /* synthetic */ ByteBuffer val$buffer;
                
                @Override
                public Object run() {
                    try {
                        final Class<? extends Unsafe> unsafeClass = PlatformDependent0.UNSAFE.getClass();
                        final MethodHandles.Lookup lookup = MethodHandles.lookup();
                        MethodHandle invokeCleaner = lookup.findVirtual(unsafeClass, "invokeCleaner", MethodType.methodType(Void.TYPE, ByteBuffer.class));
                        invokeCleaner = invokeCleaner.bindTo(PlatformDependent0.UNSAFE);
                        invokeCleaner.invokeExact(this.val$buffer);
                        return invokeCleaner;
                    }
                    catch (final Throwable e) {
                        return e;
                    }
                }
            });
            if (maybeInvokeMethod instanceof Throwable) {
                method = null;
                error = (Throwable)maybeInvokeMethod;
            }
            else {
                method = (MethodHandle)maybeInvokeMethod;
                error = null;
            }
        }
        else {
            method = null;
            error = new UnsupportedOperationException("sun.misc.Unsafe unavailable");
        }
        if (error == null) {
            CleanerJava9.logger.debug("java.nio.ByteBuffer.cleaner(): available");
        }
        else {
            CleanerJava9.logger.debug("java.nio.ByteBuffer.cleaner(): unavailable", error);
        }
        INVOKE_CLEANER = method;
    }
    
    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);
        }
    }
}