class io.vertx.core.http.impl.Http2ClientConnection$StreamImpl extends io.vertx.core.http.impl.Http2ClientConnection$Stream implements io.vertx.core.http.impl.HttpClientStream
{
void <init>(io.vertx.core.http.impl.Http2ClientConnection, io.vertx.core.impl.ContextInternal, boolean)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.http.impl.Http2ClientConnection v;
io.vertx.core.impl.ContextInternal v;
boolean v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: boolean;
specialinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: void <init>(io.vertx.core.http.impl.Http2ClientConnection,io.vertx.core.impl.ContextInternal,boolean)>(v, v, v);
return;
}
public void closeHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler closeHandler> = v;
return;
}
public void continueHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler continueHandler> = v;
return;
}
public void earlyHintsHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler earlyHintsHandler> = v;
return;
}
public void unknownFrameHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler unknownFrameHandler> = v;
return;
}
public void pushHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler pushHandler> = v;
return;
}
public io.vertx.core.http.impl.Http2ClientConnection$StreamImpl drainHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler drainHandler> = v;
return v;
}
public io.vertx.core.http.impl.Http2ClientConnection$StreamImpl exceptionHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler exceptionHandler> = v;
return v;
}
public io.vertx.core.streams.WriteStream setWriteQueueMaxSize(int)
{
int v;
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: int;
return v;
}
public boolean writeQueueFull()
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
boolean v, v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v = virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: boolean isNotWritable()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public synchronized boolean isNotWritable()
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
byte v;
long v, v;
boolean v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: long writeWindow>;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: long windowSize>;
v = v cmp v;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void headHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler headHandler> = v;
return;
}
public void chunkHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler chunkHandler> = v;
return;
}
public void priorityHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler priorityHandler> = v;
return;
}
public void endHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler endHandler> = v;
return;
}
public io.vertx.core.http.StreamPriority priority()
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.http.StreamPriority v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v = specialinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: io.vertx.core.http.StreamPriority priority()>();
return v;
}
public void updatePriority(io.vertx.core.http.StreamPriority)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.http.StreamPriority v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.http.StreamPriority;
specialinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: void updatePriority(io.vertx.core.http.StreamPriority)>(v);
return;
}
public io.vertx.core.http.HttpVersion version()
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.http.HttpVersion v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v = <io.vertx.core.http.HttpVersion: io.vertx.core.http.HttpVersion HTTP_2>;
return v;
}
void handleEnd(io.vertx.core.MultiMap)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.MultiMap v;
io.vertx.core.Handler v, v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.MultiMap;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler endHandler>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler endHandler>;
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(v);
label:
return;
}
void handleData(io.vertx.core.buffer.Buffer)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.buffer.Buffer v;
io.vertx.core.Handler v, v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.buffer.Buffer;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler chunkHandler>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler chunkHandler>;
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(v);
label:
return;
}
void handleReset(long)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
long v;
io.vertx.core.http.StreamResetException v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: long;
v = new io.vertx.core.http.StreamResetException;
specialinvoke v.<io.vertx.core.http.StreamResetException: void <init>(long)>(v);
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: void handleException(java.lang.Throwable)>(v);
return;
}
void handleWritabilityChanged(boolean)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
boolean v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: boolean;
return;
}
void handleCustomFrame(io.vertx.core.http.HttpFrame)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.http.HttpFrame v;
io.vertx.core.Handler v, v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.http.HttpFrame;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler unknownFrameHandler>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler unknownFrameHandler>;
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(v);
label:
return;
}
void handlePriorityChange(io.vertx.core.http.StreamPriority)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.http.StreamPriority v;
io.vertx.core.Handler v, v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.http.StreamPriority;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler priorityHandler>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler priorityHandler>;
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(v);
label:
return;
}
void handleContinue()
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v, v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler continueHandler>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler continueHandler>;
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(null);
label:
return;
}
void handleEarlyHints(io.vertx.core.MultiMap)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.MultiMap v;
io.vertx.core.Handler v, v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.MultiMap;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler earlyHintsHandler>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler earlyHintsHandler>;
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(v);
label:
return;
}
void handleException(java.lang.Throwable)
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.Handler v, v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: java.lang.Throwable;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler exceptionHandler>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler exceptionHandler>;
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(v);
label:
return;
}
public void writeHead(io.vertx.core.http.impl.HttpRequestHead, boolean, io.netty.buffer.ByteBuf, boolean, io.vertx.core.http.StreamPriority, boolean, io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.http.StreamPriority v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.http.impl.HttpRequestHead v;
io.netty.buffer.ByteBuf v;
io.vertx.core.Handler v, v;
boolean v, v, v;
io.vertx.core.http.impl.Http2ConnectionBase v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.http.impl.HttpRequestHead;
v := @parameter: boolean;
v := @parameter: io.netty.buffer.ByteBuf;
v := @parameter: boolean;
v := @parameter: io.vertx.core.http.StreamPriority;
v := @parameter: boolean;
v := @parameter: io.vertx.core.Handler;
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: void priority(io.vertx.core.http.StreamPriority)>(v);
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.http.impl.Http2ConnectionBase conn>;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.impl.ContextInternal context>;
v = staticinvoke <io.vertx.core.http.impl.Http2ClientConnection$StreamImpl$lambda_writeHead_0__960: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.Http2ClientConnection$StreamImpl,io.vertx.core.http.impl.HttpRequestHead,io.netty.buffer.ByteBuf,boolean,io.vertx.core.http.StreamPriority,boolean,io.vertx.core.Handler)>(v, v, v, v, v, v, v);
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void emit(java.lang.Object,io.vertx.core.Handler)>(null, v);
return;
}
private void writeHeaders(io.vertx.core.http.impl.HttpRequestHead, io.netty.buffer.ByteBuf, boolean, io.vertx.core.http.StreamPriority, boolean, io.vertx.core.Handler)
{
io.vertx.core.http.impl.HttpClientImpl v;
io.vertx.core.MultiMap v, v, v;
io.netty.util.AsciiString v, v;
io.netty.handler.codec.http.Http2Exception v;
boolean v, v, v, v, v, v;
io.vertx.core.http.impl.Http2ConnectionBase v, v;
java.lang.CharSequence v, v;
io.vertx.core.Future v;
io.vertx.core.http.impl.HttpRequestHead v;
io.vertx.core.impl.ContextInternal v;
io.netty.buffer.ByteBuf v;
int v;
io.vertx.core.http.HttpClientOptions v;
java.lang.String v, v, v, v, v, v, v;
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
java.util.Iterator v;
io.vertx.core.http.StreamPriority v;
java.lang.IllegalArgumentException v;
io.vertx.core.http.HttpMethod v, v, v;
java.lang.Object v, v, v, v;
io.vertx.core.Handler v;
io.netty.handler.codec.http.DefaultHttp2Headers v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.http.impl.HttpRequestHead;
v := @parameter: io.netty.buffer.ByteBuf;
v := @parameter: boolean;
v := @parameter: io.vertx.core.http.StreamPriority;
v := @parameter: boolean;
v := @parameter: io.vertx.core.Handler;
v = new io.netty.handler.codec.http.DefaultHttp2Headers;
specialinvoke v.<io.netty.handler.codec.http.DefaultHttp2Headers: void <init>()>();
v = v.<io.vertx.core.http.impl.HttpRequestHead: io.vertx.core.http.HttpMethod method>;
v = virtualinvoke v.<io.vertx.core.http.HttpMethod: java.lang.String name()>();
interfaceinvoke v.<io.netty.handler.codec.http.Http2Headers: io.netty.handler.codec.http.Http2Headers method(java.lang.CharSequence)>(v);
v = v.<io.vertx.core.http.impl.HttpRequestHead: io.vertx.core.http.HttpMethod method>;
v = <io.vertx.core.http.HttpMethod: io.vertx.core.http.HttpMethod CONNECT>;
if v != v goto label;
v = v.<io.vertx.core.http.impl.HttpRequestHead: java.lang.String authority>;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Missing :authority / host header");
throw v;
label:
v = v.<io.vertx.core.http.impl.HttpRequestHead: java.lang.String authority>;
interfaceinvoke v.<io.netty.handler.codec.http.Http2Headers: io.netty.handler.codec.http.Http2Headers authority(java.lang.CharSequence)>(v);
v = 0;
goto label;
label:
v = v.<io.vertx.core.http.impl.HttpRequestHead: java.lang.String uri>;
interfaceinvoke v.<io.netty.handler.codec.http.Http2Headers: io.netty.handler.codec.http.Http2Headers path(java.lang.CharSequence)>(v);
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.http.impl.Http2ConnectionBase conn>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection: boolean isSsl()>();
if v == 0 goto label;
v = "https";
goto label;
label:
v = "http";
label:
interfaceinvoke v.<io.netty.handler.codec.http.Http2Headers: io.netty.handler.codec.http.Http2Headers scheme(java.lang.CharSequence)>(v);
v = v.<io.vertx.core.http.impl.HttpRequestHead: java.lang.String authority>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.HttpRequestHead: java.lang.String authority>;
interfaceinvoke v.<io.netty.handler.codec.http.Http2Headers: io.netty.handler.codec.http.Http2Headers authority(java.lang.CharSequence)>(v);
label:
v = v;
label:
v = v.<io.vertx.core.http.impl.HttpRequestHead: io.vertx.core.MultiMap headers>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.HttpRequestHead: io.vertx.core.MultiMap headers>;
v = interfaceinvoke v.<io.vertx.core.MultiMap: int size()>();
if v <= 0 goto label;
v = v.<io.vertx.core.http.impl.HttpRequestHead: io.vertx.core.MultiMap headers>;
v = interfaceinvoke v.<io.vertx.core.MultiMap: java.util.Iterator iterator()>();
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 = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = staticinvoke <io.vertx.core.http.impl.HttpUtils: java.lang.CharSequence toLowerCase(java.lang.CharSequence)>(v);
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
interfaceinvoke v.<io.netty.handler.codec.http.Http2Headers: io.netty.handler.codec.Headers add(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.http.impl.Http2ConnectionBase conn>;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.HttpClientImpl client>;
v = virtualinvoke v.<io.vertx.core.http.impl.HttpClientImpl: io.vertx.core.http.HttpClientOptions options()>();
v = virtualinvoke v.<io.vertx.core.http.HttpClientOptions: boolean isTryUseCompression()>();
if v == 0 goto label;
v = <io.netty.handler.codec.http.HttpHeaderNames: io.netty.util.AsciiString ACCEPT_ENCODING>;
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Headers: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = <io.netty.handler.codec.http.HttpHeaderNames: io.netty.util.AsciiString ACCEPT_ENCODING>;
v = staticinvoke <io.vertx.core.http.impl.Http1xClientConnection: java.lang.CharSequence determineCompressionAcceptEncoding()>();
interfaceinvoke v.<io.netty.handler.codec.http.Http2Headers: io.netty.handler.codec.Headers set(java.lang.Object,java.lang.Object)>(v, v);
label:
specialinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: void createStream(io.vertx.core.http.impl.HttpRequestHead,io.netty.handler.codec.http.Http2Headers,io.vertx.core.Handler)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.impl.ContextInternal context>;
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.Future failedFuture(java.lang.Throwable)>(v);
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(v);
label:
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: void handleException(java.lang.Throwable)>(v);
return;
label:
if v == null goto label;
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: void doWriteHeaders(io.netty.handler.codec.http.Http2Headers,boolean,io.vertx.core.Handler)>(v, 0, null);
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: void doWriteData(io.netty.buffer.ByteBuf,boolean,io.vertx.core.Handler)>(v, v, v);
goto label;
label:
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: void doWriteHeaders(io.netty.handler.codec.http.Http2Headers,boolean,io.vertx.core.Handler)>(v, v, v);
label:
return;
catch io.netty.handler.codec.http.Http2Exception from label to label with label;
}
private void createStream(io.vertx.core.http.impl.HttpRequestHead, io.netty.handler.codec.http.Http2Headers, io.vertx.core.Handler) throws io.netty.handler.codec.http.Http2Exception
{
io.vertx.core.http.impl.HttpClientImpl v;
io.netty.handler.codec.http.Http2ConnectionEncoder v, v;
io.vertx.core.spi.tracing.SpanKind v;
io.vertx.core.http.impl.Http2ConnectionBase v, v, v, v, v, v;
io.netty.handler.codec.http.Http2Connection$Endpoint v, v;
java.lang.CharSequence v, v;
io.vertx.core.http.impl.HttpRequestHead v;
io.netty.handler.codec.http.Http2Headers v;
io.vertx.core.spi.metrics.ClientMetrics v, v;
io.vertx.core.impl.ContextInternal v, v;
int v, v;
io.netty.handler.codec.http.Http2Stream v;
java.util.function.BiConsumer v;
io.vertx.core.http.HttpClientOptions v;
java.lang.String v, v;
io.vertx.core.tracing.TracingPolicy v;
io.vertx.core.net.SocketAddress v;
io.vertx.core.http.impl.VertxHttp2ConnectionHandler v, v;
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.spi.tracing.TagExtractor v;
io.vertx.core.spi.tracing.VertxTracer v;
io.netty.handler.codec.http.Http2Connection v, v;
java.lang.Object v, v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.vertx.core.http.impl.HttpRequestHead;
v := @parameter: io.netty.handler.codec.http.Http2Headers;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.http.impl.Http2ConnectionBase conn>;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.VertxHttp2ConnectionHandler handler>;
v = virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandler: io.netty.handler.codec.http.Http2ConnectionEncoder encoder()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2ConnectionEncoder: 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 != 0 goto label;
v = 1;
goto label;
label:
v = v + 2;
label:
v.<io.vertx.core.http.impl.HttpRequestHead: int id> = v;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.http.impl.Http2ConnectionBase conn>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.net.SocketAddress remoteAddress()>();
v.<io.vertx.core.http.impl.HttpRequestHead: io.vertx.core.net.SocketAddress remoteAddress> = v;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.http.impl.Http2ConnectionBase conn>;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.VertxHttp2ConnectionHandler handler>;
v = virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandler: io.netty.handler.codec.http.Http2ConnectionEncoder encoder()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2ConnectionEncoder: 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: io.netty.handler.codec.http.Http2Stream createStream(int,boolean)>(v, 0);
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: void init(io.netty.handler.codec.http.Http2Stream)>(v);
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.http.impl.Http2ConnectionBase conn>;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.spi.metrics.ClientMetrics metrics>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.http.impl.Http2ConnectionBase conn>;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.spi.metrics.ClientMetrics metrics>;
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Headers: java.lang.CharSequence path()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = interfaceinvoke v.<io.vertx.core.spi.metrics.ClientMetrics: java.lang.Object requestBegin(java.lang.String,java.lang.Object)>(v, v);
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: java.lang.Object metric> = v;
label:
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.impl.ContextInternal context>;
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.spi.tracing.VertxTracer tracer()>();
if v == null goto label;
v = staticinvoke <io.vertx.core.http.impl.Http2ClientConnection$StreamImpl$lambda_createStream_1__961: java.util.function.BiConsumer bootstrap$(io.netty.handler.codec.http.Http2Headers)>(v);
v = v.<io.vertx.core.http.impl.HttpRequestHead: java.lang.String traceOperation>;
if v != null goto label;
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Headers: java.lang.CharSequence method()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
label:
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.impl.ContextInternal context>;
v = <io.vertx.core.spi.tracing.SpanKind: io.vertx.core.spi.tracing.SpanKind RPC>;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.http.impl.Http2ConnectionBase conn>;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.HttpClientImpl client>;
v = virtualinvoke v.<io.vertx.core.http.impl.HttpClientImpl: io.vertx.core.http.HttpClientOptions options()>();
v = virtualinvoke v.<io.vertx.core.http.HttpClientOptions: io.vertx.core.tracing.TracingPolicy getTracingPolicy()>();
v = <io.vertx.core.http.impl.HttpUtils: io.vertx.core.spi.tracing.TagExtractor CLIENT_HTTP_REQUEST_TAG_EXTRACTOR>;
v = interfaceinvoke v.<io.vertx.core.spi.tracing.VertxTracer: java.lang.Object sendRequest(io.vertx.core.Context,io.vertx.core.spi.tracing.SpanKind,io.vertx.core.tracing.TracingPolicy,java.lang.Object,java.lang.String,java.util.function.BiConsumer,io.vertx.core.spi.tracing.TagExtractor)>(v, v, v, v, v, v, v);
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: java.lang.Object trace> = v;
label:
return;
}
public void writeBuffer(io.netty.buffer.ByteBuf, boolean, io.vertx.core.Handler)
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
long v, v;
io.netty.buffer.ByteBuf v;
int v;
io.vertx.core.Handler v;
boolean v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: io.netty.buffer.ByteBuf;
v := @parameter: boolean;
v := @parameter: io.vertx.core.Handler;
if v == null goto label;
v = virtualinvoke v.<io.netty.buffer.ByteBuf: int readableBytes()>();
entermonitor v;
label:
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: long writeWindow>;
v = v + v;
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: long writeWindow> = v;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
v = staticinvoke <io.vertx.core.http.impl.Http2ClientConnection$StreamImpl$lambda_writeBuffer_2__962: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.Http2ClientConnection$StreamImpl,int,io.vertx.core.Handler)>(v, v, v);
label:
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: void writeData(io.netty.buffer.ByteBuf,boolean,io.vertx.core.Handler)>(v, v, v);
return;
catch java.lang.Throwable from label to label with label;
}
public io.vertx.core.impl.ContextInternal getContext()
{
io.vertx.core.impl.ContextInternal v;
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.impl.ContextInternal context>;
return v;
}
public void doSetWriteQueueMaxSize(int)
{
int v;
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: int;
return;
}
public void reset(java.lang.Throwable)
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.impl.ContextInternal v;
long v;
java.lang.Long v;
io.vertx.core.Handler v;
boolean v;
io.vertx.core.http.impl.Http2ConnectionBase v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v := @parameter: java.lang.Throwable;
v = v instanceof io.vertx.core.http.StreamResetException;
if v == 0 goto label;
v = virtualinvoke v.<io.vertx.core.http.StreamResetException: long getCode()>();
goto label;
label:
v = 0L;
label:
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.http.impl.Http2ConnectionBase conn>;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.impl.ContextInternal context>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <io.vertx.core.http.impl.Http2ClientConnection$StreamImpl$writeReset__963: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.Http2ClientConnection$StreamImpl)>(v);
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void emit(java.lang.Object,io.vertx.core.Handler)>(v, v);
return;
}
public io.vertx.core.http.impl.HttpClientConnection connection()
{
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.http.impl.Http2ConnectionBase v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.http.impl.Http2ConnectionBase conn>;
return v;
}
}