final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger;
private final int maxOutstandingControlFrames;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFutureListener outstandingControlFramesListener;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2LifecycleManager lifecycleManager;
private int outstandingControlFrames;
private boolean limitReached;
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ConnectionEncoder, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder$1 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ConnectionEncoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ConnectionEncoder;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ConnectionEncoder)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFutureListener outstandingControlFramesListener> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: int checkPositive(int,java.lang.String)>(v, "maxOutstandingControlFrames");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: int maxOutstandingControlFrames> = v;
return;
}
public void lifecycleManager(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2LifecycleManager)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2LifecycleManager v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2LifecycleManager;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2LifecycleManager lifecycleManager> = v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: void lifecycleManager(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2LifecycleManager)>(v);
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writeSettingsAck(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.channel.ChannelPromise v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder 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.http.Http2ControlFrameLimitEncoder;
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 = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise handleOutstandingControlFrames(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);
if v != null goto label;
return v;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writeSettingsAck(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);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writePing(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, boolean, long, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
long 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.channel.ChannelPromise v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder 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.Http2ControlFrameLimitEncoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: boolean;
v := @parameter: long;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
if v == 0 goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise handleOutstandingControlFrames(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);
if v != null goto label;
return v;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writePing(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,boolean,long,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v, v);
return v;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writePing(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,boolean,long,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writeRstStream(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, int, long, 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, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder v;
int v;
long 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.http.Http2ControlFrameLimitEncoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: int;
v := @parameter: long;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise handleOutstandingControlFrames(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);
if v != null goto label;
return v;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writeRstStream(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,int,long,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v, v);
return v;
}
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise handleOutstandingControlFrames(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
java.lang.Object[] v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Exception v;
java.lang.Integer v, 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.channel.ChannelFutureListener v;
int v, v, v, v, v, v, v, 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.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Error v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2LifecycleManager v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder;
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 = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: boolean limitReached>;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: int outstandingControlFrames>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: int maxOutstandingControlFrames>;
if v != v goto label;
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.ChannelHandlerContext flush()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: int outstandingControlFrames>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: int maxOutstandingControlFrames>;
if v != v goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: boolean limitReached> = 1;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Error: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Error ENHANCE_YOUR_CALM>;
v = newarray (java.lang.Object)[1];
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: int maxOutstandingControlFrames>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <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.Http2Exception connectionError(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Error,java.lang.String,java.lang.Object[])>(v, "Maximum number %d of outstanding control frames reached", v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = newarray (java.lang.Object)[3];
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: int maxOutstandingControlFrames>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
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[1] = v;
v[2] = v;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void info(java.lang.String,java.lang.Object[])>("Maximum number {} of outstanding control frames reached. Closing channel {}", v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2LifecycleManager lifecycleManager>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2LifecycleManager: void onError(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,boolean,java.lang.Throwable)>(v, 1, 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.ChannelFuture close()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: int outstandingControlFrames>;
v = v + 1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: int outstandingControlFrames> = v;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise unvoid()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFutureListener outstandingControlFramesListener>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
return v;
label:
return v;
}
static void <clinit>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger 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/Http2ControlFrameLimitEncoder;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2ControlFrameLimitEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
return;
}
}