public class io.netty.handler.codec.http.StreamBufferingEncoder extends io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder
{
private final java.util.TreeMap pendingStreams;
private int maxConcurrentStreams;
private boolean closed;
private io.netty.handler.codec.http.StreamBufferingEncoder$GoAwayDetail goAwayDetail;
public void <init>(io.netty.handler.codec.http.Http2ConnectionEncoder)
{
io.netty.handler.codec.http.Http2ConnectionEncoder v;
io.netty.handler.codec.http.StreamBufferingEncoder v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
v := @parameter: io.netty.handler.codec.http.Http2ConnectionEncoder;
specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder: void <init>(io.netty.handler.codec.http.Http2ConnectionEncoder,int)>(v, 100);
return;
}
public void <init>(io.netty.handler.codec.http.Http2ConnectionEncoder, int)
{
io.netty.handler.codec.http.StreamBufferingEncoder v;
io.netty.handler.codec.http.Http2Connection v;
java.util.TreeMap v;
int v;
io.netty.handler.codec.http.StreamBufferingEncoder$1 v;
io.netty.handler.codec.http.Http2ConnectionEncoder v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
v := @parameter: io.netty.handler.codec.http.Http2ConnectionEncoder;
v := @parameter: int;
specialinvoke v.<io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: void <init>(io.netty.handler.codec.http.Http2ConnectionEncoder)>(v);
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v.<io.netty.handler.codec.http.StreamBufferingEncoder: java.util.TreeMap pendingStreams> = v;
v.<io.netty.handler.codec.http.StreamBufferingEncoder: int maxConcurrentStreams> = v;
v = virtualinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder: io.netty.handler.codec.http.Http2Connection connection()>();
v = new io.netty.handler.codec.http.StreamBufferingEncoder$1;
specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$1: void <init>(io.netty.handler.codec.http.StreamBufferingEncoder)>(v);
interfaceinvoke v.<io.netty.handler.codec.http.Http2Connection: void addListener(io.netty.handler.codec.http.Http2Connection$Listener)>(v);
return;
}
public int numBufferedStreams()
{
int v;
io.netty.handler.codec.http.StreamBufferingEncoder v;
java.util.TreeMap v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: java.util.TreeMap pendingStreams>;
v = virtualinvoke v.<java.util.TreeMap: int size()>();
return v;
}
public io.netty.channel.ChannelFuture writeHeaders(io.netty.channel.ChannelHandlerContext, int, io.netty.handler.codec.http.Http2Headers, int, boolean, io.netty.channel.ChannelPromise)
{
io.netty.handler.codec.http.StreamBufferingEncoder v;
io.netty.channel.ChannelFuture v;
io.netty.channel.ChannelHandlerContext v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.http.Http2Headers v;
int v, v;
boolean v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: int;
v := @parameter: io.netty.handler.codec.http.Http2Headers;
v := @parameter: int;
v := @parameter: boolean;
v := @parameter: io.netty.channel.ChannelPromise;
v = virtualinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder: io.netty.channel.ChannelFuture writeHeaders(io.netty.channel.ChannelHandlerContext,int,io.netty.handler.codec.http.Http2Headers,int,short,boolean,int,boolean,io.netty.channel.ChannelPromise)>(v, v, v, 0, 16, 0, v, v, v);
return v;
}
public io.netty.channel.ChannelFuture writeHeaders(io.netty.channel.ChannelHandlerContext, int, io.netty.handler.codec.http.Http2Headers, int, short, boolean, int, boolean, io.netty.channel.ChannelPromise)
{
io.netty.handler.codec.http.StreamBufferingEncoder v;
io.netty.handler.codec.http.StreamBufferingEncoder$GoAwayDetail v, v;
io.netty.handler.codec.http.StreamBufferingEncoder$PendingStream v;
java.lang.Integer v, v;
io.netty.channel.ChannelHandlerContext v;
short v;
io.netty.channel.ChannelPromise v, v, v;
io.netty.handler.codec.http.StreamBufferingEncoder$HeadersFrame v;
int v, v, v;
boolean v, v, v, v, v;
io.netty.handler.codec.http.StreamBufferingEncoder$Http2ChannelClosedException v;
io.netty.channel.ChannelFuture v;
io.netty.handler.codec.http.StreamBufferingEncoder$Http2GoAwayException v;
java.util.TreeMap v, v;
io.netty.handler.codec.http.Http2Headers v;
java.lang.Object v;
java.util.Queue v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: int;
v := @parameter: io.netty.handler.codec.http.Http2Headers;
v := @parameter: int;
v := @parameter: short;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: boolean;
v := @parameter: io.netty.channel.ChannelPromise;
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: boolean closed>;
if v == 0 goto label;
v = new io.netty.handler.codec.http.StreamBufferingEncoder$Http2ChannelClosedException;
specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$Http2ChannelClosedException: void <init>()>();
v = interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
return v;
label:
v = specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder: boolean isExistingStream(int)>(v);
if v != 0 goto label;
v = specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder: boolean canCreateStream()>();
if v == 0 goto label;
label:
v = specialinvoke v.<io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: io.netty.channel.ChannelFuture writeHeaders(io.netty.channel.ChannelHandlerContext,int,io.netty.handler.codec.http.Http2Headers,int,short,boolean,int,boolean,io.netty.channel.ChannelPromise)>(v, v, v, v, v, v, v, v, v);
return v;
label:
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: io.netty.handler.codec.http.StreamBufferingEncoder$GoAwayDetail goAwayDetail>;
if v == null goto label;
v = new io.netty.handler.codec.http.StreamBufferingEncoder$Http2GoAwayException;
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: io.netty.handler.codec.http.StreamBufferingEncoder$GoAwayDetail goAwayDetail>;
specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$Http2GoAwayException: void <init>(io.netty.handler.codec.http.StreamBufferingEncoder$GoAwayDetail)>(v);
v = interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
return v;
label:
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: java.util.TreeMap pendingStreams>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<java.util.TreeMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new io.netty.handler.codec.http.StreamBufferingEncoder$PendingStream;
specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$PendingStream: void <init>(io.netty.channel.ChannelHandlerContext,int)>(v, v);
v = v;
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: java.util.TreeMap pendingStreams>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<java.util.TreeMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder$PendingStream: java.util.Queue frames>;
v = new io.netty.handler.codec.http.StreamBufferingEncoder$HeadersFrame;
specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$HeadersFrame: void <init>(io.netty.handler.codec.http.StreamBufferingEncoder,io.netty.handler.codec.http.Http2Headers,int,short,boolean,int,boolean,io.netty.channel.ChannelPromise)>(v, v, v, v, v, v, v, v);
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
return v;
}
public io.netty.channel.ChannelFuture writeRstStream(io.netty.channel.ChannelHandlerContext, int, long, io.netty.channel.ChannelPromise)
{
io.netty.handler.codec.http.StreamBufferingEncoder v;
java.lang.Object[] v;
long v;
java.lang.Integer v, v;
io.netty.channel.ChannelFuture v;
io.netty.channel.ChannelHandlerContext v;
io.netty.channel.ChannelPromise v;
java.util.TreeMap v;
io.netty.handler.codec.http.Http2Exception v;
int v;
io.netty.handler.codec.http.Http2Error v;
java.lang.Object v;
boolean v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: int;
v := @parameter: long;
v := @parameter: io.netty.channel.ChannelPromise;
v = specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder: boolean isExistingStream(int)>(v);
if v == 0 goto label;
v = specialinvoke v.<io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: io.netty.channel.ChannelFuture writeRstStream(io.netty.channel.ChannelHandlerContext,int,long,io.netty.channel.ChannelPromise)>(v, v, v, v);
return v;
label:
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: java.util.TreeMap pendingStreams>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<java.util.TreeMap: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
virtualinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$PendingStream: void close(java.lang.Throwable)>(null);
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setSuccess()>();
goto label;
label:
v = <io.netty.handler.codec.http.Http2Error: io.netty.handler.codec.http.Http2Error PROTOCOL_ERROR>;
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <io.netty.handler.codec.http.Http2Exception: io.netty.handler.codec.http.Http2Exception connectionError(io.netty.handler.codec.http.Http2Error,java.lang.String,java.lang.Object[])>(v, "Stream does not exist %d", v);
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
label:
return v;
}
public io.netty.channel.ChannelFuture writeData(io.netty.channel.ChannelHandlerContext, int, io.netty.buffer.ByteBuf, int, boolean, io.netty.channel.ChannelPromise)
{
io.netty.handler.codec.http.StreamBufferingEncoder v;
java.lang.Object[] v;
java.lang.Integer v, v;
io.netty.channel.ChannelHandlerContext v;
io.netty.buffer.ByteBuf v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.http.Http2Exception v;
int v, v;
boolean v, v;
io.netty.handler.codec.http.StreamBufferingEncoder$DataFrame v;
io.netty.channel.ChannelFuture v;
java.util.TreeMap v;
io.netty.handler.codec.http.Http2Error v;
java.lang.Object v;
java.util.Queue v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: int;
v := @parameter: io.netty.buffer.ByteBuf;
v := @parameter: int;
v := @parameter: boolean;
v := @parameter: io.netty.channel.ChannelPromise;
v = specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder: boolean isExistingStream(int)>(v);
if v == 0 goto label;
v = specialinvoke v.<io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: io.netty.channel.ChannelFuture writeData(io.netty.channel.ChannelHandlerContext,int,io.netty.buffer.ByteBuf,int,boolean,io.netty.channel.ChannelPromise)>(v, v, v, v, v, v);
return v;
label:
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: java.util.TreeMap pendingStreams>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<java.util.TreeMap: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder$PendingStream: java.util.Queue frames>;
v = new io.netty.handler.codec.http.StreamBufferingEncoder$DataFrame;
specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$DataFrame: void <init>(io.netty.handler.codec.http.StreamBufferingEncoder,io.netty.buffer.ByteBuf,int,boolean,io.netty.channel.ChannelPromise)>(v, v, v, v, v);
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
goto label;
label:
staticinvoke <io.netty.util.ReferenceCountUtil: void safeRelease(java.lang.Object)>(v);
v = <io.netty.handler.codec.http.Http2Error: io.netty.handler.codec.http.Http2Error PROTOCOL_ERROR>;
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <io.netty.handler.codec.http.Http2Exception: io.netty.handler.codec.http.Http2Exception connectionError(io.netty.handler.codec.http.Http2Error,java.lang.String,java.lang.Object[])>(v, "Stream does not exist %d", v);
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
label:
return v;
}
public void remoteSettings(io.netty.handler.codec.http.Http2Settings) throws io.netty.handler.codec.http.Http2Exception
{
io.netty.handler.codec.http.Http2Settings v;
io.netty.handler.codec.http.Http2Connection$Endpoint v;
io.netty.handler.codec.http.StreamBufferingEncoder v;
io.netty.handler.codec.http.Http2Connection v;
int v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
v := @parameter: io.netty.handler.codec.http.Http2Settings;
specialinvoke v.<io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: void remoteSettings(io.netty.handler.codec.http.Http2Settings)>(v);
v = virtualinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder: io.netty.handler.codec.http.Http2Connection connection()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Connection: io.netty.handler.codec.http.Http2Connection$Endpoint local()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Connection$Endpoint: int maxActiveStreams()>();
v.<io.netty.handler.codec.http.StreamBufferingEncoder: int maxConcurrentStreams> = v;
specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder: void tryCreatePendingStreams()>();
return;
}
public void close()
{
java.lang.Throwable v;
io.netty.handler.codec.http.StreamBufferingEncoder v;
java.util.Map$Entry v;
io.netty.handler.codec.http.StreamBufferingEncoder$Http2ChannelClosedException v;
java.util.TreeMap v, v;
java.lang.Object v;
boolean v, v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
label:
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: boolean closed>;
if v != 0 goto label;
v.<io.netty.handler.codec.http.StreamBufferingEncoder: boolean closed> = 1;
v = new io.netty.handler.codec.http.StreamBufferingEncoder$Http2ChannelClosedException;
specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$Http2ChannelClosedException: void <init>()>();
label:
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: java.util.TreeMap pendingStreams>;
v = virtualinvoke v.<java.util.TreeMap: boolean isEmpty()>();
if v != 0 goto label;
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: java.util.TreeMap pendingStreams>;
v = virtualinvoke v.<java.util.TreeMap: java.util.Map$Entry pollFirstEntry()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
virtualinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$PendingStream: void close(java.lang.Throwable)>(v);
goto label;
label:
specialinvoke v.<io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: void close()>();
goto label;
label:
v := @caughtexception;
specialinvoke v.<io.netty.handler.codec.http.DecoratingHttp2ConnectionEncoder: void close()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void tryCreatePendingStreams()
{
java.lang.Throwable v;
io.netty.handler.codec.http.StreamBufferingEncoder v;
java.util.Map$Entry v;
java.util.TreeMap v, v;
java.lang.Object v;
boolean v, v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
label:
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: java.util.TreeMap pendingStreams>;
v = virtualinvoke v.<java.util.TreeMap: boolean isEmpty()>();
if v != 0 goto label;
v = specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder: boolean canCreateStream()>();
if v == 0 goto label;
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: java.util.TreeMap pendingStreams>;
v = virtualinvoke v.<java.util.TreeMap: java.util.Map$Entry pollFirstEntry()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
label:
virtualinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$PendingStream: void sendFrames()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$PendingStream: void close(java.lang.Throwable)>(v);
goto label;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void cancelGoAwayStreams(io.netty.handler.codec.http.StreamBufferingEncoder$GoAwayDetail)
{
io.netty.handler.codec.http.StreamBufferingEncoder v;
java.util.Iterator v;
java.util.Collection v;
io.netty.handler.codec.http.StreamBufferingEncoder$GoAwayDetail v;
io.netty.handler.codec.http.StreamBufferingEncoder$Http2GoAwayException v;
java.util.TreeMap v;
int v, v;
java.lang.Object v;
boolean v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
v := @parameter: io.netty.handler.codec.http.StreamBufferingEncoder$GoAwayDetail;
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: java.util.TreeMap pendingStreams>;
v = virtualinvoke v.<java.util.TreeMap: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
v = new io.netty.handler.codec.http.StreamBufferingEncoder$Http2GoAwayException;
specialinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$Http2GoAwayException: void <init>(io.netty.handler.codec.http.StreamBufferingEncoder$GoAwayDetail)>(v);
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder$PendingStream: int streamId>;
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder$GoAwayDetail: int lastStreamId>;
if v <= v goto label;
interfaceinvoke v.<java.util.Iterator: void remove()>();
virtualinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder$PendingStream: void close(java.lang.Throwable)>(v);
goto label;
label:
return;
}
private boolean canCreateStream()
{
io.netty.handler.codec.http.Http2Connection$Endpoint v;
io.netty.handler.codec.http.StreamBufferingEncoder v;
io.netty.handler.codec.http.Http2Connection v;
int v, v;
boolean v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
v = virtualinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder: io.netty.handler.codec.http.Http2Connection connection()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Connection: io.netty.handler.codec.http.Http2Connection$Endpoint local()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Connection$Endpoint: int numActiveStreams()>();
v = v.<io.netty.handler.codec.http.StreamBufferingEncoder: int maxConcurrentStreams>;
if v >= v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
private boolean isExistingStream(int)
{
io.netty.handler.codec.http.Http2Connection$Endpoint v;
io.netty.handler.codec.http.StreamBufferingEncoder v;
io.netty.handler.codec.http.Http2Connection v;
int v, v;
boolean v;
v := @this: io.netty.handler.codec.http.StreamBufferingEncoder;
v := @parameter: int;
v = virtualinvoke v.<io.netty.handler.codec.http.StreamBufferingEncoder: io.netty.handler.codec.http.Http2Connection connection()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Connection: io.netty.handler.codec.http.Http2Connection$Endpoint local()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Connection$Endpoint: int lastStreamCreated()>();
if v > v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
}