public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.ByteToMessageDecoder implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundHandler { private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger; private static final java.util.regex.Pattern IGNORABLE_CLASS_IN_STACK; private static final java.util.regex.Pattern IGNORABLE_ERROR_MESSAGE; private static final int MAX_PLAINTEXT_LENGTH; private volatile org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx; private final javax.net.ssl.SSLEngine engine; private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$SslEngineType engineType; private final java.util.concurrent.Executor delegatedTaskExecutor; private final boolean jdkCompatibilityMode; private final java.nio.ByteBuffer[] singleBuffer; private final boolean startTls; private boolean sentFirstMessage; private boolean flushedBeforeHandshake; private boolean readDuringHandshake; private boolean handshakeStarted; private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$SslHandlerCoalescingBufferQueue pendingUnencryptedWrites; private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise handshakePromise; private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$LazyChannelPromise sslClosePromise; private boolean needsFlush; private boolean outboundClosed; private boolean closeNotify; private boolean processTask; private int packetLength; private boolean firedChannelRead; private volatile long handshakeTimeoutMillis; private volatile long closeNotifyFlushTimeoutMillis; private volatile long closeNotifyReadTimeoutMillis; volatile int wrapDataSize; static final boolean $assertionsDisabled; public void (javax.net.ssl.SSLEngine) { javax.net.ssl.SSLEngine v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: javax.net.ssl.SSLEngine; specialinvoke v.(javax.net.ssl.SSLEngine,boolean)>(v, 0); return; } public void (javax.net.ssl.SSLEngine, boolean) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ImmediateExecutor v; boolean v; javax.net.ssl.SSLEngine v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: javax.net.ssl.SSLEngine; v := @parameter: boolean; v = ; specialinvoke v.(javax.net.ssl.SSLEngine,boolean,java.util.concurrent.Executor)>(v, v, v); return; } public void (javax.net.ssl.SSLEngine, java.util.concurrent.Executor) { java.util.concurrent.Executor v; javax.net.ssl.SSLEngine v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: javax.net.ssl.SSLEngine; v := @parameter: java.util.concurrent.Executor; specialinvoke v.(javax.net.ssl.SSLEngine,boolean,java.util.concurrent.Executor)>(v, 0, v); return; } public void (javax.net.ssl.SSLEngine, boolean, java.util.concurrent.Executor) { java.nio.ByteBuffer[] v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.ByteToMessageDecoder$Cumulator v; java.util.concurrent.Executor v; javax.net.ssl.SSLEngine v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$SslEngineType v, v, v; java.lang.Object v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$LazyChannelPromise v, v; boolean v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: javax.net.ssl.SSLEngine; v := @parameter: boolean; v := @parameter: java.util.concurrent.Executor; specialinvoke v.()>(); v = newarray (java.nio.ByteBuffer)[1]; v. = v; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$LazyChannelPromise; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler)>(v); v. = v; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$LazyChannelPromise; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler)>(v); v. = v; v. = 10000L; v. = 3000L; v. = 16384; v = staticinvoke (v, "engine"); v. = v; v = staticinvoke (v, "delegatedTaskExecutor"); v. = v; v = staticinvoke (v); v. = v; v. = v; v = v.; v = virtualinvoke v.(v); v. = v; v = v.; v = v.; virtualinvoke v.(v); return; } public long getHandshakeTimeoutMillis() { long v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v = v.; return v; } public void setHandshakeTimeout(long, java.util.concurrent.TimeUnit) { java.util.concurrent.TimeUnit v; long v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; staticinvoke (v, "unit"); v = virtualinvoke v.(v); virtualinvoke v.(v); return; } public void setHandshakeTimeoutMillis(long) { byte v; long v; java.lang.String v; java.lang.IllegalArgumentException v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: long; v = v cmp 0L; if v >= 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("handshakeTimeoutMillis: \u (expected: >= 0)"); specialinvoke v.(java.lang.String)>(v); throw v; label: v. = v; return; } public final void setWrapDataSize(int) { int v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: int; v. = v; return; } public long getCloseNotifyTimeoutMillis() { long v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v = virtualinvoke v.(); return v; } public void setCloseNotifyTimeout(long, java.util.concurrent.TimeUnit) { java.util.concurrent.TimeUnit v; long v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; virtualinvoke v.(v, v); return; } public void setCloseNotifyTimeoutMillis(long) { long v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: long; virtualinvoke v.(v); return; } public final long getCloseNotifyFlushTimeoutMillis() { long v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v = v.; return v; } public final void setCloseNotifyFlushTimeout(long, java.util.concurrent.TimeUnit) { java.util.concurrent.TimeUnit v; long v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; v = virtualinvoke v.(v); virtualinvoke v.(v); return; } public final void setCloseNotifyFlushTimeoutMillis(long) { byte v; long v; java.lang.String v; java.lang.IllegalArgumentException v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: long; v = v cmp 0L; if v >= 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("closeNotifyFlushTimeoutMillis: \u (expected: >= 0)"); specialinvoke v.(java.lang.String)>(v); throw v; label: v. = v; return; } public final long getCloseNotifyReadTimeoutMillis() { long v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v = v.; return v; } public final void setCloseNotifyReadTimeout(long, java.util.concurrent.TimeUnit) { java.util.concurrent.TimeUnit v; long v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; v = virtualinvoke v.(v); virtualinvoke v.(v); return; } public final void setCloseNotifyReadTimeoutMillis(long) { byte v; long v; java.lang.String v; java.lang.IllegalArgumentException v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: long; v = v cmp 0L; if v >= 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("closeNotifyReadTimeoutMillis: \u (expected: >= 0)"); specialinvoke v.(java.lang.String)>(v); throw v; label: v. = v; return; } public javax.net.ssl.SSLEngine engine() { javax.net.ssl.SSLEngine v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v = v.; return v; } public java.lang.String applicationProtocol() { java.lang.String v; boolean v; javax.net.ssl.SSLEngine v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v = virtualinvoke v.(); v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.ApplicationProtocolAccessor; if v != 0 goto label; return null; label: v = interfaceinvoke v.(); return v; } public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future handshakeFuture() { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v = v.; return v; } public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close() { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v = virtualinvoke v.(); return v; } public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise; v = virtualinvoke v.(v); return v; } public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture closeOutbound() { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); return v; } public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture closeOutbound(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$1 v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; specialinvoke v.(v); goto label; label: v = interfaceinvoke v.(); v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$1; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v); interfaceinvoke v.(v); label: return v; } private void closeOutbound0(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v; java.lang.Exception v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v; javax.net.ssl.SSLEngine v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v, v; boolean v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise; v. = 1; v = v.; virtualinvoke v.(); label: v = v.; specialinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = interfaceinvoke v.(v); if v != 0 goto label; v = ; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.("{} flush() raised a masked exception.", v, v); label: return; catch java.lang.Exception from label to label with label; } public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future sslCloseFuture() { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$LazyChannelPromise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v = v.; return v; } public void handlerRemoved0(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$SslHandlerCoalescingBufferQueue v, v; javax.net.ssl.SSLEngine v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException; specialinvoke v.(java.lang.String)>("Pending write on removal of SslHandler"); virtualinvoke v.(v, v); label: v. = null; v = v.; v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCounted; if v == 0 goto label; v = v.; interfaceinvoke v.(); label: return; } public void bind(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, java.net.SocketAddress, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) throws java.lang.Exception { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; java.net.SocketAddress v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: java.net.SocketAddress; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise; interfaceinvoke v.(v, v); return; } public void connect(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, java.net.SocketAddress, java.net.SocketAddress, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) throws java.lang.Exception { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; java.net.SocketAddress v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: java.net.SocketAddress; v := @parameter: java.net.SocketAddress; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise; interfaceinvoke v.(v, v, v); return; } public void deregister(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) throws java.lang.Exception { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise; interfaceinvoke v.(v); return; } public void disconnect(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) throws java.lang.Exception { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise; specialinvoke v.(v, v, 1); return; } public void close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) throws java.lang.Exception { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise; specialinvoke v.(v, v, 0); return; } public void read(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v. = 1; label: interfaceinvoke v.(); return; } private static java.lang.IllegalStateException newPendingWritesNullException() { java.lang.IllegalStateException v; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("pendingUnencryptedWrites is null, handlerRemoved called?"); return v; } public void write(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, java.lang.Object, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) throws java.lang.Exception { java.lang.IllegalStateException v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$SslHandlerCoalescingBufferQueue v, v; java.lang.Class[] v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; java.lang.Object v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.UnsupportedMessageTypeException v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: java.lang.Object; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise; v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf; if v != 0 goto label; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.UnsupportedMessageTypeException; v = newarray (java.lang.Class)[1]; v[0] = class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/buffer/ByteBuf;"; specialinvoke v.(java.lang.Object,java.lang.Class[])>(v, v); staticinvoke (v); interfaceinvoke v.(v); goto label; label: v = v.; if v != null goto label; staticinvoke (v); v = staticinvoke (); interfaceinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(v, v); label: return; } public void flush(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception { java.lang.Throwable v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$SslHandlerCoalescingBufferQueue v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v = v.; if v == 0 goto label; v = v.; if v != 0 goto label; v. = 1; v = v.; virtualinvoke v.(v); specialinvoke v.(v); specialinvoke v.(); return; label: v = v.; if v == 0 goto label; return; label: specialinvoke v.(v); label: goto label; label: v := @caughtexception; specialinvoke v.(v, v); staticinvoke (v); label: return; catch java.lang.Throwable from label to label with label; } private void wrapAndFlush(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws javax.net.ssl.SSLException { java.lang.Throwable v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$SslHandlerCoalescingBufferQueue v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = ; v = interfaceinvoke v.(); virtualinvoke v.(v, v); label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v. = 1; label: specialinvoke v.(v, 0); label: specialinvoke v.(v); goto label; label: v := @caughtexception; specialinvoke v.(v); throw v; label: return; catch java.lang.Throwable from label to label with label; } private void wrap(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, boolean) throws javax.net.ssl.SSLException { java.lang.Throwable v; java.lang.IllegalStateException v; javax.net.ssl.SSLEngineResult$HandshakeStatus v, v; javax.net.ssl.SSLEngine v; javax.net.ssl.SSLEngineResult v; int[] v; int v, v, v, v, v; java.lang.String v; javax.net.ssl.SSLEngineResult$Status v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$SslHandlerCoalescingBufferQueue v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; javax.net.ssl.SSLException v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: boolean; v = null; v = null; v = interfaceinvoke v.(); v = null; label: v = v.; label: v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); if v <= 0 goto label; v = v.; v = virtualinvoke v.(v, v, v); goto label; label: v = v.; v = virtualinvoke v.(v); label: v = v; if v == null goto label; if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = specialinvoke v.(v, v, v); label: v = v.; v = specialinvoke v.(v, v, v, v); v = virtualinvoke v.(); v = ; if v != v goto label; virtualinvoke v.(); v = null; v = new javax.net.ssl.SSLException; specialinvoke v.(java.lang.String)>("SSLEngine closed already"); interfaceinvoke v.(v); v = null; v = v.; virtualinvoke v.(v, v); label: specialinvoke v.(v, v, null, v, 0); return; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(v, v); v = null; goto label; label: virtualinvoke v.(); label: v = null; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; default: goto label; }; label: v = specialinvoke v.(v); if v != 0 goto label; goto label; label: specialinvoke v.(); label: specialinvoke v.(); label: specialinvoke v.(v, v, v, v, 0); v = null; v = null; goto label; label: specialinvoke v.(v, v, v, v, 1); return; label: v = new java.lang.IllegalStateException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown handshake status: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v == null goto label; virtualinvoke v.(); label: specialinvoke v.(v, v, v, v, 0); goto label; label: v := @caughtexception; if v == null goto label; virtualinvoke v.(); label: specialinvoke v.(v, v, v, v, 0); throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private void finishWrap(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise, boolean, boolean) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise; v := @parameter: boolean; v := @parameter: boolean; if v != null goto label; v = ; goto label; label: v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(); v = ; label: if v == null goto label; interfaceinvoke v.(v, v); goto label; label: interfaceinvoke v.(v); label: if v == 0 goto label; v. = 1; label: if v == 0 goto label; specialinvoke v.(v); label: return; } private boolean wrapNonAppData(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, boolean) throws javax.net.ssl.SSLException { java.lang.Throwable v; java.lang.IllegalStateException v; javax.net.ssl.SSLEngineResult$HandshakeStatus v, v, v, v, v; javax.net.ssl.SSLEngine v; javax.net.ssl.SSLEngineResult v; int[] v; int v, v, v, v, v; java.lang.String v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$2 v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: boolean; v = null; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v != 0 goto label; if v != null goto label; v = specialinvoke v.(v, 2048, 1); label: v = v.; v = ; v = specialinvoke v.(v, v, v, v); v = virtualinvoke v.(); if v <= 0 goto label; v = interfaceinvoke v.(v); v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$2; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v, v); interfaceinvoke v.(v); if v == 0 goto label; v. = 1; label: v = null; label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; default: goto label; }; label: specialinvoke v.(); label: if v == null goto label; virtualinvoke v.(); label: return 0; label: v = specialinvoke v.(v); if v != 0 goto label; goto label; label: if v == 0 goto label; label: if v == null goto label; virtualinvoke v.(); label: return 0; label: specialinvoke v.(v); goto label; label: specialinvoke v.(); if v != 0 goto label; specialinvoke v.(v); label: if v == null goto label; virtualinvoke v.(); label: return 1; label: v = new java.lang.IllegalStateException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown handshake status: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v != 0 goto label; v = ; if v != v goto label; label: v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = ; if v != v goto label; label: if v == null goto label; virtualinvoke v.(); goto label; label: v := @caughtexception; if v == null goto label; virtualinvoke v.(); label: throw v; label: return 0; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private javax.net.ssl.SSLEngineResult wrap(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator, javax.net.ssl.SSLEngine, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf) throws javax.net.ssl.SSLException { java.nio.ByteBuffer v, v, v; int[] v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$SslEngineType v; boolean v, v, v; java.nio.ByteBuffer[] v, v, v; java.lang.Throwable v; javax.net.ssl.SSLEngine v; javax.net.ssl.SSLEngineResult v; javax.net.ssl.SSLSession v; int v, v, v, v, v, v, v, v, v, v, v, v, v; javax.net.ssl.SSLEngineResult$Status v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator; v := @parameter: javax.net.ssl.SSLEngine; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf; v = null; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = v.; if v != 0 goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.CompositeByteBuf; if v != 0 goto label; v = virtualinvoke v.(); if v != 1 goto label; v = v.; v = virtualinvoke v.(v, v); v[0] = v; goto label; label: v = virtualinvoke v.(); goto label; label: v = interfaceinvoke v.(v); virtualinvoke v.(v, v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v[0] = v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = virtualinvoke v.(v, v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + v; virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 1: goto label; default: goto label; }; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; v[0] = null; if v == null goto label; virtualinvoke v.(); label: return v; label: v := @caughtexception; v = v.; v[0] = null; if v == null goto label; virtualinvoke v.(); label: throw v; catch java.lang.Throwable from label to label with label; } public void channelInactive(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception { java.nio.channels.ClosedChannelException v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v = new java.nio.channels.ClosedChannelException; specialinvoke v.()>(); v = v.; if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v.; specialinvoke v.(v, v, v, v, 0); specialinvoke v.(v); specialinvoke v.(v); return; } public void exceptionCaught(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, java.lang.Throwable) throws java.lang.Exception { java.lang.Throwable v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: java.lang.Throwable; v = specialinvoke v.(v); if v == 0 goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = interfaceinvoke v.(); interfaceinvoke v.("{} Swallowing a harmless \'connection reset by peer / broken pipe\' error that occurred while writing close_notify in response to the peer\'s close_notify", v, v); label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; interfaceinvoke v.(); goto label; label: interfaceinvoke v.(v); label: return; } private boolean ignoreException(java.lang.Throwable) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v; java.util.regex.Matcher v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$LazyChannelPromise v; boolean v, v, v, v, v, v, v, v, v, v; java.lang.StackTraceElement[] v; java.lang.ClassLoader v; java.util.regex.Pattern v, v; java.lang.Throwable v, v; java.lang.Object[] v; int v, v, v; java.lang.StackTraceElement v; java.lang.String v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; java.lang.Class v, v, v, v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: java.lang.Throwable; v = v instanceof javax.net.ssl.SSLException; if v != 0 goto label; v = v instanceof java.io.IOException; if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; return 1; label: v = virtualinvoke v.(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.("org.apache.hive.kudu.org.apache.kudu.shaded.io.netty."); if v != 0 goto label; v = "read"; v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; return 1; label: v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); v = class "Ljava/nio/channels/SocketChannel;"; v = virtualinvoke v.(v); if v != 0 goto label; v = class "Ljava/nio/channels/DatagramChannel;"; v = virtualinvoke v.(v); if v == 0 goto label; label: return 1; label: v = staticinvoke (); if v < 7 goto label; v = "com.sun.nio.sctp.SctpChannel"; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: return 1; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Unexpected exception while loading class {} classname {}", v); label: v = v + 1; goto label; label: return 0; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public static boolean isEncrypted(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf) { int v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v; java.lang.IllegalArgumentException v; boolean v; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf; v = virtualinvoke v.(); if v >= 5 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("buffer must have at least 5 readable bytes"); throw v; label: v = virtualinvoke v.(); v = staticinvoke (v, v); v = (int) -2; if v == v goto label; v = 1; goto label; label: v = 0; label: return v; } private void decodeJdkCompatible(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf) throws org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.NotSslRecordException { java.lang.Throwable v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.NotSslRecordException v; java.lang.AssertionError v, v; javax.net.ssl.SSLEngine v; int v, v, v, v, v, v, v, v; java.lang.String v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf; v = v.; if v <= 0 goto label; v = virtualinvoke v.(); if v >= v goto label; return; label: v = virtualinvoke v.(); if v >= 5 goto label; return; label: v = virtualinvoke v.(); v = staticinvoke (v, v); v = (int) -2; if v != v goto label; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.NotSslRecordException; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("not an SSL/TLS record: \u0001"); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); virtualinvoke v.(v); specialinvoke v.(v, v); throw v; label: v = ; if v != 0 goto label; if v > 0 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: if v <= v goto label; v. = v; return; label: v. = 0; label: v = virtualinvoke v.(); v = specialinvoke v.(v, v, v, v); v = ; if v != 0 goto label; if v == v goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.AssertionError; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("we feed the SSLEngine a packets worth of data: \u but it only consumed: \u0001"); specialinvoke v.(java.lang.Object)>(v); throw v; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; specialinvoke v.(v, v); label: return; catch java.lang.Throwable from label to label with label; } private void decodeNonJdkCompatible(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf) { java.lang.Throwable v; int v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = specialinvoke v.(v, v, v, v); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; specialinvoke v.(v, v); label: return; catch java.lang.Throwable from label to label with label; } private void handleUnwrapThrowable(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, java.lang.Throwable) { java.lang.Throwable v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; javax.net.ssl.SSLException v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandshakeCompletionEvent v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: java.lang.Throwable; label: v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandshakeCompletionEvent; specialinvoke v.(java.lang.Throwable)>(v); interfaceinvoke v.(v); label: specialinvoke v.(v); label: specialinvoke v.(v, v, 1, 0, 1); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("SSLException during trying to call SSLEngine.wrap(...) because of an previous SSLException, ignoring...", v); label: specialinvoke v.(v, v, 1, 0, 1); goto label; label: v := @caughtexception; specialinvoke v.(v, v, 1, 0, 1); throw v; label: staticinvoke (v); return; catch javax.net.ssl.SSLException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } protected void decode(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, java.util.List) throws javax.net.ssl.SSLException { java.util.List v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf; v := @parameter: java.util.List; v = v.; if v == 0 goto label; return; label: v = v.; if v == 0 goto label; specialinvoke v.(v, v); goto label; label: specialinvoke v.(v, v); label: return; } public void channelReadComplete(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; specialinvoke v.(v); return; } private void channelReadComplete0(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; virtualinvoke v.(); specialinvoke v.(v); specialinvoke v.(v); v. = 0; interfaceinvoke v.(); return; } private void readIfNeeded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = v.; if v == 0 goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; label: interfaceinvoke v.(); label: return; } private void flushIfNeeded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v = v.; if v == 0 goto label; specialinvoke v.(v); label: return; } private void unwrapNonAppData(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws javax.net.ssl.SSLException { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v = ; specialinvoke v.(v, v, 0, 0); return; } private int unwrap(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, int, int) throws javax.net.ssl.SSLException { java.lang.IllegalStateException v, v; javax.net.ssl.SSLEngineResult$HandshakeStatus v, v, v; int[] v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler$SslEngineType v, v; boolean v, v, v, v, v, v, v, v, v, v; java.lang.Throwable v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise v; javax.net.ssl.SSLEngine v, v, v; javax.net.ssl.SSLEngineResult v; javax.net.ssl.SSLSession v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v; javax.net.ssl.SSLEngineResult$Status v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler v; java.lang.Class v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.ssl.SslHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf; v := @parameter: int; v := @parameter: int; v = v; v = 0; v = 0; v = (int) -1; v = v; v = specialinvoke v.(v, v); label: v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(v, v, v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + v; v = v - v; v = ; v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 1: goto label; case 2: goto label; default: goto label; }; label: v = virtualinvoke v.(); v = v; v = v; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v - v; if v <= 0 goto label; v. = 1; interfaceinvoke v.(v); v = null; if v > 0 goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); goto label; label: virtualinvoke v.(); v = null; label: if v != 0 goto label; if v != 0 goto label; v = new java.lang.IllegalStateException; v = class "Ljavax/net/ssl/SSLSession;"; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Two consecutive overflows but no content was consumed. \u getApplicationBufferSize: \u maybe too small."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = virtualinvoke v.(v, v); v = specialinvoke v.(v, v); goto label; label: v = 1; v = (int) -1; v = v; goto label; label: v = (int) -1; v = v; label: v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; default: goto label; }; label: v = specialinvoke v.(v, 1); if v == 0 goto label; if v != 0 goto label; goto label; label: v = specialinvoke v.(1); if v != 0 goto label; v = 0; goto label; label: specialinvoke v.(); v = 1; goto label; label: v = specialinvoke v.(); if v == 0 goto label; v = 1; goto label; label: if v != 0 goto label; goto label; label: v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("unknown handshake status: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; if v == v goto label; v = ; if v == v goto label; if v != 0 goto label; if v != 0 goto label; label: v = ; if v != v goto label; specialinvoke v.