public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController extends java.lang.Object implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger;
private static final int MIN_WRITABLE_CHUNK;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection connection;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$PropertyKey stateKey;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor streamByteDistributor;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState connectionState;
private int initialWindowSize;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor monitor;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx;
static final boolean $assertionsDisabled;
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection;
v = null;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener)>(v, v);
return;
}
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener)>(v, v, null);
return;
}
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.WeightedFairQueueByteDistributor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.WeightedFairQueueByteDistributor;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.WeightedFairQueueByteDistributor: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener)>(v, v, v);
return;
}
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$1 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$PropertyKey v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener v;
java.lang.Object v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener;
specialinvoke v.<java.lang.Object: void <init>()>();
v = (int) 65535;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: int initialWindowSize> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "connection");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection connection> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "streamWriteDistributor");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor streamByteDistributor> = v;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$PropertyKey newKey()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$PropertyKey stateKey> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream connectionStream()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream)>(v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState connectionState> = v;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream connectionStream()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$PropertyKey stateKey>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState connectionState>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream: java.lang.Object setProperty(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$PropertyKey,java.lang.Object)>(v, v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: void listener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor monitor>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState connectionState>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: int initialWindowSize>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor: void windowSize(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState,int)>(v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection: void addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$Listener)>(v);
return;
}
public void channelHandlerContext(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
java.lang.Object 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.http.DefaultHttp2RemoteFlowController;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "ctx");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx> = v;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: void channelWritabilityChanged()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: boolean isChannelWritable()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: void writePendingBytes()>();
label:
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext channelHandlerContext()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController 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.http.DefaultHttp2RemoteFlowController;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
return v;
}
public void initialWindowSize(int) throws org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
java.lang.AssertionError v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: int;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor executor()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor: boolean inEventLoop()>();
if v != 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor monitor>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor: void initialWindowSize(int)>(v);
return;
}
public int initialWindowSize()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: int initialWindowSize>;
return v;
}
public int windowSize(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState state(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState: int windowSize()>();
return v;
}
public boolean isWritable(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor monitor>;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState state(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor: boolean isWritable(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState)>(v);
return v;
}
public void channelWritabilityChanged() throws org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor monitor>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor: void channelWritabilityChange()>();
return;
}
public void updateDependencyTree(int, int, short, boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor v;
java.lang.AssertionError v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
short v;
int v, v;
boolean v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: int;
v := @parameter: int;
v := @parameter: short;
v := @parameter: boolean;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: boolean $assertionsDisabled>;
if v != 0 goto label;
if v < 1 goto label;
if v <= 256 goto label;
label:
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>("Invalid weight");
throw v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: boolean $assertionsDisabled>;
if v != 0 goto label;
if v != v goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>("A stream cannot depend on itself");
throw v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: boolean $assertionsDisabled>;
if v != 0 goto label;
if v <= 0 goto label;
if v >= 0 goto label;
label:
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>("childStreamId must be > 0. parentStreamId must be >= 0.");
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor streamByteDistributor>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.StreamByteDistributor: void updateDependencyTree(int,int,short,boolean)>(v, v, v, v);
return;
}
private boolean isChannelWritable()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController 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.codec.http.DefaultHttp2RemoteFlowController;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
if v == null goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: boolean isChannelWritable0()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
private boolean isChannelWritable0()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel 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.http.DefaultHttp2RemoteFlowController;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: boolean isWritable()>();
return v;
}
public void listener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$ListenerWritabilityMonitor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener;
if v != null goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor;
v = v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController)>(v);
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$ListenerWritabilityMonitor;
v = v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$ListenerWritabilityMonitor: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$Listener)>(v, v);
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor monitor> = v;
return;
}
public void incrementWindowSize(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream, int) throws org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream v;
java.lang.AssertionError v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream;
v := @parameter: int;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor executor()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor: boolean inEventLoop()>();
if v != 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor monitor>;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState state(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor: void incrementWindowSize(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState,int)>(v, v);
return;
}
public void addFlowControlled(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$FlowControlled)
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream v;
java.lang.AssertionError v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$FlowControlled v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v, v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$FlowControlled;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor executor()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor: boolean inEventLoop()>();
if v != 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "frame");
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor monitor>;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState state(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor: void enqueueFrame(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$FlowControlled)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2RemoteFlowController$FlowControlled: void error(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,java.lang.Throwable)>(v, v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean hasFlowControlled(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState state(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState: boolean hasFrame()>();
return v;
}
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState state(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$PropertyKey v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream v;
java.lang.Object v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$PropertyKey stateKey>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream: java.lang.Object getProperty(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$PropertyKey)>(v);
return v;
}
private int connectionWindowSize()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState connectionState>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState: int windowSize()>();
return v;
}
private int minUsableChannelBytes()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig v;
int v, v, 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.http.DefaultHttp2RemoteFlowController;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig config()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig: int getWriteBufferLowWaterMark()>();
v = (int) 32768;
v = staticinvoke <java.lang.Math: int max(int,int)>(v, v);
return v;
}
private int maxUsableChannelBytes()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
long v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
int v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState 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.http.DefaultHttp2RemoteFlowController;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: long bytesBeforeUnwritable()>();
v = staticinvoke <java.lang.Math: long min(long,long)>(2147483647L, v);
if v <= 0 goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: int minUsableChannelBytes()>();
v = staticinvoke <java.lang.Math: int max(int,int)>(v, v);
goto label;
label:
v = 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState connectionState>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$FlowState: int windowSize()>();
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
return v;
}
private int writableBytes()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
int v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: int connectionWindowSize()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: int maxUsableChannelBytes()>();
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
return v;
}
public void writePendingBytes() throws org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor monitor>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController$WritabilityMonitor: void writePendingBytes()>();
return;
}
static void <clinit>()
{
java.lang.Class v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
boolean v, v;
v = class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http2/DefaultHttp2RemoteFlowController;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: boolean $assertionsDisabled> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLoggerFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger getInstance(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http2/DefaultHttp2RemoteFlowController;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2RemoteFlowController: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
return;
}
}