final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint extends java.lang.Object implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$Endpoint
{
private final boolean server;
private int nextStreamIdToCreate;
private int nextReservationStreamId;
private int lastStreamKnownByPeer;
private boolean pushToAllowed;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2FlowController flowController;
private int maxStreams;
private int maxActiveStreams;
private final int maxReservedStreams;
int numActiveStreams;
int numStreams;
static final boolean $assertionsDisabled;
final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection this$0;
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection, boolean, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection;
v := @parameter: boolean;
v := @parameter: int;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v = (int) -1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int lastStreamKnownByPeer> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean pushToAllowed> = 1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean server> = v;
if v == 0 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextStreamIdToCreate> = 2;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextReservationStreamId> = 0;
goto label;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextStreamIdToCreate> = 1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextReservationStreamId> = 1;
label:
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean pushToAllowed> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int maxActiveStreams> = 2147483647;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: int checkPositiveOrZero(int,java.lang.String)>(v, "maxReservedStreams");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int maxReservedStreams> = v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: void updateMaxStreams()>();
return;
}
public int incrementAndGetNextStreamId()
{
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextReservationStreamId>;
if v < 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextReservationStreamId>;
v = v + 2;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextReservationStreamId> = v;
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextReservationStreamId>;
label:
return v;
}
private void incrementExpectedStreamId(int)
{
int v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: int;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextReservationStreamId>;
if v <= v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextReservationStreamId>;
if v < 0 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextReservationStreamId> = v;
label:
v = v + 2;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextStreamIdToCreate> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int numStreams>;
v = v + 1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int numStreams> = v;
return;
}
public boolean isValidStreamId(int)
{
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: int;
if v <= 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean server>;
v = v & 1;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean mayHaveCreatedStream(int)
{
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean isValidStreamId(int)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int lastStreamCreated()>();
if v > v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean canOpenStream()
{
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int numActiveStreams>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int maxActiveStreams>;
if v >= v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream createStream(int, boolean) 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.DefaultHttp2Connection v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: int;
v := @parameter: boolean;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State IDLE>;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean isLocal()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State activeState(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State,boolean,boolean)>(v, v, v, v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: void checkNewStreamAllowed(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State)>(v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection this$0>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State)>(v, v, v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: void incrementExpectedStreamId(int)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: void addStream(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream: void activate()>();
return v;
}
public boolean created(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.Http2Stream v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint createdBy()>();
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isServer()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean server>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream reservePushStream(int, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream) throws org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Exception
{
java.lang.Object[] v, v, 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.Http2Exception v, v, v;
java.lang.Integer v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$Endpoint v;
boolean v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Error v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: int;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream;
if v != null goto label;
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 PROTOCOL_ERROR>;
v = newarray (java.lang.Object)[0];
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, "Parent stream missing", v);
throw v;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean isLocal()>();
if v == 0 goto label;
v = interfaceinvoke v.<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.Http2Stream$State state()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State: boolean localSideOpen()>();
if v != 0 goto label;
goto label;
label:
v = interfaceinvoke v.<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.Http2Stream$State state()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State: boolean remoteSideOpen()>();
if v != 0 goto label;
label:
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 PROTOCOL_ERROR>;
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream: int id()>();
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, "Stream %d is not open for sending push promise", v);
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$Endpoint opposite()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$Endpoint: boolean allowPushTo()>();
if v != 0 goto label;
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 PROTOCOL_ERROR>;
v = newarray (java.lang.Object)[0];
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, "Server push not allowed to opposite endpoint", v);
throw v;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean isLocal()>();
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State RESERVED_LOCAL>;
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State RESERVED_REMOTE>;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: void checkNewStreamAllowed(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State)>(v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection this$0>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State)>(v, v, v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: void incrementExpectedStreamId(int)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: void addStream(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream)>(v);
return v;
}
private void addStream(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream)
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection v, v, v;
java.util.List v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap streamMap>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultStream: int id()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap: java.lang.Object put(int,java.lang.Object)>(v, v);
v = 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection: java.util.List listeners>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection: java.util.List listeners>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$Listener: void onStreamAdded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void error(java.lang.String,java.lang.Throwable)>("Caught Throwable from listener onStreamAdded.", v);
label:
v = v + 1;
goto label;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void allowPushTo(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
java.lang.IllegalArgumentException v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: boolean;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean server>;
if v == 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Servers do not allow push");
throw v;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean pushToAllowed> = v;
return;
}
public boolean allowPushTo()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean pushToAllowed>;
return v;
}
public int numActiveStreams()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int numActiveStreams>;
return v;
}
public int maxActiveStreams()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int maxActiveStreams>;
return v;
}
public void maxActiveStreams(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: int;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int maxActiveStreams> = v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: void updateMaxStreams()>();
return;
}
public int lastStreamCreated()
{
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextStreamIdToCreate>;
if v <= 1 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextStreamIdToCreate>;
v = v - 2;
goto label;
label:
v = 0;
label:
return v;
}
public int lastStreamKnownByPeer()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int lastStreamKnownByPeer>;
return v;
}
private void lastStreamKnownByPeer(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: int;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int lastStreamKnownByPeer> = v;
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2FlowController flowController()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2FlowController v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2FlowController flowController>;
return v;
}
public void flowController(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2FlowController)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2FlowController v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2FlowController;
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, "flowController");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2FlowController flowController> = v;
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Connection$Endpoint opposite()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean isLocal()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint remoteEndpoint>;
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint localEndpoint>;
label:
return v;
}
private void updateMaxStreams()
{
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
long v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int maxActiveStreams>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int maxReservedStreams>;
v = v + v;
v = staticinvoke <java.lang.Math: long min(long,long)>(2147483647L, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int maxStreams> = v;
return;
}
private void checkNewStreamAllowed(int, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State) 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.Http2Exception v, v, v, v, v, v;
java.lang.Integer v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v;
boolean v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State v, v, v, v;
java.lang.Object[] v, v, v, v, v, v;
java.lang.AssertionError v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2NoMoreStreamIdsException v;
int v, v, v, v, v, v, v, v, v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Error v, v, v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v := @parameter: int;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean $assertionsDisabled>;
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State IDLE>;
if v != v 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.DefaultHttp2Connection$DefaultEndpoint: int lastStreamKnownByPeer>;
if v < 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int lastStreamKnownByPeer>;
if v <= v goto label;
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 REFUSED_STREAM>;
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int lastStreamKnownByPeer>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = 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 streamError(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Error,java.lang.String,java.lang.Object[])>(v, v, "Cannot create stream %d greater than Last-Stream-ID %d from GOAWAY.", v);
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean isValidStreamId(int)>(v);
if v != 0 goto label;
if v >= 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2NoMoreStreamIdsException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2NoMoreStreamIdsException: void <init>()>();
throw v;
label:
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 PROTOCOL_ERROR>;
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean server>;
if v == 0 goto label;
v = "server";
goto label;
label:
v = "client";
label:
v[1] = 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, "Request stream %d is not correct for %s connection", v);
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextStreamIdToCreate>;
if v >= v goto label;
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 PROTOCOL_ERROR>;
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextStreamIdToCreate>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = 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 closedStreamError(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Error,java.lang.String,java.lang.Object[])>(v, "Request stream %d is behind the next expected stream %d", v);
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int nextStreamIdToCreate>;
if v > 0 goto label;
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 REFUSED_STREAM>;
v = newarray (java.lang.Object)[0];
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, "Stream IDs are exhausted for this endpoint.", v);
throw v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State RESERVED_LOCAL>;
if v == v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Stream$State RESERVED_REMOTE>;
if v != v goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
v = v;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: boolean canOpenStream()>();
if v == 0 goto label;
label:
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int numStreams>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: int maxStreams>;
if v < v goto label;
label:
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 REFUSED_STREAM>;
v = newarray (java.lang.Object)[0];
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 streamError(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.Http2Error,java.lang.String,java.lang.Object[])>(v, v, "Maximum active streams violated for this endpoint.", v);
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection this$0>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection: boolean isClosed()>();
if v == 0 goto label;
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 INTERNAL_ERROR>;
v = newarray (java.lang.Object)[1];
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, "Attempted to create stream id %d after connection was closed", v);
throw v;
label:
return;
}
private boolean isLocal()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.DefaultHttp2Connection$DefaultEndpoint localEndpoint>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
static void <clinit>()
{
java.lang.Class v;
boolean v, v;
v = class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http2/DefaultHttp2Connection;";
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.DefaultHttp2Connection$DefaultEndpoint: boolean $assertionsDisabled> = v;
return;
}
}