public class io.vertx.core.http.impl.Http1xServerRequest extends io.vertx.core.http.impl.HttpServerRequestInternal implements io.vertx.core.spi.observability.HttpRequest
{
private static final io.vertx.core.impl.logging.Logger log;
private final io.vertx.core.http.impl.Http1xServerConnection conn;
final io.vertx.core.impl.ContextInternal context;
private io.netty.handler.codec.http.HttpRequest request;
private io.vertx.core.http.HttpVersion version;
private io.vertx.core.http.HttpMethod method;
private io.vertx.core.net.HostAndPort authority;
private java.lang.String uri;
private java.lang.String path;
private java.lang.String query;
io.vertx.core.http.impl.Http1xServerRequest next;
java.lang.Object metric;
java.lang.Object trace;
private io.vertx.core.http.impl.Http1xServerResponse response;
private java.nio.charset.Charset paramsCharset;
private io.vertx.core.MultiMap params;
private io.vertx.core.MultiMap headers;
private java.lang.String absoluteURI;
private io.vertx.core.http.impl.HttpEventHandler eventHandler;
private io.vertx.core.Handler uploadHandler;
private io.vertx.core.MultiMap attributes;
private io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder;
private boolean ended;
private long bytesRead;
private io.vertx.core.streams.impl.InboundBuffer pending;
void <init>(io.vertx.core.http.impl.Http1xServerConnection, io.netty.handler.codec.http.HttpRequest, io.vertx.core.impl.ContextInternal)
{
io.netty.handler.codec.http.HttpRequest v;
io.vertx.core.http.impl.Http1xServerRequest v;
java.nio.charset.Charset v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.http.impl.Http1xServerConnection v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: io.vertx.core.http.impl.Http1xServerConnection;
v := @parameter: io.netty.handler.codec.http.HttpRequest;
v := @parameter: io.vertx.core.impl.ContextInternal;
specialinvoke v.<io.vertx.core.http.impl.HttpServerRequestInternal: void <init>()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v.<io.vertx.core.http.impl.Http1xServerRequest: java.nio.charset.Charset paramsCharset> = v;
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn> = v;
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.impl.ContextInternal context> = v;
v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request> = v;
return;
}
private io.vertx.core.http.impl.HttpEventHandler eventHandler(boolean)
{
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.HttpEventHandler v, v, v;
io.vertx.core.impl.ContextInternal v;
boolean v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: boolean;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.HttpEventHandler eventHandler>;
if v != null goto label;
if v == 0 goto label;
v = new io.vertx.core.http.impl.HttpEventHandler;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.impl.ContextInternal context>;
specialinvoke v.<io.vertx.core.http.impl.HttpEventHandler: void <init>(io.vertx.core.impl.ContextInternal)>(v);
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.HttpEventHandler eventHandler> = v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.HttpEventHandler eventHandler>;
return v;
}
io.netty.handler.codec.http.HttpRequest nettyRequest()
{
java.lang.Throwable v;
io.netty.handler.codec.http.HttpRequest v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.Http1xServerConnection v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
void setRequest(io.netty.handler.codec.http.HttpRequest)
{
java.lang.Throwable v;
io.netty.handler.codec.http.HttpRequest v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.Http1xServerConnection v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: io.netty.handler.codec.http.HttpRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request> = v;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private io.vertx.core.streams.impl.InboundBuffer pendingQueue()
{
io.vertx.core.streams.impl.InboundBuffer v, v, v, v, v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.Handler v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.streams.impl.InboundBuffer pending>;
if v != null goto label;
v = new io.vertx.core.streams.impl.InboundBuffer;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.impl.ContextInternal context>;
specialinvoke v.<io.vertx.core.streams.impl.InboundBuffer: void <init>(io.vertx.core.Context,long)>(v, 8L);
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.streams.impl.InboundBuffer pending> = v;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.streams.impl.InboundBuffer pending>;
v = staticinvoke <io.vertx.core.http.impl.Http1xServerRequest$lambda_pendingQueue_0__1537: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.Http1xServerRequest)>(v);
virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: io.vertx.core.streams.impl.InboundBuffer drainHandler(io.vertx.core.Handler)>(v);
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.streams.impl.InboundBuffer pending>;
v = staticinvoke <io.vertx.core.http.impl.Http1xServerRequest$lambda_pendingQueue_1__1538: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.Http1xServerRequest)>(v);
virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: io.vertx.core.streams.impl.InboundBuffer handler(io.vertx.core.Handler)>(v);
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.streams.impl.InboundBuffer pending>;
return v;
}
void handleContent(io.vertx.core.buffer.Buffer)
{
java.lang.Throwable v;
io.vertx.core.streams.impl.InboundBuffer v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.http.impl.Http1xServerConnection v, v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.buffer.Buffer v;
io.vertx.core.Handler v;
boolean v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: io.vertx.core.buffer.Buffer;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.streams.impl.InboundBuffer pending>;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
v = virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: boolean write(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
virtualinvoke v.<io.vertx.core.http.impl.Http1xServerConnection: void doPause()>();
goto label;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.impl.ContextInternal context>;
v = staticinvoke <io.vertx.core.http.impl.Http1xServerRequest$onData__1539: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.Http1xServerRequest)>(v);
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void execute(java.lang.Object,io.vertx.core.Handler)>(v, v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
void handleBegin(boolean, boolean)
{
io.netty.handler.codec.http.HttpRequest v;
io.vertx.core.Vertx v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.http.impl.Http1xServerConnection v, v, v;
io.vertx.core.http.impl.Http1xServerResponse v;
io.vertx.core.http.impl.Http1xServerRequest v;
java.lang.Object v;
boolean v, v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: boolean;
v := @parameter: boolean;
v = <io.vertx.core.spi.metrics.Metrics: boolean METRICS_ENABLED>;
if v == 0 goto label;
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void reportRequestBegin()>();
label:
v = new io.vertx.core.http.impl.Http1xServerResponse;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerConnection: io.vertx.core.Vertx vertx()>();
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.impl.ContextInternal context>;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.Object metric>;
specialinvoke v.<io.vertx.core.http.impl.Http1xServerResponse: void <init>(io.vertx.core.impl.VertxInternal,io.vertx.core.impl.ContextInternal,io.vertx.core.http.impl.Http1xServerConnection,io.netty.handler.codec.http.HttpRequest,java.lang.Object,boolean,boolean)>(v, v, v, v, v, v, v);
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerResponse response> = v;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = v.<io.vertx.core.http.impl.Http1xServerConnection: boolean handle100ContinueAutomatically>;
if v == 0 goto label;
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void check100()>();
label:
return;
}
void enqueue(io.vertx.core.http.impl.Http1xServerRequest)
{
io.vertx.core.http.impl.Http1xServerRequest v, v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: io.vertx.core.http.impl.Http1xServerRequest;
v = v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerRequest next>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerRequest next>;
goto label;
label:
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerRequest next> = v;
return;
}
io.vertx.core.http.impl.Http1xServerRequest next()
{
io.vertx.core.http.impl.Http1xServerRequest v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerRequest next>;
return v;
}
private void check100()
{
io.netty.handler.codec.http.HttpRequest v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.Http1xServerConnection v;
boolean v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
v = staticinvoke <io.netty.handler.codec.http.HttpUtil: boolean is100ContinueExpected(io.netty.handler.codec.http.HttpMessage)>(v);
if v == 0 goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
virtualinvoke v.<io.vertx.core.http.impl.Http1xServerConnection: void write100Continue()>();
label:
return;
}
public java.lang.Object metric()
{
java.lang.Object v;
io.vertx.core.http.impl.Http1xServerRequest v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.Object metric>;
return v;
}
java.lang.Object trace()
{
java.lang.Object v;
io.vertx.core.http.impl.Http1xServerRequest v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.Object trace>;
return v;
}
public io.vertx.core.Context context()
{
io.vertx.core.impl.ContextInternal v;
io.vertx.core.http.impl.Http1xServerRequest v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.impl.ContextInternal context>;
return v;
}
public int id()
{
io.vertx.core.http.impl.Http1xServerRequest v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
return 0;
}
public io.vertx.core.http.HttpVersion version()
{
io.netty.handler.codec.http.HttpVersion v, v, v;
io.netty.handler.codec.http.HttpRequest v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.HttpVersion v, v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpVersion version>;
if v != null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpRequest: io.netty.handler.codec.http.HttpVersion protocolVersion()>();
v = <io.netty.handler.codec.http.HttpVersion: io.netty.handler.codec.http.HttpVersion HTTP_1_0>;
if v != v goto label;
v = <io.vertx.core.http.HttpVersion: io.vertx.core.http.HttpVersion HTTP_1_0>;
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpVersion version> = v;
goto label;
label:
v = <io.netty.handler.codec.http.HttpVersion: io.netty.handler.codec.http.HttpVersion HTTP_1_1>;
if v != v goto label;
v = <io.vertx.core.http.HttpVersion: io.vertx.core.http.HttpVersion HTTP_1_1>;
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpVersion version> = v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpVersion version>;
return v;
}
public io.vertx.core.http.HttpMethod method()
{
io.netty.handler.codec.http.HttpRequest v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.HttpMethod v, v, v;
io.netty.handler.codec.http.HttpMethod v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpMethod method>;
if v != null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpRequest: io.netty.handler.codec.http.HttpMethod method()>();
v = staticinvoke <io.vertx.core.http.HttpMethod: io.vertx.core.http.HttpMethod fromNetty(io.netty.handler.codec.http.HttpMethod)>(v);
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpMethod method> = v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpMethod method>;
return v;
}
public java.lang.String uri()
{
io.netty.handler.codec.http.HttpRequest v;
io.vertx.core.http.impl.Http1xServerRequest v;
java.lang.String v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String uri>;
if v != null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpRequest: java.lang.String uri()>();
v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String uri> = v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String uri>;
return v;
}
public java.lang.String path()
{
io.vertx.core.http.impl.Http1xServerRequest v;
java.lang.String v, v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String path>;
if v != null goto label;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String uri()>();
v = staticinvoke <io.vertx.core.http.impl.HttpUtils: java.lang.String parsePath(java.lang.String)>(v);
v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String path> = v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String path>;
return v;
}
public java.lang.String query()
{
io.vertx.core.http.impl.Http1xServerRequest v;
java.lang.String v, v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String query>;
if v != null goto label;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String uri()>();
v = staticinvoke <io.vertx.core.http.impl.HttpUtils: java.lang.String parseQuery(java.lang.String)>(v);
v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String query> = v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String query>;
return v;
}
public synchronized io.vertx.core.net.HostAndPort authority()
{
io.vertx.core.http.impl.Http1xServerRequest v;
int v;
io.netty.util.AsciiString v;
io.vertx.core.net.impl.HostAndPortImpl v;
io.vertx.core.net.HostAndPort v, v;
java.lang.String v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.net.HostAndPort authority>;
if v != null goto label;
v = <io.netty.handler.codec.http.HttpHeaderNames: io.netty.util.AsciiString HOST>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String getHeader(java.lang.CharSequence)>(v);
if v == null goto label;
v = (int) -1;
v = staticinvoke <io.vertx.core.net.impl.HostAndPortImpl: io.vertx.core.net.impl.HostAndPortImpl parseHostAndPort(java.lang.String,int)>(v, v);
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.net.HostAndPort authority> = v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.net.HostAndPort authority>;
return v;
}
public java.lang.String host()
{
io.netty.util.AsciiString v;
io.vertx.core.http.impl.Http1xServerRequest v;
java.lang.String v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = <io.netty.handler.codec.http.HttpHeaderNames: io.netty.util.AsciiString HOST>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String getHeader(java.lang.CharSequence)>(v);
return v;
}
public long bytesRead()
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http1xServerRequest v;
long v;
io.vertx.core.http.impl.Http1xServerConnection v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: long bytesRead>;
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public io.vertx.core.http.impl.Http1xServerResponse response()
{
io.vertx.core.http.impl.Http1xServerResponse v;
io.vertx.core.http.impl.Http1xServerRequest v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerResponse response>;
return v;
}
public io.vertx.core.MultiMap headers()
{
io.vertx.core.http.impl.headers.HeadersAdaptor v;
io.netty.handler.codec.http.HttpHeaders v;
io.netty.handler.codec.http.HttpRequest v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.MultiMap v, v;
boolean v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap headers>;
if v != null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpRequest: io.netty.handler.codec.http.HttpHeaders headers()>();
v = v instanceof io.vertx.core.MultiMap;
if v == 0 goto label;
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap headers> = v;
goto label;
label:
v = new io.vertx.core.http.impl.headers.HeadersAdaptor;
specialinvoke v.<io.vertx.core.http.impl.headers.HeadersAdaptor: void <init>(io.netty.handler.codec.http.HttpHeaders)>(v);
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap headers> = v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap headers>;
return v;
}
public io.vertx.core.http.HttpServerRequest setParamsCharset(java.lang.String)
{
io.vertx.core.http.impl.Http1xServerRequest v;
java.nio.charset.Charset v, v, v;
java.lang.String v;
boolean v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: java.lang.String;
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "Charset must not be null");
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.nio.charset.Charset paramsCharset>;
v = staticinvoke <java.nio.charset.Charset: java.nio.charset.Charset forName(java.lang.String)>(v);
v.<io.vertx.core.http.impl.Http1xServerRequest: java.nio.charset.Charset paramsCharset> = v;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.nio.charset.Charset paramsCharset>;
v = virtualinvoke v.<java.nio.charset.Charset: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap params> = null;
label:
return v;
}
public java.lang.String getParamsCharset()
{
io.vertx.core.http.impl.Http1xServerRequest v;
java.lang.String v;
java.nio.charset.Charset v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.nio.charset.Charset paramsCharset>;
v = virtualinvoke v.<java.nio.charset.Charset: java.lang.String name()>();
return v;
}
public io.vertx.core.MultiMap params()
{
io.vertx.core.http.impl.Http1xServerRequest v;
java.nio.charset.Charset v;
io.vertx.core.MultiMap v, v, v;
java.lang.String v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap params>;
if v != null goto label;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String uri()>();
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.nio.charset.Charset paramsCharset>;
v = staticinvoke <io.vertx.core.http.impl.HttpUtils: io.vertx.core.MultiMap params(java.lang.String,java.nio.charset.Charset)>(v, v);
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap params> = v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap params>;
return v;
}
public io.vertx.core.http.HttpServerRequest handler(io.vertx.core.Handler)
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.HttpEventHandler v;
io.vertx.core.http.impl.Http1xServerConnection v;
io.vertx.core.Handler v;
boolean v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
if v == null goto label;
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void checkEnded()>();
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.HttpEventHandler eventHandler(boolean)>(v);
if v == null goto label;
virtualinvoke v.<io.vertx.core.http.impl.HttpEventHandler: void chunkHandler(io.vertx.core.Handler)>(v);
label:
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public io.vertx.core.http.HttpServerRequest exceptionHandler(io.vertx.core.Handler)
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.HttpEventHandler v;
io.vertx.core.http.impl.Http1xServerConnection v;
io.vertx.core.Handler v;
boolean v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.HttpEventHandler eventHandler(boolean)>(v);
if v == null goto label;
virtualinvoke v.<io.vertx.core.http.impl.HttpEventHandler: void exceptionHandler(io.vertx.core.Handler)>(v);
label:
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public io.vertx.core.http.HttpServerRequest pause()
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.streams.impl.InboundBuffer v;
io.vertx.core.http.impl.Http1xServerConnection v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
v = specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.streams.impl.InboundBuffer pendingQueue()>();
virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: io.vertx.core.streams.impl.InboundBuffer pause()>();
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public io.vertx.core.http.HttpServerRequest fetch(long)
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.streams.impl.InboundBuffer v;
long v;
io.vertx.core.http.impl.Http1xServerConnection v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: long;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
v = specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.streams.impl.InboundBuffer pendingQueue()>();
virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: boolean fetch(long)>(v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public io.vertx.core.http.HttpServerRequest resume()
{
io.vertx.core.http.HttpServerRequest v;
io.vertx.core.http.impl.Http1xServerRequest v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpServerRequest fetch(long)>(9223372036854775807L);
return v;
}
public io.vertx.core.http.HttpServerRequest endHandler(io.vertx.core.Handler)
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.HttpEventHandler v;
io.vertx.core.http.impl.Http1xServerConnection v;
io.vertx.core.Handler v;
boolean v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
if v == null goto label;
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void checkEnded()>();
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.HttpEventHandler eventHandler(boolean)>(v);
if v == null goto label;
virtualinvoke v.<io.vertx.core.http.impl.HttpEventHandler: void endHandler(io.vertx.core.Handler)>(v);
label:
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public java.lang.String scheme()
{
io.vertx.core.http.impl.Http1xServerRequest v;
java.lang.String v;
boolean v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: boolean isSSL()>();
if v == 0 goto label;
v = "https";
goto label;
label:
v = "http";
label:
return v;
}
public java.lang.String absoluteURI()
{
io.vertx.core.impl.logging.Logger v;
java.net.URISyntaxException v;
io.vertx.core.http.impl.Http1xServerConnection v;
io.vertx.core.http.impl.Http1xServerRequest v;
java.lang.String v, v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String absoluteURI>;
if v != null goto label;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerConnection: java.lang.String getServerOrigin()>();
v = staticinvoke <io.vertx.core.http.impl.HttpUtils: java.lang.String absoluteURI(java.lang.String,io.vertx.core.http.HttpServerRequest)>(v, v);
v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String absoluteURI> = v;
label:
goto label;
label:
v := @caughtexception;
v = <io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.impl.logging.Logger log>;
interfaceinvoke v.<io.vertx.core.impl.logging.Logger: void error(java.lang.Object,java.lang.Throwable)>("Failed to create abs uri", v);
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.String absoluteURI>;
return v;
catch java.net.URISyntaxException from label to label with label;
}
public io.vertx.core.net.SocketAddress remoteAddress()
{
io.vertx.core.http.impl.Http1xServerConnection v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.net.SocketAddress v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerConnection: io.vertx.core.net.SocketAddress remoteAddress()>();
return v;
}
public javax.security.cert.X509Certificate[] peerCertificateChain() throws javax.net.ssl.SSLPeerUnverifiedException
{
javax.security.cert.X509Certificate[] v;
io.vertx.core.http.impl.Http1xServerConnection v;
io.vertx.core.http.impl.Http1xServerRequest v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerConnection: javax.security.cert.X509Certificate[] peerCertificateChain()>();
return v;
}
public io.vertx.core.Future toNetSocket()
{
io.vertx.core.http.impl.Http1xServerResponse v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.HttpMethod v;
io.vertx.core.MultiMap v;
io.vertx.core.Future v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerResponse response>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpMethod method()>();
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap headers()>();
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerResponse: io.vertx.core.Future netSocket(io.vertx.core.http.HttpMethod,io.vertx.core.MultiMap)>(v, v);
return v;
}
public io.vertx.core.http.HttpServerRequest uploadHandler(io.vertx.core.Handler)
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.Http1xServerConnection v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
if v == null goto label;
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void checkEnded()>();
label:
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.Handler uploadHandler> = v;
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public io.vertx.core.MultiMap formAttributes()
{
io.vertx.core.MultiMap v;
io.vertx.core.http.impl.Http1xServerRequest v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap attributes()>();
return v;
}
public java.lang.String getFormAttribute(java.lang.String)
{
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.MultiMap v;
java.lang.String v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap formAttributes()>();
v = interfaceinvoke v.<io.vertx.core.MultiMap: java.lang.String get(java.lang.String)>(v);
return v;
}
public io.vertx.core.Future toWebSocket()
{
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.Future v, v;
java.util.function.Function v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.Future webSocket()>();
v = staticinvoke <io.vertx.core.http.impl.Http1xServerRequest$lambda_toWebSocket_2__1540: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<io.vertx.core.Future: io.vertx.core.Future map(java.util.function.Function)>(v);
return v;
}
io.vertx.core.Future webSocket()
{
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.impl.future.PromiseInternal v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.Future v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.impl.ContextInternal context>;
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.impl.future.PromiseInternal promise()>();
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void webSocket(io.vertx.core.impl.future.PromiseInternal)>(v);
v = interfaceinvoke v.<io.vertx.core.impl.future.PromiseInternal: io.vertx.core.Future future()>();
return v;
}
private void webSocket(io.vertx.core.impl.future.PromiseInternal)
{
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.impl.future.PromiseInternal v;
io.vertx.core.buffer.Buffer v;
boolean[] v;
io.vertx.core.Handler v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: io.vertx.core.impl.future.PromiseInternal;
v = staticinvoke <io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer buffer()>();
v = newarray (boolean)[1];
v = staticinvoke <io.vertx.core.http.impl.Http1xServerRequest$lambda_webSocket_3__1541: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.Http1xServerRequest,boolean[],io.vertx.core.buffer.Buffer)>(v, v, v);
virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpServerRequest handler(io.vertx.core.Handler)>(v);
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <io.vertx.core.http.impl.Http1xServerRequest$tryFail__1542: io.vertx.core.Handler bootstrap$(io.vertx.core.impl.future.PromiseInternal)>(v);
virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpServerRequest exceptionHandler(io.vertx.core.Handler)>(v);
v = staticinvoke <io.vertx.core.http.impl.Http1xServerRequest$lambda_webSocket_4__1543: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.Http1xServerRequest,boolean[],io.vertx.core.buffer.Buffer,io.vertx.core.impl.future.PromiseInternal)>(v, v, v, v);
virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpServerRequest endHandler(io.vertx.core.Handler)>(v);
virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.HttpServerRequest resume()>();
return;
}
public io.vertx.core.http.HttpServerRequest setExpectMultipart(boolean)
{
java.lang.Throwable v;
java.lang.IllegalStateException v, v, v;
io.netty.handler.codec.http.HttpHeaders v;
io.netty.util.AsciiString v;
io.vertx.core.impl.ContextInternal v;
java.util.function.Supplier v;
io.vertx.core.http.impl.Http1xServerRequest v;
int v;
java.lang.String v;
boolean v, v, v;
io.netty.handler.codec.http.HttpRequest v, v, v;
io.vertx.core.http.impl.NettyFileUploadDataFactory v;
io.netty.handler.codec.http.HttpMethod v;
io.vertx.core.http.impl.Http1xServerConnection v, v;
io.vertx.core.http.HttpServerOptions v;
io.netty.handler.codec.http.multipart.HttpPostRequestDecoder v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: boolean;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void checkEnded()>();
if v == 0 goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
if v != null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpRequest: io.netty.handler.codec.http.HttpHeaders headers()>();
v = <io.netty.handler.codec.http.HttpHeaderNames: io.netty.util.AsciiString CONTENT_TYPE>;
v = virtualinvoke v.<io.netty.handler.codec.http.HttpHeaders: java.lang.String get(java.lang.CharSequence)>(v);
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Request must have a content-type header to decode a multipart request");
throw v;
label:
v = staticinvoke <io.vertx.core.http.impl.HttpUtils: boolean isValidMultipartContentType(java.lang.String)>(v);
if v != 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Request must have a valid content-type header to decode a multipart request");
throw v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpRequest: io.netty.handler.codec.http.HttpMethod method()>();
v = staticinvoke <io.vertx.core.http.impl.HttpUtils: boolean isValidMultipartMethod(io.netty.handler.codec.http.HttpMethod)>(v);
if v != 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Request method must be one of POST, PUT, PATCH or DELETE to decode a multipart request");
throw v;
label:
v = new io.vertx.core.http.impl.NettyFileUploadDataFactory;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.impl.ContextInternal context>;
v = staticinvoke <io.vertx.core.http.impl.Http1xServerRequest$lambda_setExpectMultipart_5__1544: java.util.function.Supplier bootstrap$(io.vertx.core.http.impl.Http1xServerRequest)>(v);
specialinvoke v.<io.vertx.core.http.impl.NettyFileUploadDataFactory: void <init>(io.vertx.core.impl.ContextInternal,io.vertx.core.http.HttpServerRequest,java.util.function.Supplier)>(v, v, v);
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = v.<io.vertx.core.http.impl.Http1xServerConnection: io.vertx.core.http.HttpServerOptions options>;
v = virtualinvoke v.<io.vertx.core.http.HttpServerOptions: int getMaxFormAttributeSize()>();
virtualinvoke v.<io.vertx.core.http.impl.NettyFileUploadDataFactory: void setMaxLimit(long)>(v);
v = new io.netty.handler.codec.http.multipart.HttpPostRequestDecoder;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
specialinvoke v.<io.netty.handler.codec.http.multipart.HttpPostRequestDecoder: void <init>(io.netty.handler.codec.http.multipart.HttpDataFactory,io.netty.handler.codec.http.HttpRequest)>(v, v);
v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder> = v;
goto label;
label:
v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder> = null;
label:
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean isExpectMultipart()
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.Http1xServerConnection v;
io.netty.handler.codec.http.multipart.HttpPostRequestDecoder v;
boolean v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean isEnded()
{
java.lang.Throwable v;
io.vertx.core.streams.impl.InboundBuffer v, v, v;
io.vertx.core.http.impl.Http1xServerConnection v;
io.vertx.core.http.impl.Http1xServerRequest v;
boolean v, v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: boolean ended>;
if v == 0 goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.streams.impl.InboundBuffer pending>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.streams.impl.InboundBuffer pending>;
v = virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: boolean isPaused()>();
if v != 0 goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.streams.impl.InboundBuffer pending>;
v = virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: boolean isEmpty()>();
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public io.vertx.core.http.HttpServerRequest customFrameHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: io.vertx.core.Handler;
return v;
}
public io.vertx.core.http.HttpConnection connection()
{
io.vertx.core.http.impl.Http1xServerConnection v;
io.vertx.core.http.impl.Http1xServerRequest v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
return v;
}
public synchronized io.vertx.core.Future body()
{
io.vertx.core.http.impl.HttpEventHandler v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.Future v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void checkEnded()>();
v = specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.HttpEventHandler eventHandler(boolean)>(1);
v = virtualinvoke v.<io.vertx.core.http.impl.HttpEventHandler: io.vertx.core.Future body()>();
return v;
}
public synchronized io.vertx.core.Future end()
{
io.vertx.core.http.impl.HttpEventHandler v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.Future v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void checkEnded()>();
v = specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.HttpEventHandler eventHandler(boolean)>(1);
v = virtualinvoke v.<io.vertx.core.http.impl.HttpEventHandler: io.vertx.core.Future end()>();
return v;
}
public void onData(io.vertx.core.buffer.Buffer)
{
java.lang.Throwable v;
io.vertx.core.http.impl.HttpEventHandler v, v;
long v, v;
io.vertx.core.http.impl.Http1xServerConnection v;
io.netty.handler.codec.http.multipart.HttpPostRequestDecoder$ErrorDataDecoderException v;
io.netty.handler.codec.http.DefaultHttpContent v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.netty.buffer.ByteBuf v;
io.vertx.core.buffer.Buffer v;
int v;
io.netty.handler.codec.http.multipart.HttpPostRequestDecoder v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: io.vertx.core.buffer.Buffer;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: long bytesRead>;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int length()>();
v = v + v;
v.<io.vertx.core.http.impl.Http1xServerRequest: long bytesRead> = v;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
if v == null goto label;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
v = new io.netty.handler.codec.http.DefaultHttpContent;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.netty.buffer.ByteBuf getByteBuf()>();
specialinvoke v.<io.netty.handler.codec.http.DefaultHttpContent: void <init>(io.netty.buffer.ByteBuf)>(v);
virtualinvoke v.<io.netty.handler.codec.http.multipart.HttpPostRequestDecoder: io.netty.handler.codec.http.multipart.InterfaceHttpPostRequestDecoder offer(io.netty.handler.codec.http.HttpContent)>(v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void handleException(java.lang.Throwable)>(v);
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.HttpEventHandler eventHandler>;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.HttpEventHandler eventHandler>;
virtualinvoke v.<io.vertx.core.http.impl.HttpEventHandler: void handleChunk(io.vertx.core.buffer.Buffer)>(v);
label:
return;
catch io.netty.handler.codec.http.multipart.HttpPostRequestDecoder$ErrorDataDecoderException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
void handleEnd()
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.streams.impl.InboundBuffer v;
java.lang.Object v;
io.vertx.core.http.impl.Http1xServerConnection v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
v.<io.vertx.core.http.impl.Http1xServerRequest: boolean ended> = 1;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.streams.impl.InboundBuffer pending>;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
v = <io.vertx.core.streams.impl.InboundBuffer: java.lang.Object END_SENTINEL>;
virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: boolean write(java.lang.Object)>(v);
goto label;
label:
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void onEnd()>();
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void onEnd()
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.HttpEventHandler v;
io.vertx.core.http.impl.Http1xServerConnection v;
io.netty.handler.codec.http.multipart.HttpPostRequestDecoder v;
boolean v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = <io.vertx.core.spi.metrics.Metrics: boolean METRICS_ENABLED>;
if v == 0 goto label;
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void reportRequestComplete()>();
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
if v == null goto label;
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void endDecode()>();
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.HttpEventHandler eventHandler>;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
virtualinvoke v.<io.vertx.core.http.impl.HttpEventHandler: void handleEnd()>();
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void reportRequestComplete()
{
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.spi.metrics.HttpServerMetrics v;
java.lang.Object v;
long v;
io.vertx.core.http.impl.Http1xServerConnection v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = v.<io.vertx.core.http.impl.Http1xServerConnection: io.vertx.core.spi.metrics.HttpServerMetrics metrics>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.Object metric>;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: long bytesRead>;
interfaceinvoke v.<io.vertx.core.spi.metrics.HttpServerMetrics: void requestEnd(java.lang.Object,io.vertx.core.spi.observability.HttpRequest,long)>(v, v, v);
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
virtualinvoke v.<io.vertx.core.http.impl.Http1xServerConnection: void flushBytesRead()>();
label:
return;
}
private void reportRequestBegin()
{
io.netty.handler.codec.http.HttpHeaders v;
io.vertx.core.impl.ContextInternal v, v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.spi.metrics.HttpServerMetrics v;
io.vertx.core.spi.tracing.SpanKind v;
java.lang.String v;
io.vertx.core.tracing.TracingPolicy v;
io.netty.handler.codec.http.HttpRequest v, v;
io.vertx.core.spi.tracing.TagExtractor v;
io.netty.handler.codec.http.HttpMethod v;
io.vertx.core.spi.tracing.VertxTracer v;
io.vertx.core.http.impl.Http1xServerConnection v, v, v;
java.lang.Object v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = v.<io.vertx.core.http.impl.Http1xServerConnection: io.vertx.core.spi.metrics.HttpServerMetrics metrics>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerConnection: java.lang.Object metric()>();
v = interfaceinvoke v.<io.vertx.core.spi.metrics.HttpServerMetrics: java.lang.Object requestBegin(java.lang.Object,io.vertx.core.spi.observability.HttpRequest)>(v, v);
v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.Object metric> = v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: 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 = v.<io.vertx.core.http.impl.Http1xServerRequest: 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.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerConnection: io.vertx.core.tracing.TracingPolicy tracingPolicy()>();
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpRequest: io.netty.handler.codec.http.HttpMethod method()>();
v = virtualinvoke v.<io.netty.handler.codec.http.HttpMethod: java.lang.String name()>();
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpRequest: io.netty.handler.codec.http.HttpHeaders headers()>();
v = <io.vertx.core.http.impl.HttpUtils: io.vertx.core.spi.tracing.TagExtractor SERVER_REQUEST_TAG_EXTRACTOR>;
v = interfaceinvoke v.<io.vertx.core.spi.tracing.VertxTracer: java.lang.Object receiveRequest(io.vertx.core.Context,io.vertx.core.spi.tracing.SpanKind,io.vertx.core.tracing.TracingPolicy,java.lang.Object,java.lang.String,java.lang.Iterable,io.vertx.core.spi.tracing.TagExtractor)>(v, v, v, v, v, v, v);
v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.Object trace> = v;
label:
return;
}
private void endDecode()
{
java.lang.Throwable v, v;
io.vertx.core.MultiMap v;
io.netty.handler.codec.http.LastHttpContent v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.netty.handler.codec.http.multipart.HttpPostRequestDecoder$EndOfDataDecoderException v;
java.lang.String v, v;
boolean v, v;
io.netty.handler.codec.http.multipart.InterfaceHttpData v;
io.netty.handler.codec.http.multipart.HttpPostRequestDecoder$ErrorDataDecoderException v;
java.lang.Exception v;
io.netty.handler.codec.http.multipart.HttpPostRequestDecoder v, v, v, v, v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
v = <io.netty.handler.codec.http.LastHttpContent: io.netty.handler.codec.http.LastHttpContent EMPTY_LAST_CONTENT>;
virtualinvoke v.<io.netty.handler.codec.http.multipart.HttpPostRequestDecoder: io.netty.handler.codec.http.multipart.InterfaceHttpPostRequestDecoder offer(io.netty.handler.codec.http.HttpContent)>(v);
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
v = virtualinvoke v.<io.netty.handler.codec.http.multipart.HttpPostRequestDecoder: boolean hasNext()>();
if v == 0 goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
v = virtualinvoke v.<io.netty.handler.codec.http.multipart.HttpPostRequestDecoder: io.netty.handler.codec.http.multipart.InterfaceHttpData next()>();
v = v instanceof io.netty.handler.codec.http.multipart.Attribute;
if v == 0 goto label;
label:
v = specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap attributes()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.multipart.Attribute: java.lang.String getName()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.multipart.Attribute: java.lang.String getValue()>();
interfaceinvoke v.<io.vertx.core.MultiMap: io.vertx.core.MultiMap add(java.lang.String,java.lang.String)>(v, v);
label:
interfaceinvoke v.<io.netty.handler.codec.http.multipart.Attribute: boolean release()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void handleException(java.lang.Throwable)>(v);
label:
interfaceinvoke v.<io.netty.handler.codec.http.multipart.Attribute: boolean release()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<io.netty.handler.codec.http.multipart.Attribute: boolean release()>();
throw v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
virtualinvoke v.<io.netty.handler.codec.http.multipart.HttpPostRequestDecoder: void destroy()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void handleException(java.lang.Throwable)>(v);
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
virtualinvoke v.<io.netty.handler.codec.http.multipart.HttpPostRequestDecoder: void destroy()>();
goto label;
label:
v := @caughtexception;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
virtualinvoke v.<io.netty.handler.codec.http.multipart.HttpPostRequestDecoder: void destroy()>();
goto label;
label:
v := @caughtexception;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
virtualinvoke v.<io.netty.handler.codec.http.multipart.HttpPostRequestDecoder: void destroy()>();
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch io.netty.handler.codec.http.multipart.HttpPostRequestDecoder$ErrorDataDecoderException from label to label with label;
catch io.netty.handler.codec.http.multipart.HttpPostRequestDecoder$EndOfDataDecoderException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
void handleException(java.lang.Throwable)
{
java.lang.Throwable v, v;
io.vertx.core.http.impl.HttpEventHandler v;
io.vertx.core.http.impl.Http1xServerConnection v;
io.netty.handler.codec.http.multipart.InterfaceHttpData v;
io.vertx.core.http.impl.Http1xServerResponse v, v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.netty.handler.codec.http.multipart.HttpPostRequestDecoder v, v;
boolean v, v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: java.lang.Throwable;
v = null;
v = null;
v = null;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
entermonitor v;
label:
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: boolean isEnded()>();
if v != 0 goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.HttpEventHandler eventHandler>;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.multipart.HttpPostRequestDecoder decoder>;
v = virtualinvoke v.<io.netty.handler.codec.http.multipart.HttpPostRequestDecoder: io.netty.handler.codec.http.multipart.InterfaceHttpData currentPartialHttpData()>();
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerResponse response>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerResponse: boolean ended()>();
if v != 0 goto label;
v = <io.vertx.core.spi.metrics.Metrics: boolean METRICS_ENABLED>;
if v == 0 goto label;
specialinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: void reportRequestReset(java.lang.Throwable)>(v);
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerResponse response>;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
virtualinvoke v.<io.vertx.core.http.impl.Http1xServerResponse: void handleException(java.lang.Throwable)>(v);
label:
v = v instanceof io.vertx.core.http.impl.NettyFileUpload;
if v == 0 goto label;
virtualinvoke v.<io.vertx.core.http.impl.NettyFileUpload: void handleException(java.lang.Throwable)>(v);
label:
if v == null goto label;
virtualinvoke v.<io.vertx.core.http.impl.HttpEventHandler: void handleException(java.lang.Throwable)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void reportRequestReset(java.lang.Throwable)
{
java.lang.Throwable v;
io.vertx.core.spi.tracing.TagExtractor v;
io.vertx.core.impl.ContextInternal v, v;
io.vertx.core.spi.tracing.VertxTracer v;
io.vertx.core.http.impl.Http1xServerConnection v, v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.spi.metrics.HttpServerMetrics v, v;
java.lang.Object v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: java.lang.Throwable;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = v.<io.vertx.core.http.impl.Http1xServerConnection: io.vertx.core.spi.metrics.HttpServerMetrics metrics>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = v.<io.vertx.core.http.impl.Http1xServerConnection: io.vertx.core.spi.metrics.HttpServerMetrics metrics>;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.Object metric>;
interfaceinvoke v.<io.vertx.core.spi.metrics.HttpServerMetrics: void requestReset(java.lang.Object)>(v);
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: 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 = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.impl.ContextInternal context>;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.Object trace>;
v = staticinvoke <io.vertx.core.spi.tracing.TagExtractor: io.vertx.core.spi.tracing.TagExtractor empty()>();
interfaceinvoke v.<io.vertx.core.spi.tracing.VertxTracer: void sendResponse(io.vertx.core.Context,java.lang.Object,java.lang.Object,java.lang.Throwable,io.vertx.core.spi.tracing.TagExtractor)>(v, null, v, v, v);
label:
return;
}
private void checkEnded()
{
java.lang.IllegalStateException v;
io.vertx.core.http.impl.Http1xServerRequest v;
boolean v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerRequest: boolean isEnded()>();
if v == 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Request has already been read");
throw v;
label:
return;
}
private io.vertx.core.MultiMap attributes()
{
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.MultiMap v, v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap attributes>;
if v != null goto label;
v = staticinvoke <io.vertx.core.MultiMap: io.vertx.core.MultiMap caseInsensitiveMultiMap()>();
v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap attributes> = v;
label:
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.MultiMap attributes>;
return v;
}
public io.vertx.core.http.HttpServerRequest streamPriorityHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: io.vertx.core.Handler;
return v;
}
public io.netty.handler.codec.DecoderResult decoderResult()
{
io.netty.handler.codec.DecoderResult v;
io.netty.handler.codec.http.HttpRequest v;
io.vertx.core.http.impl.Http1xServerRequest v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.netty.handler.codec.http.HttpRequest request>;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpRequest: io.netty.handler.codec.DecoderResult decoderResult()>();
return v;
}
public java.util.Set cookies()
{
io.vertx.core.http.impl.Http1xServerResponse v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.CookieJar v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerResponse response>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerResponse: io.vertx.core.http.impl.CookieJar cookies()>();
return v;
}
public java.util.Set cookies(java.lang.String)
{
io.vertx.core.http.impl.Http1xServerResponse v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.CookieJar v, v;
java.lang.String v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: java.lang.String;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerResponse response>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerResponse: io.vertx.core.http.impl.CookieJar cookies()>();
v = virtualinvoke v.<io.vertx.core.http.impl.CookieJar: io.vertx.core.http.impl.CookieJar getAll(java.lang.String)>(v);
return v;
}
public io.vertx.core.http.Cookie getCookie(java.lang.String)
{
io.vertx.core.http.impl.Http1xServerResponse v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.CookieJar v;
java.lang.String v;
io.vertx.core.http.impl.ServerCookie v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: java.lang.String;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerResponse response>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerResponse: io.vertx.core.http.impl.CookieJar cookies()>();
v = virtualinvoke v.<io.vertx.core.http.impl.CookieJar: io.vertx.core.http.impl.ServerCookie get(java.lang.String)>(v);
return v;
}
public io.vertx.core.http.Cookie getCookie(java.lang.String, java.lang.String, java.lang.String)
{
io.vertx.core.http.impl.Http1xServerResponse v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.http.impl.CookieJar v;
java.lang.String v, v, v;
io.vertx.core.http.impl.ServerCookie v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerResponse response>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerResponse: io.vertx.core.http.impl.CookieJar cookies()>();
v = virtualinvoke v.<io.vertx.core.http.impl.CookieJar: io.vertx.core.http.impl.ServerCookie get(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
return v;
}
public io.vertx.core.http.HttpServerRequest routed(java.lang.String)
{
io.vertx.core.http.impl.Http1xServerConnection v, v;
io.vertx.core.http.impl.Http1xServerResponse v;
io.vertx.core.http.impl.Http1xServerRequest v;
io.vertx.core.spi.metrics.HttpServerMetrics v, v;
java.lang.Object v;
java.lang.String v;
boolean v, v;
v := @this: io.vertx.core.http.impl.Http1xServerRequest;
v := @parameter: java.lang.String;
v = <io.vertx.core.spi.metrics.Metrics: boolean METRICS_ENABLED>;
if v == 0 goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerResponse response>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xServerResponse: boolean ended()>();
if v != 0 goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = v.<io.vertx.core.http.impl.Http1xServerConnection: io.vertx.core.spi.metrics.HttpServerMetrics metrics>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.http.impl.Http1xServerConnection conn>;
v = v.<io.vertx.core.http.impl.Http1xServerConnection: io.vertx.core.spi.metrics.HttpServerMetrics metrics>;
v = v.<io.vertx.core.http.impl.Http1xServerRequest: java.lang.Object metric>;
interfaceinvoke v.<io.vertx.core.spi.metrics.HttpServerMetrics: void requestRouted(java.lang.Object,java.lang.String)>(v, v);
label:
return v;
}
static void <clinit>()
{
io.vertx.core.impl.logging.Logger v;
v = staticinvoke <io.vertx.core.impl.logging.LoggerFactory: io.vertx.core.impl.logging.Logger getLogger(java.lang.Class)>(class "Lio/vertx/core/http/impl/Http1xServerRequest;");
<io.vertx.core.http.impl.Http1xServerRequest: io.vertx.core.impl.logging.Logger log> = v;
return;
}
}