public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelDuplexHandler { private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyProtocolException PROTOCOL_EXCEPTION; private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyProtocolException STREAM_CLOSED; private static final int DEFAULT_WINDOW_SIZE; private int initialSendWindowSize; private int initialReceiveWindowSize; private volatile int initialSessionReceiveWindowSize; private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession spdySession; private int lastGoodStreamId; private static final int DEFAULT_MAX_CONCURRENT_STREAMS; private int remoteConcurrentStreams; private int localConcurrentStreams; private final java.util.concurrent.atomic.AtomicInteger pings; private boolean sentGoAwayFrame; private boolean receivedGoAwayFrame; private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFutureListener closeSessionFutureListener; private final boolean server; private final int minorVersion; public void (org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyVersion, boolean) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyVersion v; java.util.concurrent.atomic.AtomicInteger v; int v, v, v; java.lang.Object v; boolean v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyVersion; v := @parameter: boolean; specialinvoke v.()>(); v. = 65536; v. = 65536; v. = 65536; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession; v = v.; v = v.; specialinvoke v.(int,int)>(v, v); v. = v; v. = 2147483647; v. = 2147483647; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.()>(); v. = v; v = staticinvoke (v, "version"); v = virtualinvoke v.(); v. = v; v. = v; return; } public void setSessionReceiveWindowSize(int) { int v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; v := @parameter: int; staticinvoke (v, "sessionReceiveWindowSize"); v. = v; return; } public void channelRead(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, java.lang.Object) throws java.lang.Exception { byte v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyWindowUpdateFrame v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyDataFrame v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyStreamStatus v, v, v, v, v, v, v, v, v, v, 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.codec.spdy.SpdySessionHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v, v; java.util.concurrent.atomic.AtomicInteger v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionStatus v, v, v, v; java.lang.Object v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: java.lang.Object; v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyDataFrame; if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = (int) -1; v = v * v; v = v.; v = virtualinvoke v.(0, v); if v >= 0 goto label; v = ; specialinvoke v.(v, v); return; label: v = v.; v = v / 2; if v > v goto label; v = v.; v = v - v; v = v.; virtualinvoke v.(0, v); v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyWindowUpdateFrame; specialinvoke v.(int,int)>(0, v); interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(v); if v != 0 goto label; interfaceinvoke v.(); v = v.; if v > v goto label; v = ; specialinvoke v.(v, v, v); goto label; label: v = v.; if v != 0 goto label; v = ; specialinvoke v.(v, v, v); label: return; label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; interfaceinvoke v.(); v = ; specialinvoke v.(v, v, v); return; label: v = specialinvoke v.(v); if v != 0 goto label; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; interfaceinvoke v.(); v = ; specialinvoke v.(v, v, v); return; label: v = v.; v = virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(v); if v >= v goto label; interfaceinvoke v.(); v = ; specialinvoke v.(v, v, v); return; label: if v >= 0 goto label; label: v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v.; if v <= v goto label; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyDataFrame; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); specialinvoke v.(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v); interfaceinvoke v.(v); goto label; label: v = v.; v = v / 2; if v > v goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = v - v; v = v.; virtualinvoke v.(v, v); v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyWindowUpdateFrame; specialinvoke v.(int,int)>(v, v); interfaceinvoke v.(v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(v, 1, v); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySynStreamFrame; if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; label: v = ; specialinvoke v.(v, v, v); return; label: v = v.; if v > v goto label; v = ; specialinvoke v.(v, v); return; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = specialinvoke v.(v, v, v, v); if v != 0 goto label; v = ; specialinvoke v.(v, v, v); return; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySynReplyFrame; if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = specialinvoke v.(v); if v != 0 goto label; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; label: v = ; specialinvoke v.(v, v, v); return; label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = ; specialinvoke v.(v, v, v); return; label: v = v.; virtualinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(v, 1, v); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyRstStreamFrame; if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); specialinvoke v.(v, v); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySettingsFrame; if v == 0 goto label; v = interfaceinvoke v.(0); if v < 0 goto label; v = v.; if v == v goto label; v = ; specialinvoke v.(v, v); return; label: v = interfaceinvoke v.(4); if v < 0 goto label; v. = v; label: v = interfaceinvoke v.(7); if v == 0 goto label; interfaceinvoke v.(7); label: interfaceinvoke v.(7, 0); v = interfaceinvoke v.(7); if v < 0 goto label; specialinvoke v.(v); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyPingFrame; if v == 0 goto label; v = interfaceinvoke v.(); v = specialinvoke v.(v); if v == 0 goto label; interfaceinvoke v.(v); return; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; return; label: v = v.; virtualinvoke v.(); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyGoAwayFrame; if v == 0 goto label; v. = 1; goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyHeadersFrame; if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; v = ; specialinvoke v.(v, v, v); return; label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = ; specialinvoke v.(v, v, v); return; label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(v, 1, v); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyWindowUpdateFrame; if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; return; label: v = v.; v = virtualinvoke v.(v); v = 2147483647 - v; if v <= v goto label; if v != 0 goto label; v = ; specialinvoke v.(v, v); goto label; label: v = ; specialinvoke v.(v, v, v); label: return; label: specialinvoke v.(v, v, v); label: interfaceinvoke v.(v); return; } public void channelInactive(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception { java.util.Iterator v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; java.util.Set v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v; java.util.Map v; int v; java.lang.Object 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.codec.spdy.SpdySession v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); specialinvoke v.(v, v); goto label; label: interfaceinvoke 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.handler.codec.spdy.SpdySessionHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionStatus 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.codec.spdy.SpdySessionHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: java.lang.Throwable; v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyProtocolException; if v == 0 goto label; v = ; specialinvoke v.(v, v); label: interfaceinvoke v.(v); 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.handler.codec.spdy.SpdySessionHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; 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); return; } 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 { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler 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.channel.ChannelHandlerContext v; boolean v, v, v, v, v, v, v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; 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.handler.codec.spdy.SpdyDataFrame; if v != 0 goto label; v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySynStreamFrame; if v != 0 goto label; v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySynReplyFrame; if v != 0 goto label; v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyRstStreamFrame; if v != 0 goto label; v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySettingsFrame; if v != 0 goto label; v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyPingFrame; if v != 0 goto label; v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyGoAwayFrame; if v != 0 goto label; v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyHeadersFrame; if v != 0 goto label; v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyWindowUpdateFrame; if v == 0 goto label; label: specialinvoke v.(v, v, v); goto label; label: interfaceinvoke v.(v, v); label: return; } private void handleOutboundMessage(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 { byte v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyDataFrame v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; java.lang.String 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.codec.spdy.SpdySessionHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v; java.util.concurrent.atomic.AtomicInteger v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession v, v, v, v, v, v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession$PendingWrite 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.codec.spdy.SpdySessionHandler$2 v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler$1 v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyProtocolException v, v, v, v, v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.IllegalArgumentException v; java.lang.Object v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; 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.handler.codec.spdy.SpdyDataFrame; if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); if v == 0 goto label; interfaceinvoke v.(); v = ; interfaceinvoke v.(v); return; label: v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(0); v = staticinvoke (v, v); if v > 0 goto label; v = v.; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession$PendingWrite; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyDataFrame,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v); virtualinvoke v.(v, v); return; label: if v >= v goto label; v = v.; v = (int) -1; v = v * v; virtualinvoke v.(v, v); v = v.; v = (int) -1; v = v * v; virtualinvoke v.(0, v); v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyDataFrame; v = interfaceinvoke v.(); v = virtualinvoke v.(v); specialinvoke v.(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v); v = v.; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession$PendingWrite; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyDataFrame,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v); virtualinvoke v.(v, v); v = interfaceinvoke v.(v); v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler$1; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v, v); interfaceinvoke v.(v); return; label: v = v.; v = (int) -1; v = v * v; virtualinvoke v.(v, v); v = v.; v = (int) -1; v = v * v; virtualinvoke v.(0, v); v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler$2; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v, v); interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; specialinvoke v.(v, 0, v); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySynStreamFrame; if v == 0 goto label; v = interfaceinvoke v.(); v = specialinvoke v.(v); if v == 0 goto label; v = ; interfaceinvoke v.(v); return; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = specialinvoke v.(v, v, v, v); if v != 0 goto label; v = ; interfaceinvoke v.(v); return; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySynReplyFrame; if v == 0 goto label; v = interfaceinvoke v.(); v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; label: v = ; interfaceinvoke v.(v); return; label: v = interfaceinvoke v.(); if v == 0 goto label; specialinvoke v.(v, 0, v); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyRstStreamFrame; if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(v, v); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySettingsFrame; if v == 0 goto label; v = interfaceinvoke v.(0); if v < 0 goto label; v = v.; if v == v goto label; v = ; interfaceinvoke v.(v); return; label: v = interfaceinvoke v.(4); if v < 0 goto label; v. = v; label: v = interfaceinvoke v.(7); if v == 0 goto label; interfaceinvoke v.(7); label: interfaceinvoke v.(7, 0); v = interfaceinvoke v.(7); if v < 0 goto label; specialinvoke v.(v); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyPingFrame; if v == 0 goto label; v = interfaceinvoke v.(); v = specialinvoke v.(v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("invalid PING ID: \u0001"); specialinvoke v.(java.lang.String)>(v); interfaceinvoke v.(v); return; label: v = v.; virtualinvoke v.(); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyGoAwayFrame; if v == 0 goto label; v = ; interfaceinvoke v.(v); return; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyHeadersFrame; if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = ; interfaceinvoke v.(v); return; label: v = interfaceinvoke v.(); if v == 0 goto label; specialinvoke v.(v, 0, v); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyWindowUpdateFrame; if v == 0 goto label; v = ; interfaceinvoke v.(v); return; label: interfaceinvoke v.(v, v); return; } private void issueSessionError(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionStatus) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionStatus v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler$ClosingChannelFutureListener 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; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; 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.handler.codec.spdy.SpdySessionStatus; v = specialinvoke v.(v, v); v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler$ClosingChannelFutureListener; v = interfaceinvoke v.(); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v); interfaceinvoke v.(v); return; } private void issueStreamError(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, int, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyStreamStatus) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyRstStreamFrame v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyStreamStatus v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; int 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.codec.spdy.SpdySession v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: int; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyStreamStatus; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = interfaceinvoke v.(); specialinvoke v.(v, v); v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyRstStreamFrame; specialinvoke v.(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyStreamStatus)>(v, v); interfaceinvoke v.(v, v); if v == 0 goto label; interfaceinvoke v.(v); label: return; } private boolean isRemoteInitiatedId(int) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; int v; boolean v, v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; v := @parameter: int; v = staticinvoke (v); v = v.; if v == 0 goto label; if v == 0 goto label; label: v = v.; if v != 0 goto label; if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } private void updateInitialSendWindowSize(int) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; int v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; v := @parameter: int; v = v.; v = v - v; v. = v; v = v.; virtualinvoke v.(v); return; } private void updateInitialReceiveWindowSize(int) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; int v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; v := @parameter: int; v = v.; v = v - v; v. = v; v = v.; virtualinvoke v.(v); return; } private boolean acceptStream(int, byte, boolean, boolean) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; byte v; int v, v, v, v, v; boolean v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; v := @parameter: int; v := @parameter: byte; v := @parameter: boolean; v := @parameter: boolean; v = v.; if v != 0 goto label; v = v.; if v == 0 goto label; label: return 0; label: v = specialinvoke v.(v); if v == 0 goto label; v = v.; goto label; label: v = v.; label: v = v.; v = virtualinvoke v.(v); if v < v goto label; return 0; label: v = v.; v = v.; v = v.; virtualinvoke v.(v, v, v, v, v, v, v); if v == 0 goto label; v. = v; label: return 1; } private void halfCloseStream(int, boolean, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFutureListener v, v; int v; boolean v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; v := @parameter: int; v := @parameter: boolean; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture; if v == 0 goto label; v = v.; v = specialinvoke v.(v); virtualinvoke v.(v, v); goto label; label: v = v.; v = specialinvoke v.(v); virtualinvoke v.(v, v); label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v); label: return; } private void removeStream(int, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFutureListener v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyProtocolException v; int v; boolean v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; v := @parameter: int; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture; v = v.; v = ; v = specialinvoke v.(v); virtualinvoke v.(v, v, v); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v); label: return; } private void updateSendWindowSize(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, int, int) { boolean v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession v, v, v, v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySession$PendingWrite v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyDataFrame v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler$4 v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler$3 v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyDataFrame v; int v, v, v, v, v, v, v, v, v, v, v, v, v, 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.codec.spdy.SpdySessionHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: int; v := @parameter: int; v = v.; virtualinvoke v.(v, v); label: v = v.; v = virtualinvoke v.(v); if v != null goto label; return; label: v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(0); v = staticinvoke (v, v); if v > 0 goto label; return; label: if v >= v goto label; v = v.; v = (int) -1; v = v * v; virtualinvoke v.(v, v); v = v.; v = (int) -1; v = v * v; virtualinvoke v.(0, v); v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyDataFrame; v = interfaceinvoke v.(); v = virtualinvoke v.(v); specialinvoke v.(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v); v = interfaceinvoke v.(v); v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler$3; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v, v); interfaceinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(v); v = v.; v = (int) -1; v = v * v; virtualinvoke v.(v, v); v = v.; v = (int) -1; v = v * v; virtualinvoke v.(0, v); v = interfaceinvoke v.(); if v == 0 goto label; v = v.; specialinvoke v.(v, 0, v); label: v = v.; v = interfaceinvoke v.(v, v); v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler$4; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v, v); interfaceinvoke v.(v); goto label; } private void sendGoAwayFrame(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionStatus v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler$ClosingChannelFutureListener 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.channel.ChannelPromise 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.codec.spdy.SpdySession v; v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler; 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; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; interfaceinvoke v.(v); return; label: v = ; v = specialinvoke v.(v, v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler$ClosingChannelFutureListener; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v); interfaceinvoke v.(v); goto label; label: v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler$ClosingChannelFutureListener; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v); v. = v; label: return; } private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture sendGoAwayFrame(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionStatus) { org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionHandler v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionStatus v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyGoAwayFrame v; int 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.codec.spdy.SpdySessionHandler; 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.handler.codec.spdy.SpdySessionStatus; v = v.; if v != 0 goto label; v. = 1; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.DefaultSpdyGoAwayFrame; v = v.; specialinvoke v.(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdySessionStatus)>(v, v); v = interfaceinvoke v.(v); return v; label: v = interfaceinvoke v.(); return v; } static void () { java.lang.Throwable v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.spdy.SpdyProtocolException v, v; v = staticinvoke (null); v = staticinvoke (v, class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/spdy/SpdySessionHandler;", "handleOutboundMessage(...)"); = v; v = staticinvoke ("Stream closed"); v = staticinvoke (v, class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/spdy/SpdySessionHandler;", "removeStream(...)"); = v; return; } }