public class io.vertx.core.net.impl.pool.ConnectionManager extends java.lang.Object
{
private final java.util.Map endpointMap;
public void <init>()
{
java.util.concurrent.ConcurrentHashMap v;
io.vertx.core.net.impl.pool.ConnectionManager v;
v := @this: io.vertx.core.net.impl.pool.ConnectionManager;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<io.vertx.core.net.impl.pool.ConnectionManager: java.util.Map endpointMap> = v;
return;
}
public void forEach(java.util.function.Consumer)
{
java.util.function.Consumer v;
java.util.Collection v;
java.util.Map v;
io.vertx.core.net.impl.pool.ConnectionManager v;
v := @this: io.vertx.core.net.impl.pool.ConnectionManager;
v := @parameter: java.util.function.Consumer;
v = v.<io.vertx.core.net.impl.pool.ConnectionManager: java.util.Map endpointMap>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
interfaceinvoke v.<java.util.Collection: void forEach(java.util.function.Consumer)>(v);
return;
}
public void getConnection(io.vertx.core.impl.ContextInternal, java.lang.Object, io.vertx.core.net.impl.pool.EndpointProvider, io.vertx.core.Handler)
{
io.vertx.core.impl.ContextInternal v;
java.lang.Object v;
io.vertx.core.Handler v;
io.vertx.core.net.impl.pool.ConnectionManager v;
io.vertx.core.net.impl.pool.EndpointProvider v;
v := @this: io.vertx.core.net.impl.pool.ConnectionManager;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: java.lang.Object;
v := @parameter: io.vertx.core.net.impl.pool.EndpointProvider;
v := @parameter: io.vertx.core.Handler;
virtualinvoke v.<io.vertx.core.net.impl.pool.ConnectionManager: void getConnection(io.vertx.core.impl.ContextInternal,java.lang.Object,io.vertx.core.net.impl.pool.EndpointProvider,long,io.vertx.core.Handler)>(v, v, v, 0L, v);
return;
}
public void getConnection(io.vertx.core.impl.ContextInternal, java.lang.Object, io.vertx.core.net.impl.pool.EndpointProvider, long, io.vertx.core.Handler)
{
io.vertx.core.impl.ContextInternal v;
long v;
java.lang.Runnable v;
java.util.function.Function v;
java.util.Map v;
java.lang.Object v, v;
io.vertx.core.Handler v;
io.vertx.core.net.impl.pool.ConnectionManager v;
io.vertx.core.net.impl.pool.EndpointProvider v;
boolean v;
v := @this: io.vertx.core.net.impl.pool.ConnectionManager;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: java.lang.Object;
v := @parameter: io.vertx.core.net.impl.pool.EndpointProvider;
v := @parameter: long;
v := @parameter: io.vertx.core.Handler;
v = staticinvoke <io.vertx.core.net.impl.pool.ConnectionManager$lambda_getConnection_0__1390: java.lang.Runnable bootstrap$(io.vertx.core.net.impl.pool.ConnectionManager,java.lang.Object)>(v, v);
label:
v = v.<io.vertx.core.net.impl.pool.ConnectionManager: java.util.Map endpointMap>;
v = staticinvoke <io.vertx.core.net.impl.pool.ConnectionManager$lambda_getConnection_1__1391: java.util.function.Function bootstrap$(io.vertx.core.net.impl.pool.EndpointProvider,io.vertx.core.impl.ContextInternal,java.lang.Runnable)>(v, v, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object computeIfAbsent(java.lang.Object,java.util.function.Function)>(v, v);
v = virtualinvoke v.<io.vertx.core.net.impl.pool.Endpoint: boolean getConnection(io.vertx.core.impl.ContextInternal,long,io.vertx.core.Handler)>(v, v, v);
if v == 0 goto label;
return;
}
public void close()
{
java.util.Iterator v;
java.util.Collection v;
java.util.Map v;
java.lang.Object v;
io.vertx.core.net.impl.pool.ConnectionManager v;
boolean v;
v := @this: io.vertx.core.net.impl.pool.ConnectionManager;
v = v.<io.vertx.core.net.impl.pool.ConnectionManager: java.util.Map endpointMap>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: 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()>();
virtualinvoke v.<io.vertx.core.net.impl.pool.Endpoint: void close()>();
goto label;
label:
return;
}
}