class io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request extends java.lang.Object implements io.vertx.core.net.impl.pool.PoolWaiter$Listener, io.vertx.core.Handler
{
private final io.vertx.core.impl.ContextInternal context;
private final io.vertx.core.http.HttpVersion protocol;
private final long timeout;
private final io.vertx.core.Handler handler;
private long timerID;
final io.vertx.core.http.impl.SharedClientHttpStreamEndpoint this$0;
void <init>(io.vertx.core.http.impl.SharedClientHttpStreamEndpoint, io.vertx.core.impl.ContextInternal, io.vertx.core.http.HttpVersion, long, io.vertx.core.Handler)
{
io.vertx.core.http.HttpVersion v;
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request v;
io.vertx.core.impl.ContextInternal v;
long v;
io.vertx.core.Handler v;
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint v;
v := @this: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request;
v := @parameter: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: io.vertx.core.http.HttpVersion;
v := @parameter: long;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: io.vertx.core.impl.ContextInternal context> = v;
v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: io.vertx.core.http.HttpVersion protocol> = v;
v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: long timeout> = v;
v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: io.vertx.core.Handler handler> = v;
v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: long timerID> = -1L;
return;
}
public void onEnqueue(io.vertx.core.net.impl.pool.PoolWaiter)
{
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request v;
io.vertx.core.net.impl.pool.PoolWaiter v;
v := @this: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request;
v := @parameter: io.vertx.core.net.impl.pool.PoolWaiter;
virtualinvoke v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: void onConnect(io.vertx.core.net.impl.pool.PoolWaiter)>(v);
return;
}
public void onConnect(io.vertx.core.net.impl.pool.PoolWaiter)
{
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request v;
io.vertx.core.impl.ContextInternal v;
long v, v, v, v;
byte v, v;
io.vertx.core.net.impl.pool.PoolWaiter v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request;
v := @parameter: io.vertx.core.net.impl.pool.PoolWaiter;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: long timeout>;
v = v cmp 0L;
if v <= 0 goto label;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: long timerID>;
v = v cmp -1L;
if v != 0 goto label;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: io.vertx.core.impl.ContextInternal context>;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: long timeout>;
v = staticinvoke <io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request$lambda_onConnect_1__1047: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request,io.vertx.core.net.impl.pool.PoolWaiter)>(v, v);
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: long setTimer(long,io.vertx.core.Handler)>(v, v);
v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: long timerID> = v;
label:
return;
}
public void handle(io.vertx.core.AsyncResult)
{
io.vertx.core.impl.VertxInternal v;
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request v;
io.vertx.core.impl.ContextInternal v;
long v, v;
byte v;
io.vertx.core.AsyncResult v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request;
v := @parameter: io.vertx.core.AsyncResult;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: long timerID>;
v = v cmp 0L;
if v < 0 goto label;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: io.vertx.core.impl.ContextInternal context>;
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.impl.VertxInternal owner()>();
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: long timerID>;
interfaceinvoke v.<io.vertx.core.impl.VertxInternal: boolean cancelTimer(long)>(v);
label:
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: io.vertx.core.Handler handler>;
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(v);
return;
}
void acquire()
{
byte v;
io.vertx.core.http.HttpVersion v, v;
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request v;
io.vertx.core.net.impl.pool.ConnectionPool v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint v;
v := @this: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint this$0>;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint: io.vertx.core.net.impl.pool.ConnectionPool pool>;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: io.vertx.core.impl.ContextInternal context>;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: io.vertx.core.http.HttpVersion protocol>;
v = <io.vertx.core.http.HttpVersion: io.vertx.core.http.HttpVersion HTTP_2>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
interfaceinvoke v.<io.vertx.core.net.impl.pool.ConnectionPool: void acquire(io.vertx.core.impl.ContextInternal,io.vertx.core.net.impl.pool.PoolWaiter$Listener,int,io.vertx.core.Handler)>(v, v, v, v);
return;
}
}