public class org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager extends java.lang.Object implements org.apache.hc.client.http.io.HttpClientConnectionManager, org.apache.hc.core.pool.ConnPoolControl
{
private static final org.slf4j.Logger LOG;
public static final int DEFAULT_MAX_TOTAL_CONNECTIONS;
public static final int DEFAULT_MAX_CONNECTIONS_PER_ROUTE;
private final org.apache.hc.client.http.io.HttpClientConnectionOperator connectionOperator;
private final org.apache.hc.core.pool.ManagedConnPool pool;
private final org.apache.hc.core.http.io.HttpConnectionFactory connFactory;
private final java.util.concurrent.atomic.AtomicBoolean closed;
private volatile org.apache.hc.core.http.io.SocketConfig defaultSocketConfig;
private volatile org.apache.hc.core.util.TimeValue validateAfterInactivity;
private static final java.util.concurrent.atomic.AtomicLong COUNT;
public void <init>()
{
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.http.URIScheme v, v;
org.apache.hc.core.http.config.Registry v;
org.apache.hc.core.http.config.RegistryBuilder v, v, v;
org.apache.hc.client.http.ssl.SSLConnectionSocketFactory v;
org.apache.hc.client.http.socket.PlainConnectionSocketFactory v;
java.lang.String v, v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v = staticinvoke <org.apache.hc.core.http.config.RegistryBuilder: org.apache.hc.core.http.config.RegistryBuilder create()>();
v = <org.apache.hc.core.http.URIScheme: org.apache.hc.core.http.URIScheme HTTP>;
v = v.<org.apache.hc.core.http.URIScheme: java.lang.String id>;
v = staticinvoke <org.apache.hc.client.http.socket.PlainConnectionSocketFactory: org.apache.hc.client.http.socket.PlainConnectionSocketFactory getSocketFactory()>();
v = virtualinvoke v.<org.apache.hc.core.http.config.RegistryBuilder: org.apache.hc.core.http.config.RegistryBuilder register(java.lang.String,java.lang.Object)>(v, v);
v = <org.apache.hc.core.http.URIScheme: org.apache.hc.core.http.URIScheme HTTPS>;
v = v.<org.apache.hc.core.http.URIScheme: java.lang.String id>;
v = staticinvoke <org.apache.hc.client.http.ssl.SSLConnectionSocketFactory: org.apache.hc.client.http.ssl.SSLConnectionSocketFactory getSocketFactory()>();
v = virtualinvoke v.<org.apache.hc.core.http.config.RegistryBuilder: org.apache.hc.core.http.config.RegistryBuilder register(java.lang.String,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.hc.core.http.config.RegistryBuilder: org.apache.hc.core.http.config.Registry build()>();
specialinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: void <init>(org.apache.hc.core.http.config.Registry)>(v);
return;
}
public void <init>(org.apache.hc.core.http.config.Registry)
{
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.http.config.Registry v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.core.http.config.Registry;
specialinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: void <init>(org.apache.hc.core.http.config.Registry,org.apache.hc.core.http.io.HttpConnectionFactory)>(v, null);
return;
}
public void <init>(org.apache.hc.core.http.config.Registry, org.apache.hc.core.http.io.HttpConnectionFactory)
{
org.apache.hc.core.http.io.HttpConnectionFactory v;
org.apache.hc.core.util.TimeValue v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.PoolConcurrencyPolicy v;
org.apache.hc.core.http.config.Registry v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.core.http.config.Registry;
v := @parameter: org.apache.hc.core.http.io.HttpConnectionFactory;
v = <org.apache.hc.core.pool.PoolConcurrencyPolicy: org.apache.hc.core.pool.PoolConcurrencyPolicy STRICT>;
v = <org.apache.hc.core.util.TimeValue: org.apache.hc.core.util.TimeValue NEG_ONE_MILLISECOND>;
specialinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: void <init>(org.apache.hc.core.http.config.Registry,org.apache.hc.core.pool.PoolConcurrencyPolicy,org.apache.hc.core.util.TimeValue,org.apache.hc.core.http.io.HttpConnectionFactory)>(v, v, v, v);
return;
}
public void <init>(org.apache.hc.core.http.config.Registry, org.apache.hc.core.pool.PoolConcurrencyPolicy, org.apache.hc.core.util.TimeValue, org.apache.hc.core.http.io.HttpConnectionFactory)
{
org.apache.hc.core.http.io.HttpConnectionFactory v;
org.apache.hc.core.util.TimeValue v;
org.apache.hc.core.pool.PoolReusePolicy v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.PoolConcurrencyPolicy v;
org.apache.hc.core.http.config.Registry v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.core.http.config.Registry;
v := @parameter: org.apache.hc.core.pool.PoolConcurrencyPolicy;
v := @parameter: org.apache.hc.core.util.TimeValue;
v := @parameter: org.apache.hc.core.http.io.HttpConnectionFactory;
v = <org.apache.hc.core.pool.PoolReusePolicy: org.apache.hc.core.pool.PoolReusePolicy LIFO>;
specialinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: void <init>(org.apache.hc.core.http.config.Registry,org.apache.hc.core.pool.PoolConcurrencyPolicy,org.apache.hc.core.pool.PoolReusePolicy,org.apache.hc.core.util.TimeValue,org.apache.hc.core.http.io.HttpConnectionFactory)>(v, v, v, v, v);
return;
}
public void <init>(org.apache.hc.core.http.config.Registry, org.apache.hc.core.pool.PoolConcurrencyPolicy, org.apache.hc.core.pool.PoolReusePolicy, org.apache.hc.core.util.TimeValue)
{
org.apache.hc.core.util.TimeValue v;
org.apache.hc.core.pool.PoolReusePolicy v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.PoolConcurrencyPolicy v;
org.apache.hc.core.http.config.Registry v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.core.http.config.Registry;
v := @parameter: org.apache.hc.core.pool.PoolConcurrencyPolicy;
v := @parameter: org.apache.hc.core.pool.PoolReusePolicy;
v := @parameter: org.apache.hc.core.util.TimeValue;
specialinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: void <init>(org.apache.hc.core.http.config.Registry,org.apache.hc.core.pool.PoolConcurrencyPolicy,org.apache.hc.core.pool.PoolReusePolicy,org.apache.hc.core.util.TimeValue,org.apache.hc.core.http.io.HttpConnectionFactory)>(v, v, v, v, null);
return;
}
public void <init>(org.apache.hc.core.http.config.Registry, org.apache.hc.core.pool.PoolConcurrencyPolicy, org.apache.hc.core.pool.PoolReusePolicy, org.apache.hc.core.util.TimeValue, org.apache.hc.core.http.io.HttpConnectionFactory)
{
org.apache.hc.core.http.io.HttpConnectionFactory v;
org.apache.hc.core.util.TimeValue v;
org.apache.hc.core.pool.PoolReusePolicy v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.PoolConcurrencyPolicy v;
org.apache.hc.core.http.config.Registry v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.core.http.config.Registry;
v := @parameter: org.apache.hc.core.pool.PoolConcurrencyPolicy;
v := @parameter: org.apache.hc.core.pool.PoolReusePolicy;
v := @parameter: org.apache.hc.core.util.TimeValue;
v := @parameter: org.apache.hc.core.http.io.HttpConnectionFactory;
specialinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: void <init>(org.apache.hc.core.http.config.Registry,org.apache.hc.core.pool.PoolConcurrencyPolicy,org.apache.hc.core.pool.PoolReusePolicy,org.apache.hc.core.util.TimeValue,org.apache.hc.client.http.SchemePortResolver,org.apache.hc.client.http.DnsResolver,org.apache.hc.core.http.io.HttpConnectionFactory)>(v, v, v, v, null, null, v);
return;
}
public void <init>(org.apache.hc.core.http.config.Registry, org.apache.hc.core.pool.PoolConcurrencyPolicy, org.apache.hc.core.pool.PoolReusePolicy, org.apache.hc.core.util.TimeValue, org.apache.hc.client.http.SchemePortResolver, org.apache.hc.client.http.DnsResolver, org.apache.hc.core.http.io.HttpConnectionFactory)
{
org.apache.hc.core.http.io.HttpConnectionFactory v;
org.apache.hc.core.util.TimeValue v;
org.apache.hc.core.pool.PoolReusePolicy v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.PoolConcurrencyPolicy v;
org.apache.hc.core.http.config.Registry v;
org.apache.hc.client.http.SchemePortResolver v;
org.apache.hc.client.http.impl.io.DefaultHttpClientConnectionOperator v;
org.apache.hc.client.http.DnsResolver v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.core.http.config.Registry;
v := @parameter: org.apache.hc.core.pool.PoolConcurrencyPolicy;
v := @parameter: org.apache.hc.core.pool.PoolReusePolicy;
v := @parameter: org.apache.hc.core.util.TimeValue;
v := @parameter: org.apache.hc.client.http.SchemePortResolver;
v := @parameter: org.apache.hc.client.http.DnsResolver;
v := @parameter: org.apache.hc.core.http.io.HttpConnectionFactory;
v = new org.apache.hc.client.http.impl.io.DefaultHttpClientConnectionOperator;
specialinvoke v.<org.apache.hc.client.http.impl.io.DefaultHttpClientConnectionOperator: void <init>(org.apache.hc.core.http.config.Lookup,org.apache.hc.client.http.SchemePortResolver,org.apache.hc.client.http.DnsResolver)>(v, v, v);
specialinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: void <init>(org.apache.hc.client.http.io.HttpClientConnectionOperator,org.apache.hc.core.pool.PoolConcurrencyPolicy,org.apache.hc.core.pool.PoolReusePolicy,org.apache.hc.core.util.TimeValue,org.apache.hc.core.http.io.HttpConnectionFactory)>(v, v, v, v, v);
return;
}
protected void <init>(org.apache.hc.client.http.io.HttpClientConnectionOperator, org.apache.hc.core.pool.PoolConcurrencyPolicy, org.apache.hc.core.pool.PoolReusePolicy, org.apache.hc.core.util.TimeValue, org.apache.hc.core.http.io.HttpConnectionFactory)
{
org.apache.hc.core.http.io.HttpConnectionFactory v, v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hc.client.http.io.HttpClientConnectionOperator v;
int[] v;
int v, v;
java.lang.String v;
org.apache.hc.core.util.TimeValue v, v;
org.apache.hc.core.pool.PoolReusePolicy v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
java.lang.IllegalArgumentException v;
org.apache.hc.core.pool.StrictConnPool v;
org.apache.hc.core.pool.PoolConcurrencyPolicy v, v;
org.apache.hc.core.pool.LaxConnPool v;
java.lang.Object v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.client.http.io.HttpClientConnectionOperator;
v := @parameter: org.apache.hc.core.pool.PoolConcurrencyPolicy;
v := @parameter: org.apache.hc.core.pool.PoolReusePolicy;
v := @parameter: org.apache.hc.core.util.TimeValue;
v := @parameter: org.apache.hc.core.http.io.HttpConnectionFactory;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Connection operator");
v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.client.http.io.HttpClientConnectionOperator connectionOperator> = v;
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$2: int[] $SwitchMap$org$apache$hc$core5$pool$PoolConcurrencyPolicy>;
if v == null goto label;
v = v;
goto label;
label:
v = <org.apache.hc.core.pool.PoolConcurrencyPolicy: org.apache.hc.core.pool.PoolConcurrencyPolicy STRICT>;
label:
v = virtualinvoke v.<org.apache.hc.core.pool.PoolConcurrencyPolicy: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = new org.apache.hc.core.pool.StrictConnPool;
specialinvoke v.<org.apache.hc.core.pool.StrictConnPool: void <init>(int,int,org.apache.hc.core.util.TimeValue,org.apache.hc.core.pool.PoolReusePolicy,org.apache.hc.core.pool.ConnPoolListener)>(5, 25, v, v, null);
v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool> = v;
goto label;
label:
v = new org.apache.hc.core.pool.LaxConnPool;
specialinvoke v.<org.apache.hc.core.pool.LaxConnPool: void <init>(int,org.apache.hc.core.util.TimeValue,org.apache.hc.core.pool.PoolReusePolicy,org.apache.hc.core.pool.ConnPoolListener)>(5, v, v, null);
v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool> = v;
goto label;
label:
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hc.core.pool.PoolConcurrencyPolicy)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unexpected PoolConcurrencyPolicy value: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
if v == null goto label;
v = v;
goto label;
label:
v = <org.apache.hc.client.http.impl.io.ManagedHttpClientConnectionFactory: org.apache.hc.client.http.impl.io.ManagedHttpClientConnectionFactory INSTANCE>;
label:
v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.http.io.HttpConnectionFactory connFactory> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: java.util.concurrent.atomic.AtomicBoolean closed> = v;
v = staticinvoke <org.apache.hc.core.util.TimeValue: org.apache.hc.core.util.TimeValue ofSeconds(long)>(2L);
v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.util.TimeValue validateAfterInactivity> = v;
return;
}
protected void <init>(org.apache.hc.client.http.io.HttpClientConnectionOperator, org.apache.hc.core.pool.ManagedConnPool, org.apache.hc.core.http.io.HttpConnectionFactory)
{
org.apache.hc.core.http.io.HttpConnectionFactory v, v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.client.http.io.HttpClientConnectionOperator v;
org.apache.hc.core.pool.ManagedConnPool v;
java.lang.Object v, v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.client.http.io.HttpClientConnectionOperator;
v := @parameter: org.apache.hc.core.pool.ManagedConnPool;
v := @parameter: org.apache.hc.core.http.io.HttpConnectionFactory;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Connection operator");
v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.client.http.io.HttpClientConnectionOperator connectionOperator> = v;
v = staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Connection pool");
v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool> = v;
if v == null goto label;
v = v;
goto label;
label:
v = <org.apache.hc.client.http.impl.io.ManagedHttpClientConnectionFactory: org.apache.hc.client.http.impl.io.ManagedHttpClientConnectionFactory INSTANCE>;
label:
v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.http.io.HttpConnectionFactory connFactory> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: java.util.concurrent.atomic.AtomicBoolean closed> = v;
return;
}
public void close()
{
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.io.CloseMode v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v = <org.apache.hc.core.io.CloseMode: org.apache.hc.core.io.CloseMode GRACEFUL>;
virtualinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: void close(org.apache.hc.core.io.CloseMode)>(v);
return;
}
public void close(org.apache.hc.core.io.CloseMode)
{
org.slf4j.Logger v, v, v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.ManagedConnPool v;
org.apache.hc.core.io.CloseMode v;
boolean v, v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.core.io.CloseMode;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: java.util.concurrent.atomic.AtomicBoolean closed>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Shutdown connection pool {}", v);
label:
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void close(org.apache.hc.core.io.CloseMode)>(v);
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Connection pool shut down");
label:
return;
}
private org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$InternalConnectionEndpoint cast(org.apache.hc.client.http.io.ConnectionEndpoint)
{
java.lang.IllegalStateException v;
org.apache.hc.client.http.io.ConnectionEndpoint v;
java.lang.Class v;
java.lang.String v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
boolean v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.client.http.io.ConnectionEndpoint;
v = v instanceof org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$InternalConnectionEndpoint;
if v == 0 goto label;
return v;
label:
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Class)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unexpected endpoint class: \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
}
public org.apache.hc.client.http.io.LeaseRequest lease(java.lang.String, org.apache.hc.client.http.HttpRoute, java.lang.Object)
{
org.apache.hc.client.http.HttpRoute v;
org.apache.hc.client.http.io.LeaseRequest v;
java.lang.Object v;
java.lang.String v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.util.Timeout v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hc.client.http.HttpRoute;
v := @parameter: java.lang.Object;
v = <org.apache.hc.core.util.Timeout: org.apache.hc.core.util.Timeout DISABLED>;
v = virtualinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.client.http.io.LeaseRequest lease(java.lang.String,org.apache.hc.client.http.HttpRoute,org.apache.hc.core.util.Timeout,java.lang.Object)>(v, v, v, v);
return v;
}
public org.apache.hc.client.http.io.LeaseRequest lease(java.lang.String, org.apache.hc.client.http.HttpRoute, org.apache.hc.core.util.Timeout, java.lang.Object)
{
java.lang.Object[] v;
org.slf4j.Logger v, v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.util.Timeout v;
org.apache.hc.core.pool.ManagedConnPool v, v;
org.apache.hc.client.http.HttpRoute v;
java.util.concurrent.Future v;
java.lang.Object v;
java.lang.String v, v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$1 v;
boolean v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hc.client.http.HttpRoute;
v := @parameter: org.apache.hc.core.util.Timeout;
v := @parameter: java.lang.Object;
staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "HTTP route");
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String formatStats(org.apache.hc.client.http.HttpRoute,java.lang.Object,org.apache.hc.core.pool.ConnPoolControl)>(v, v, v);
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("{} endpoint lease request ({}) {}", v);
label:
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
v = interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: java.util.concurrent.Future lease(java.lang.Object,java.lang.Object,org.apache.hc.core.util.Timeout,org.apache.hc.core.concurrent.FutureCallback)>(v, v, v, null);
v = new org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$1;
specialinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$1: void <init>(org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager,java.util.concurrent.Future,java.lang.String,org.apache.hc.client.http.HttpRoute,java.lang.Object)>(v, v, v, v, v);
return v;
}
public void release(org.apache.hc.client.http.io.ConnectionEndpoint, java.lang.Object, org.apache.hc.core.util.TimeValue)
{
org.apache.hc.core.pool.ManagedConnPool v, v, v, v;
org.apache.hc.client.http.io.ConnectionEndpoint v;
org.apache.hc.core.io.ModalCloseable v;
boolean v, v, v, v, v, v, v, v, v, v;
org.apache.hc.core.util.TimeValue v;
java.lang.Throwable v;
java.lang.Object[] v;
org.apache.hc.core.pool.PoolEntry v;
org.apache.hc.core.io.CloseMode v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$InternalConnectionEndpoint v;
org.slf4j.Logger v, v, v, v, v, v, v, v, v, v;
java.lang.RuntimeException v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.client.http.io.ConnectionEndpoint;
v := @parameter: java.lang.Object;
v := @parameter: org.apache.hc.core.util.TimeValue;
staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Managed endpoint");
v = specialinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$InternalConnectionEndpoint cast(org.apache.hc.client.http.io.ConnectionEndpoint)>(v);
v = virtualinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$InternalConnectionEndpoint: org.apache.hc.core.pool.PoolEntry detach()>();
if v != null goto label;
return;
label:
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} releasing endpoint", v);
label:
v = virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: org.apache.hc.core.io.ModalCloseable getConnection()>();
if v == null goto label;
if v != null goto label;
v = <org.apache.hc.core.io.CloseMode: org.apache.hc.core.io.CloseMode GRACEFUL>;
interfaceinvoke v.<org.apache.hc.client.http.io.ManagedHttpClientConnection: void close(org.apache.hc.core.io.CloseMode)>(v);
label:
if v == null goto label;
v = interfaceinvoke v.<org.apache.hc.client.http.io.ManagedHttpClientConnection: boolean isOpen()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.hc.client.http.io.ManagedHttpClientConnection: boolean isConsistent()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
label:
if v == 0 goto label;
virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: void updateState(java.lang.Object)>(v);
virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: void updateExpiry(org.apache.hc.core.util.TimeValue)>(v);
interfaceinvoke v.<org.apache.hc.client.http.io.ManagedHttpClientConnection: void passivate()>();
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = staticinvoke <org.apache.hc.core.util.TimeValue: boolean isPositive(org.apache.hc.core.util.TimeValue)>(v);
if v == 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hc.core.util.TimeValue)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("for \u0001");
goto label;
label:
v = "indefinitely";
label:
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
v[0] = v;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("{} connection {} can be kept alive {}", v);
goto label;
label:
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} connection is not kept alive", v);
label:
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void release(org.apache.hc.core.pool.PoolEntry,boolean)>(v, v);
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: java.lang.Object getRoute()>();
v = virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: java.lang.Object getState()>();
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String formatStats(org.apache.hc.client.http.HttpRoute,java.lang.Object,org.apache.hc.core.pool.ConnPoolControl)>(v, v, v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} connection released {}", v, v);
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void release(org.apache.hc.core.pool.PoolEntry,boolean)>(v, v);
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: java.lang.Object getRoute()>();
v = virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: java.lang.Object getState()>();
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String formatStats(org.apache.hc.client.http.HttpRoute,java.lang.Object,org.apache.hc.core.pool.ConnPoolControl)>(v, v, v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} connection released {}", v, v);
label:
throw v;
label:
return;
catch java.lang.RuntimeException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void connect(org.apache.hc.client.http.io.ConnectionEndpoint, org.apache.hc.core.util.TimeValue, org.apache.hc.core.http.protocol.HttpContext) throws java.io.IOException
{
org.apache.hc.core.http.io.HttpConnectionFactory v;
java.lang.Object[] v;
org.apache.hc.core.http.protocol.HttpContext v;
org.apache.hc.core.pool.PoolEntry v;
org.apache.hc.client.http.io.HttpClientConnectionOperator v;
org.apache.hc.client.http.io.ConnectionEndpoint v;
org.apache.hc.core.io.ModalCloseable v;
java.lang.String v, v, v;
boolean v, v, v, v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$InternalConnectionEndpoint v;
org.apache.hc.core.util.TimeValue v;
org.slf4j.Logger v, v, v, v;
org.apache.hc.core.http.io.SocketConfig v, v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
java.net.InetSocketAddress v;
org.apache.hc.core.http.HttpHost v, v, v;
org.apache.hc.core.http.HttpConnection v;
java.lang.Object v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.client.http.io.ConnectionEndpoint;
v := @parameter: org.apache.hc.core.util.TimeValue;
v := @parameter: org.apache.hc.core.http.protocol.HttpContext;
staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Managed endpoint");
v = specialinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$InternalConnectionEndpoint cast(org.apache.hc.client.http.io.ConnectionEndpoint)>(v);
v = virtualinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$InternalConnectionEndpoint: boolean isConnected()>();
if v == 0 goto label;
return;
label:
v = virtualinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$InternalConnectionEndpoint: org.apache.hc.core.pool.PoolEntry getPoolEntry()>();
v = virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: boolean hasConnection()>();
if v != 0 goto label;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.http.io.HttpConnectionFactory connFactory>;
v = interfaceinvoke v.<org.apache.hc.core.http.io.HttpConnectionFactory: org.apache.hc.core.http.HttpConnection createConnection(java.net.Socket)>(null);
virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: void assignConnection(org.apache.hc.core.io.ModalCloseable)>(v);
label:
v = virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: java.lang.Object getRoute()>();
v = virtualinvoke v.<org.apache.hc.client.http.HttpRoute: org.apache.hc.core.http.HttpHost getProxyHost()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.hc.client.http.HttpRoute: org.apache.hc.core.http.HttpHost getProxyHost()>();
goto label;
label:
v = virtualinvoke v.<org.apache.hc.client.http.HttpRoute: org.apache.hc.core.http.HttpHost getTargetHost()>();
label:
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("{} connecting endpoint to {} ({})", v);
label:
v = virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: org.apache.hc.core.io.ModalCloseable getConnection()>();
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.http.io.SocketConfig defaultSocketConfig>;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.client.http.io.HttpClientConnectionOperator connectionOperator>;
v = v;
v = virtualinvoke v.<org.apache.hc.client.http.HttpRoute: java.net.InetSocketAddress getLocalSocketAddress()>();
if v == null goto label;
v = v;
goto label;
label:
v = <org.apache.hc.core.http.io.SocketConfig: org.apache.hc.core.http.io.SocketConfig DEFAULT>;
label:
interfaceinvoke v.<org.apache.hc.client.http.io.HttpClientConnectionOperator: void connect(org.apache.hc.client.http.io.ManagedHttpClientConnection,org.apache.hc.core.http.HttpHost,java.net.InetSocketAddress,org.apache.hc.core.util.TimeValue,org.apache.hc.core.http.io.SocketConfig,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v, v, v, v);
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} connected {}", v, v);
label:
return;
}
public void upgrade(org.apache.hc.client.http.io.ConnectionEndpoint, org.apache.hc.core.http.protocol.HttpContext) throws java.io.IOException
{
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$InternalConnectionEndpoint v;
org.apache.hc.core.http.protocol.HttpContext v;
org.apache.hc.core.pool.PoolEntry v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.client.http.io.HttpClientConnectionOperator v;
org.apache.hc.core.http.HttpHost v;
org.apache.hc.client.http.io.ConnectionEndpoint v;
org.apache.hc.core.io.ModalCloseable v;
java.lang.Object v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.client.http.io.ConnectionEndpoint;
v := @parameter: org.apache.hc.core.http.protocol.HttpContext;
staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Managed endpoint");
v = specialinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$InternalConnectionEndpoint cast(org.apache.hc.client.http.io.ConnectionEndpoint)>(v);
v = virtualinvoke v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager$InternalConnectionEndpoint: org.apache.hc.core.pool.PoolEntry getValidatedPoolEntry()>();
v = virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: java.lang.Object getRoute()>();
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.client.http.io.HttpClientConnectionOperator connectionOperator>;
v = virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: org.apache.hc.core.io.ModalCloseable getConnection()>();
v = virtualinvoke v.<org.apache.hc.client.http.HttpRoute: org.apache.hc.core.http.HttpHost getTargetHost()>();
interfaceinvoke v.<org.apache.hc.client.http.io.HttpClientConnectionOperator: void upgrade(org.apache.hc.client.http.io.ManagedHttpClientConnection,org.apache.hc.core.http.HttpHost,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v);
return;
}
public void closeIdle(org.apache.hc.core.util.TimeValue)
{
org.apache.hc.core.util.TimeValue v;
org.slf4j.Logger v, v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.ManagedConnPool v;
boolean v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.core.util.TimeValue;
staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Idle time");
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Closing connections idle longer than {}", v);
label:
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void closeIdle(org.apache.hc.core.util.TimeValue)>(v);
return;
}
public void closeExpired()
{
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.slf4j.Logger v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v = <org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Closing expired connections");
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void closeExpired()>();
return;
}
public java.util.Set getRoutes()
{
java.util.Set v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
v = interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: java.util.Set getRoutes()>();
return v;
}
public int getMaxTotal()
{
int v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
v = interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: int getMaxTotal()>();
return v;
}
public void setMaxTotal(int)
{
int v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: int;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void setMaxTotal(int)>(v);
return;
}
public int getDefaultMaxPerRoute()
{
int v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
v = interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: int getDefaultMaxPerRoute()>();
return v;
}
public void setDefaultMaxPerRoute(int)
{
int v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: int;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void setDefaultMaxPerRoute(int)>(v);
return;
}
public int getMaxPerRoute(org.apache.hc.client.http.HttpRoute)
{
org.apache.hc.client.http.HttpRoute v;
int v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.client.http.HttpRoute;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
v = interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: int getMaxPerRoute(java.lang.Object)>(v);
return v;
}
public void setMaxPerRoute(org.apache.hc.client.http.HttpRoute, int)
{
org.apache.hc.client.http.HttpRoute v;
int v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.client.http.HttpRoute;
v := @parameter: int;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void setMaxPerRoute(java.lang.Object,int)>(v, v);
return;
}
public org.apache.hc.core.pool.PoolStats getTotalStats()
{
org.apache.hc.core.pool.PoolStats v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
v = interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: org.apache.hc.core.pool.PoolStats getTotalStats()>();
return v;
}
public org.apache.hc.core.pool.PoolStats getStats(org.apache.hc.client.http.HttpRoute)
{
org.apache.hc.client.http.HttpRoute v;
org.apache.hc.core.pool.PoolStats v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.client.http.HttpRoute;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.pool.ManagedConnPool pool>;
v = interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: org.apache.hc.core.pool.PoolStats getStats(java.lang.Object)>(v);
return v;
}
public org.apache.hc.core.http.io.SocketConfig getDefaultSocketConfig()
{
org.apache.hc.core.http.io.SocketConfig v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.http.io.SocketConfig defaultSocketConfig>;
return v;
}
public void setDefaultSocketConfig(org.apache.hc.core.http.io.SocketConfig)
{
org.apache.hc.core.http.io.SocketConfig v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.core.http.io.SocketConfig;
v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.http.io.SocketConfig defaultSocketConfig> = v;
return;
}
public org.apache.hc.core.util.TimeValue getValidateAfterInactivity()
{
org.apache.hc.core.util.TimeValue v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v = v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.util.TimeValue validateAfterInactivity>;
return v;
}
public void setValidateAfterInactivity(org.apache.hc.core.util.TimeValue)
{
org.apache.hc.core.util.TimeValue v;
org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager v;
v := @this: org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.hc.core.util.TimeValue;
v.<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.apache.hc.core.util.TimeValue validateAfterInactivity> = v;
return;
}
static void <clinit>()
{
java.util.concurrent.atomic.AtomicLong v;
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hc/client5/http/impl/io/PoolingHttpClientConnectionManager;");
<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: org.slf4j.Logger LOG> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
<org.apache.hc.client.http.impl.io.PoolingHttpClientConnectionManager: java.util.concurrent.atomic.AtomicLong COUNT> = v;
return;
}
}