class io.vertx.core.http.impl.SharedClientHttpStreamEndpoint extends io.vertx.core.http.impl.ClientHttpEndpointBase implements io.vertx.core.net.impl.pool.PoolConnector
{
private static final java.util.function.BiFunction LIFO_SELECTOR;
private final io.vertx.core.http.impl.HttpClientImpl client;
private final io.vertx.core.http.impl.HttpChannelConnector connector;
private final io.vertx.core.net.impl.pool.ConnectionPool pool;
public void <init>(io.vertx.core.http.impl.HttpClientImpl, io.vertx.core.spi.metrics.ClientMetrics, int, int, int, io.vertx.core.http.impl.HttpChannelConnector, java.lang.Runnable)
{
io.vertx.core.http.impl.HttpChannelConnector v;
io.vertx.core.http.impl.HttpClientImpl v;
java.util.function.BiFunction v;
io.vertx.core.net.impl.pool.ConnectionPool v, v, v;
java.lang.Runnable v;
java.util.function.Function v;
int[] v;
int v, v, v;
io.vertx.core.spi.metrics.ClientMetrics v;
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint v;
v := @this: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint;
v := @parameter: io.vertx.core.http.impl.HttpClientImpl;
v := @parameter: io.vertx.core.spi.metrics.ClientMetrics;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v := @parameter: io.vertx.core.http.impl.HttpChannelConnector;
v := @parameter: java.lang.Runnable;
specialinvoke v.<io.vertx.core.http.impl.ClientHttpEndpointBase: void <init>(io.vertx.core.spi.metrics.ClientMetrics,java.lang.Runnable)>(v, v);
v = newarray (int)[2];
v[0] = v;
v[1] = v;
v = staticinvoke <io.vertx.core.net.impl.pool.ConnectionPool: io.vertx.core.net.impl.pool.ConnectionPool pool(io.vertx.core.net.impl.pool.PoolConnector,int[],int)>(v, v, v);
v = <io.vertx.core.http.impl.SharedClientHttpStreamEndpoint: java.util.function.BiFunction LIFO_SELECTOR>;
v = interfaceinvoke v.<io.vertx.core.net.impl.pool.ConnectionPool: io.vertx.core.net.impl.pool.ConnectionPool connectionSelector(java.util.function.BiFunction)>(v);
v = virtualinvoke v.<io.vertx.core.http.impl.HttpClientImpl: java.util.function.Function contextProvider()>();
v = interfaceinvoke v.<io.vertx.core.net.impl.pool.ConnectionPool: io.vertx.core.net.impl.pool.ConnectionPool contextProvider(java.util.function.Function)>(v);
v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint: io.vertx.core.http.impl.HttpClientImpl client> = v;
v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint: io.vertx.core.http.impl.HttpChannelConnector connector> = v;
v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint: io.vertx.core.net.impl.pool.ConnectionPool pool> = v;
return;
}
public void connect(io.vertx.core.impl.EventLoopContext, io.vertx.core.net.impl.pool.PoolConnector$Listener, io.vertx.core.Handler)
{
io.vertx.core.impl.EventLoopContext v;
io.vertx.core.http.impl.HttpChannelConnector v;
io.vertx.core.Handler v, v;
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint v;
io.vertx.core.net.impl.pool.PoolConnector$Listener v;
v := @this: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint;
v := @parameter: io.vertx.core.impl.EventLoopContext;
v := @parameter: io.vertx.core.net.impl.pool.PoolConnector$Listener;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint: io.vertx.core.http.impl.HttpChannelConnector connector>;
v = staticinvoke <io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$lambda_connect_2__1150: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.SharedClientHttpStreamEndpoint,io.vertx.core.net.impl.pool.PoolConnector$Listener,io.vertx.core.impl.EventLoopContext,io.vertx.core.Handler)>(v, v, v, v);
virtualinvoke v.<io.vertx.core.http.impl.HttpChannelConnector: void httpConnect(io.vertx.core.impl.EventLoopContext,io.vertx.core.Handler)>(v, v);
return;
}
public boolean isValid(io.vertx.core.http.impl.HttpClientConnection)
{
io.vertx.core.http.impl.HttpClientConnection v;
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint v;
boolean v;
v := @this: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint;
v := @parameter: io.vertx.core.http.impl.HttpClientConnection;
v = interfaceinvoke v.<io.vertx.core.http.impl.HttpClientConnection: boolean isValid()>();
return v;
}
void checkExpired()
{
java.util.function.Predicate v;
io.vertx.core.net.impl.pool.ConnectionPool v;
io.vertx.core.Handler v;
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint v;
v := @this: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint: io.vertx.core.net.impl.pool.ConnectionPool pool>;
v = staticinvoke <io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$lambda_checkExpired_3__1151: java.util.function.Predicate bootstrap$()>();
v = staticinvoke <io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$lambda_checkExpired_4__1152: io.vertx.core.Handler bootstrap$()>();
interfaceinvoke v.<io.vertx.core.net.impl.pool.ConnectionPool: void evict(java.util.function.Predicate,io.vertx.core.Handler)>(v, v);
return;
}
public void requestConnection2(io.vertx.core.impl.ContextInternal, long, io.vertx.core.Handler)
{
io.vertx.core.http.impl.HttpClientImpl v;
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request v;
io.vertx.core.impl.ContextInternal v;
long v;
io.vertx.core.http.HttpVersion v;
io.vertx.core.http.HttpClientOptions v;
io.vertx.core.Handler v;
io.vertx.core.http.impl.SharedClientHttpStreamEndpoint v;
v := @this: io.vertx.core.http.impl.SharedClientHttpStreamEndpoint;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: long;
v := @parameter: io.vertx.core.Handler;
v = new io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request;
v = v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint: 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.http.HttpVersion getProtocolVersion()>();
specialinvoke v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: void <init>(io.vertx.core.http.impl.SharedClientHttpStreamEndpoint,io.vertx.core.impl.ContextInternal,io.vertx.core.http.HttpVersion,long,io.vertx.core.Handler)>(v, v, v, v, v);
virtualinvoke v.<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$Request: void acquire()>();
return;
}
static void <clinit>()
{
java.util.function.BiFunction v;
v = staticinvoke <io.vertx.core.http.impl.SharedClientHttpStreamEndpoint$lambda_static_0__1156: java.util.function.BiFunction bootstrap$()>();
<io.vertx.core.http.impl.SharedClientHttpStreamEndpoint: java.util.function.BiFunction LIFO_SELECTOR> = v;
return;
}
}