public class org.apache.http.impl.conn.PoolingHttpClientConnectionManager extends java.lang.Object implements org.apache.http.conn.HttpClientConnectionManager, org.apache.http.pool.ConnPoolControl, java.io.Closeable
{
private final org.apache.commons.logging.Log log;
private final org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData;
private final org.apache.http.impl.conn.CPool pool;
private final org.apache.http.conn.HttpClientConnectionOperator connectionOperator;
private final java.util.concurrent.atomic.AtomicBoolean isShutDown;
private static org.apache.http.config.Registry getDefaultRegistry()
{
org.apache.http.config.Registry v;
org.apache.http.config.RegistryBuilder v, v, v;
org.apache.http.conn.socket.PlainConnectionSocketFactory v;
org.apache.http.conn.ssl.SSLConnectionSocketFactory v;
v = staticinvoke <org.apache.http.config.RegistryBuilder: org.apache.http.config.RegistryBuilder create()>();
v = staticinvoke <org.apache.http.conn.socket.PlainConnectionSocketFactory: org.apache.http.conn.socket.PlainConnectionSocketFactory getSocketFactory()>();
v = virtualinvoke v.<org.apache.http.config.RegistryBuilder: org.apache.http.config.RegistryBuilder register(java.lang.String,java.lang.Object)>("http", v);
v = staticinvoke <org.apache.http.conn.ssl.SSLConnectionSocketFactory: org.apache.http.conn.ssl.SSLConnectionSocketFactory getSocketFactory()>();
v = virtualinvoke v.<org.apache.http.config.RegistryBuilder: org.apache.http.config.RegistryBuilder register(java.lang.String,java.lang.Object)>("https", v);
v = virtualinvoke v.<org.apache.http.config.RegistryBuilder: org.apache.http.config.Registry build()>();
return v;
}
public void <init>()
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.config.Registry v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v = staticinvoke <org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.config.Registry getDefaultRegistry()>();
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void <init>(org.apache.http.config.Registry)>(v);
return;
}
public void <init>(long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
org.apache.http.config.Registry v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
long v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = staticinvoke <org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.config.Registry getDefaultRegistry()>();
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void <init>(org.apache.http.config.Registry,org.apache.http.conn.HttpConnectionFactory,org.apache.http.conn.SchemePortResolver,org.apache.http.conn.DnsResolver,long,java.util.concurrent.TimeUnit)>(v, null, null, null, v, v);
return;
}
public void <init>(org.apache.http.config.Registry)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.config.Registry v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.config.Registry;
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void <init>(org.apache.http.config.Registry,org.apache.http.conn.HttpConnectionFactory,org.apache.http.conn.DnsResolver)>(v, null, null);
return;
}
public void <init>(org.apache.http.config.Registry, org.apache.http.conn.DnsResolver)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.config.Registry v;
org.apache.http.conn.DnsResolver v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.config.Registry;
v := @parameter: org.apache.http.conn.DnsResolver;
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void <init>(org.apache.http.config.Registry,org.apache.http.conn.HttpConnectionFactory,org.apache.http.conn.DnsResolver)>(v, null, v);
return;
}
public void <init>(org.apache.http.config.Registry, org.apache.http.conn.HttpConnectionFactory)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.config.Registry v;
org.apache.http.conn.HttpConnectionFactory v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.config.Registry;
v := @parameter: org.apache.http.conn.HttpConnectionFactory;
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void <init>(org.apache.http.config.Registry,org.apache.http.conn.HttpConnectionFactory,org.apache.http.conn.DnsResolver)>(v, v, null);
return;
}
public void <init>(org.apache.http.conn.HttpConnectionFactory)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.config.Registry v;
org.apache.http.conn.HttpConnectionFactory v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.conn.HttpConnectionFactory;
v = staticinvoke <org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.config.Registry getDefaultRegistry()>();
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void <init>(org.apache.http.config.Registry,org.apache.http.conn.HttpConnectionFactory,org.apache.http.conn.DnsResolver)>(v, v, null);
return;
}
public void <init>(org.apache.http.config.Registry, org.apache.http.conn.HttpConnectionFactory, org.apache.http.conn.DnsResolver)
{
java.util.concurrent.TimeUnit v;
org.apache.http.config.Registry v;
org.apache.http.conn.HttpConnectionFactory v;
org.apache.http.conn.DnsResolver v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.config.Registry;
v := @parameter: org.apache.http.conn.HttpConnectionFactory;
v := @parameter: org.apache.http.conn.DnsResolver;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void <init>(org.apache.http.config.Registry,org.apache.http.conn.HttpConnectionFactory,org.apache.http.conn.SchemePortResolver,org.apache.http.conn.DnsResolver,long,java.util.concurrent.TimeUnit)>(v, v, null, v, -1L, v);
return;
}
public void <init>(org.apache.http.config.Registry, org.apache.http.conn.HttpConnectionFactory, org.apache.http.conn.SchemePortResolver, org.apache.http.conn.DnsResolver, long, java.util.concurrent.TimeUnit)
{
org.apache.http.impl.conn.DefaultHttpClientConnectionOperator v;
org.apache.http.conn.SchemePortResolver v;
org.apache.http.conn.DnsResolver v;
long v;
java.util.concurrent.TimeUnit v;
org.apache.http.config.Registry v;
org.apache.http.conn.HttpConnectionFactory v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.config.Registry;
v := @parameter: org.apache.http.conn.HttpConnectionFactory;
v := @parameter: org.apache.http.conn.SchemePortResolver;
v := @parameter: org.apache.http.conn.DnsResolver;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = new org.apache.http.impl.conn.DefaultHttpClientConnectionOperator;
specialinvoke v.<org.apache.http.impl.conn.DefaultHttpClientConnectionOperator: void <init>(org.apache.http.config.Lookup,org.apache.http.conn.SchemePortResolver,org.apache.http.conn.DnsResolver)>(v, v, v);
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void <init>(org.apache.http.conn.HttpClientConnectionOperator,org.apache.http.conn.HttpConnectionFactory,long,java.util.concurrent.TimeUnit)>(v, v, v, v);
return;
}
public void <init>(org.apache.http.conn.HttpClientConnectionOperator, org.apache.http.conn.HttpConnectionFactory, long, java.util.concurrent.TimeUnit)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData v, v;
java.util.concurrent.atomic.AtomicBoolean v;
long v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$InternalConnectionFactory v;
org.apache.http.impl.conn.CPool v, v;
java.util.concurrent.TimeUnit v;
org.apache.http.conn.HttpConnectionFactory v;
org.apache.http.conn.HttpClientConnectionOperator v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
java.lang.Class v;
java.lang.Object v;
org.apache.commons.logging.Log v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.conn.HttpClientConnectionOperator;
v := @parameter: org.apache.http.conn.HttpConnectionFactory;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
specialinvoke v.<java.lang.Object: void <init>()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.apache.commons.logging.LogFactory: org.apache.commons.logging.Log getLog(java.lang.Class)>(v);
v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log> = v;
v = new org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData;
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData: void <init>()>();
v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData> = v;
v = new org.apache.http.impl.conn.CPool;
v = new org.apache.http.impl.conn.PoolingHttpClientConnectionManager$InternalConnectionFactory;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData>;
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$InternalConnectionFactory: void <init>(org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData,org.apache.http.conn.HttpConnectionFactory)>(v, v);
specialinvoke v.<org.apache.http.impl.conn.CPool: void <init>(org.apache.http.pool.ConnFactory,int,int,long,java.util.concurrent.TimeUnit)>(v, 2, 20, v, v);
v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool> = v;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
virtualinvoke v.<org.apache.http.impl.conn.CPool: void setValidateAfterInactivity(int)>(2000);
v = staticinvoke <org.apache.http.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "HttpClientConnectionOperator");
v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.conn.HttpClientConnectionOperator connectionOperator> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.util.concurrent.atomic.AtomicBoolean isShutDown> = v;
return;
}
void <init>(org.apache.http.impl.conn.CPool, org.apache.http.config.Lookup, org.apache.http.conn.SchemePortResolver, org.apache.http.conn.DnsResolver)
{
org.apache.http.impl.conn.DefaultHttpClientConnectionOperator v;
org.apache.http.conn.SchemePortResolver v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData v;
org.apache.http.conn.DnsResolver v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.http.impl.conn.CPool v;
org.apache.http.config.Lookup v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
java.lang.Class v;
org.apache.commons.logging.Log v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.impl.conn.CPool;
v := @parameter: org.apache.http.config.Lookup;
v := @parameter: org.apache.http.conn.SchemePortResolver;
v := @parameter: org.apache.http.conn.DnsResolver;
specialinvoke v.<java.lang.Object: void <init>()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.apache.commons.logging.LogFactory: org.apache.commons.logging.Log getLog(java.lang.Class)>(v);
v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log> = v;
v = new org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData;
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData: void <init>()>();
v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData> = v;
v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool> = v;
v = new org.apache.http.impl.conn.DefaultHttpClientConnectionOperator;
specialinvoke v.<org.apache.http.impl.conn.DefaultHttpClientConnectionOperator: void <init>(org.apache.http.config.Lookup,org.apache.http.conn.SchemePortResolver,org.apache.http.conn.DnsResolver)>(v, v, v);
v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.conn.HttpClientConnectionOperator connectionOperator> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.util.concurrent.atomic.AtomicBoolean isShutDown> = v;
return;
}
protected void finalize() throws java.lang.Throwable
{
java.lang.Throwable v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
label:
virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void shutdown()>();
label:
specialinvoke v.<java.lang.Object: void finalize()>();
goto label;
label:
v := @caughtexception;
specialinvoke v.<java.lang.Object: void finalize()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void close()
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void shutdown()>();
return;
}
private java.lang.String format(org.apache.http.conn.routing.HttpRoute, java.lang.Object)
{
org.apache.http.conn.routing.HttpRoute v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
java.lang.Object v;
java.lang.StringBuilder v, v, v, v, v;
java.lang.String v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.conn.routing.HttpRoute;
v := @parameter: java.lang.Object;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("[route: ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("]");
if v == null goto label;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("[state: ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("]");
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
private java.lang.String formatStats(org.apache.http.conn.routing.HttpRoute)
{
org.apache.http.conn.routing.HttpRoute v;
int v, v, v, v, v, v, v, v, v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
java.lang.String v;
org.apache.http.pool.PoolStats v, v;
org.apache.http.impl.conn.CPool v, v;
java.lang.StringBuilder v, v, v, v, v, v, v, v, v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.conn.routing.HttpRoute;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = virtualinvoke v.<org.apache.http.impl.conn.CPool: org.apache.http.pool.PoolStats getTotalStats()>();
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = virtualinvoke v.<org.apache.http.impl.conn.CPool: org.apache.http.pool.PoolStats getStats(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("[total available: ");
v = virtualinvoke v.<org.apache.http.pool.PoolStats: int getAvailable()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("; ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("route allocated: ");
v = virtualinvoke v.<org.apache.http.pool.PoolStats: int getLeased()>();
v = virtualinvoke v.<org.apache.http.pool.PoolStats: int getAvailable()>();
v = v + v;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" of ");
v = virtualinvoke v.<org.apache.http.pool.PoolStats: int getMax()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("; ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("total allocated: ");
v = virtualinvoke v.<org.apache.http.pool.PoolStats: int getLeased()>();
v = virtualinvoke v.<org.apache.http.pool.PoolStats: int getAvailable()>();
v = v + v;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" of ");
v = virtualinvoke v.<org.apache.http.pool.PoolStats: int getMax()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("]");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
private java.lang.String format(org.apache.http.impl.conn.CPoolEntry)
{
org.apache.http.impl.conn.CPoolEntry v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
java.lang.Object v, v;
java.lang.StringBuilder v, v, v, v, v, v, v;
java.lang.String v, v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.impl.conn.CPoolEntry;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("[id: ");
v = virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: java.lang.String getId()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("]");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("[route: ");
v = virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: java.lang.Object getRoute()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("]");
v = virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: java.lang.Object getState()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("[state: ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("]");
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
private org.apache.http.config.SocketConfig resolveSocketConfig(org.apache.http.HttpHost)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData v, v;
org.apache.http.config.SocketConfig v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.HttpHost v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.HttpHost;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData>;
v = virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData: org.apache.http.config.SocketConfig getSocketConfig(org.apache.http.HttpHost)>(v);
if v != null goto label;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData>;
v = virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData: org.apache.http.config.SocketConfig getDefaultSocketConfig()>();
if v != null goto label;
v = <org.apache.http.config.SocketConfig: org.apache.http.config.SocketConfig DEFAULT>;
label:
return v;
}
public org.apache.http.conn.ConnectionRequest requestConnection(org.apache.http.conn.routing.HttpRoute, java.lang.Object)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$1 v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.http.conn.routing.HttpRoute v;
org.apache.http.impl.conn.CPool v;
java.util.concurrent.Future v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
java.lang.Object v;
org.apache.commons.logging.Log v, v;
java.lang.String v, v, v;
boolean v, v, v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.conn.routing.HttpRoute;
v := @parameter: java.lang.Object;
staticinvoke <org.apache.http.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "HTTP route");
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
v = specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.lang.String format(org.apache.http.conn.routing.HttpRoute,java.lang.Object)>(v, v);
v = specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.lang.String formatStats(org.apache.http.conn.routing.HttpRoute)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("Connection request: \u0001\u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object)>(v);
label:
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.util.concurrent.atomic.AtomicBoolean isShutDown>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.http.util.Asserts: void check(boolean,java.lang.String)>(v, "Connection pool shut down");
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = virtualinvoke v.<org.apache.http.impl.conn.CPool: java.util.concurrent.Future lease(java.lang.Object,java.lang.Object,org.apache.http.concurrent.FutureCallback)>(v, v, null);
v = new org.apache.http.impl.conn.PoolingHttpClientConnectionManager$1;
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$1: void <init>(org.apache.http.impl.conn.PoolingHttpClientConnectionManager,java.util.concurrent.Future,org.apache.http.conn.routing.HttpRoute)>(v, v, v);
return v;
}
protected org.apache.http.HttpClientConnection leaseConnection(java.util.concurrent.Future, long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, org.apache.http.conn.ConnectionPoolTimeoutException
{
java.util.concurrent.TimeoutException v;
long v;
java.util.concurrent.Future v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
java.lang.String v, v, v;
boolean v, v, v;
org.apache.http.HttpClientConnection v;
java.util.concurrent.CancellationException v;
org.apache.http.conn.ConnectionPoolTimeoutException v;
java.util.concurrent.ExecutionException v;
java.util.concurrent.TimeUnit v;
java.lang.Object v, v, v;
org.apache.commons.logging.Log v, v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: java.util.concurrent.Future;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
label:
v = interfaceinvoke v.<java.util.concurrent.Future: java.lang.Object get(long,java.util.concurrent.TimeUnit)>(v, v);
if v == null goto label;
v = interfaceinvoke v.<java.util.concurrent.Future: boolean isCancelled()>();
if v == 0 goto label;
label:
v = new java.util.concurrent.ExecutionException;
v = new java.util.concurrent.CancellationException;
specialinvoke v.<java.util.concurrent.CancellationException: void <init>(java.lang.String)>("Operation cancelled");
specialinvoke v.<java.util.concurrent.ExecutionException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: java.lang.Object getConnection()>();
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.http.util.Asserts: void check(boolean,java.lang.String)>(v, "Pool entry with no connection");
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
v = specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.lang.String format(org.apache.http.impl.conn.CPoolEntry)>(v);
v = virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: java.lang.Object getRoute()>();
v = specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.lang.String formatStats(org.apache.http.conn.routing.HttpRoute)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("Connection leased: \u0001\u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object)>(v);
label:
v = staticinvoke <org.apache.http.impl.conn.CPoolProxy: org.apache.http.HttpClientConnection newProxy(org.apache.http.impl.conn.CPoolEntry)>(v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.http.conn.ConnectionPoolTimeoutException;
specialinvoke v.<org.apache.http.conn.ConnectionPoolTimeoutException: void <init>(java.lang.String)>("Timeout waiting for connection from pool");
throw v;
catch java.util.concurrent.TimeoutException from label to label with label;
}
public void releaseConnection(org.apache.http.HttpClientConnection, java.lang.Object, long, java.util.concurrent.TimeUnit)
{
byte v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
boolean v, v, v, v, v, v, v, v, v, v;
java.lang.Throwable v, v;
long v, v;
org.apache.http.impl.conn.CPoolEntry v;
java.lang.String v, v, v, v, v, v, v, v, v;
double v;
org.apache.http.HttpClientConnection v;
org.apache.http.impl.conn.CPool v, v;
java.util.concurrent.TimeUnit v, v;
java.lang.Object v, v, v, v;
org.apache.commons.logging.Log v, v, v, v, v, v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.HttpClientConnection;
v := @parameter: java.lang.Object;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
staticinvoke <org.apache.http.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Managed connection");
entermonitor v;
label:
v = staticinvoke <org.apache.http.impl.conn.CPoolProxy: org.apache.http.impl.conn.CPoolEntry detach(org.apache.http.HttpClientConnection)>(v);
if v != null goto label;
exitmonitor v;
label:
return;
label:
v = virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: java.lang.Object getConnection()>();
label:
v = interfaceinvoke v.<org.apache.http.conn.ManagedHttpClientConnection: boolean isOpen()>();
if v == 0 goto label;
if v == null goto label;
v = v;
goto label;
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
label:
virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: void setState(java.lang.Object)>(v);
virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: void updateExpiry(long,java.util.concurrent.TimeUnit)>(v, v);
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v cmp 0L;
if v <= 0 goto label;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toMillis(long)>(v);
v = v / 1000.0;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (double)>(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 \u seconds");
goto label;
label:
v = "indefinitely";
label:
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
v = specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.lang.String format(org.apache.http.impl.conn.CPoolEntry)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("Connection \u can be kept alive \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object)>(v);
label:
interfaceinvoke v.<org.apache.http.conn.ManagedHttpClientConnection: void setSocketTimeout(int)>(0);
label:
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = interfaceinvoke v.<org.apache.http.conn.ManagedHttpClientConnection: boolean isOpen()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: boolean isRouteComplete()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
virtualinvoke v.<org.apache.http.impl.conn.CPool: void release(org.apache.http.pool.PoolEntry,boolean)>(v, v);
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
v = specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.lang.String format(org.apache.http.impl.conn.CPoolEntry)>(v);
v = virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: java.lang.Object getRoute()>();
v = specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.lang.String formatStats(org.apache.http.conn.routing.HttpRoute)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("Connection released: \u0001\u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object)>(v);
goto label;
label:
v := @caughtexception;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = interfaceinvoke v.<org.apache.http.conn.ManagedHttpClientConnection: boolean isOpen()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: boolean isRouteComplete()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
virtualinvoke v.<org.apache.http.impl.conn.CPool: void release(org.apache.http.pool.PoolEntry,boolean)>(v, v);
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
v = specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.lang.String format(org.apache.http.impl.conn.CPoolEntry)>(v);
v = virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: java.lang.Object getRoute()>();
v = specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.lang.String formatStats(org.apache.http.conn.routing.HttpRoute)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("Connection released: \u0001\u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object)>(v);
label:
throw v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable 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;
}
public void connect(org.apache.http.HttpClientConnection, org.apache.http.conn.routing.HttpRoute, int, org.apache.http.protocol.HttpContext) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.http.HttpClientConnection v;
org.apache.http.config.SocketConfig v;
org.apache.http.conn.routing.HttpRoute v;
java.net.InetSocketAddress v;
org.apache.http.impl.conn.CPoolEntry v;
org.apache.http.protocol.HttpContext v;
int v;
org.apache.http.conn.HttpClientConnectionOperator v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
java.lang.Object v;
org.apache.http.HttpHost v, v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.HttpClientConnection;
v := @parameter: org.apache.http.conn.routing.HttpRoute;
v := @parameter: int;
v := @parameter: org.apache.http.protocol.HttpContext;
staticinvoke <org.apache.http.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Managed Connection");
staticinvoke <org.apache.http.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "HTTP route");
entermonitor v;
label:
v = staticinvoke <org.apache.http.impl.conn.CPoolProxy: org.apache.http.impl.conn.CPoolEntry getPoolEntry(org.apache.http.HttpClientConnection)>(v);
v = virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: java.lang.Object getConnection()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = virtualinvoke v.<org.apache.http.conn.routing.HttpRoute: org.apache.http.HttpHost getProxyHost()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.http.conn.routing.HttpRoute: org.apache.http.HttpHost getProxyHost()>();
goto label;
label:
v = virtualinvoke v.<org.apache.http.conn.routing.HttpRoute: org.apache.http.HttpHost getTargetHost()>();
label:
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.conn.HttpClientConnectionOperator connectionOperator>;
v = virtualinvoke v.<org.apache.http.conn.routing.HttpRoute: java.net.InetSocketAddress getLocalSocketAddress()>();
v = specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.config.SocketConfig resolveSocketConfig(org.apache.http.HttpHost)>(v);
interfaceinvoke v.<org.apache.http.conn.HttpClientConnectionOperator: void connect(org.apache.http.conn.ManagedHttpClientConnection,org.apache.http.HttpHost,java.net.InetSocketAddress,int,org.apache.http.config.SocketConfig,org.apache.http.protocol.HttpContext)>(v, v, v, v, v, v);
return;
catch java.lang.Throwable from label to label with label;
}
public void upgrade(org.apache.http.HttpClientConnection, org.apache.http.conn.routing.HttpRoute, org.apache.http.protocol.HttpContext) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.http.HttpClientConnection v;
org.apache.http.conn.routing.HttpRoute v;
org.apache.http.impl.conn.CPoolEntry v;
org.apache.http.protocol.HttpContext v;
org.apache.http.conn.HttpClientConnectionOperator v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
java.lang.Object v;
org.apache.http.HttpHost v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.HttpClientConnection;
v := @parameter: org.apache.http.conn.routing.HttpRoute;
v := @parameter: org.apache.http.protocol.HttpContext;
staticinvoke <org.apache.http.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Managed Connection");
staticinvoke <org.apache.http.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "HTTP route");
entermonitor v;
label:
v = staticinvoke <org.apache.http.impl.conn.CPoolProxy: org.apache.http.impl.conn.CPoolEntry getPoolEntry(org.apache.http.HttpClientConnection)>(v);
v = virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: java.lang.Object getConnection()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.conn.HttpClientConnectionOperator connectionOperator>;
v = virtualinvoke v.<org.apache.http.conn.routing.HttpRoute: org.apache.http.HttpHost getTargetHost()>();
interfaceinvoke v.<org.apache.http.conn.HttpClientConnectionOperator: void upgrade(org.apache.http.conn.ManagedHttpClientConnection,org.apache.http.HttpHost,org.apache.http.protocol.HttpContext)>(v, v, v);
return;
catch java.lang.Throwable from label to label with label;
}
public void routeComplete(org.apache.http.HttpClientConnection, org.apache.http.conn.routing.HttpRoute, org.apache.http.protocol.HttpContext) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.http.HttpClientConnection v;
org.apache.http.impl.conn.CPoolEntry v;
org.apache.http.protocol.HttpContext v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.conn.routing.HttpRoute v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.HttpClientConnection;
v := @parameter: org.apache.http.conn.routing.HttpRoute;
v := @parameter: org.apache.http.protocol.HttpContext;
staticinvoke <org.apache.http.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Managed Connection");
staticinvoke <org.apache.http.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "HTTP route");
entermonitor v;
label:
v = staticinvoke <org.apache.http.impl.conn.CPoolProxy: org.apache.http.impl.conn.CPoolEntry getPoolEntry(org.apache.http.HttpClientConnection)>(v);
virtualinvoke v.<org.apache.http.impl.conn.CPoolEntry: void markRouteComplete()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void shutdown()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$2 v;
java.io.IOException v;
org.apache.http.impl.conn.CPool v, v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.commons.logging.Log v, v, v;
boolean v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: java.util.concurrent.atomic.AtomicBoolean isShutDown>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object)>("Connection manager is shutting down");
label:
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = new org.apache.http.impl.conn.PoolingHttpClientConnectionManager$2;
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$2: void <init>(org.apache.http.impl.conn.PoolingHttpClientConnectionManager)>(v);
virtualinvoke v.<org.apache.http.impl.conn.CPool: void enumLeased(org.apache.http.pool.PoolEntryCallback)>(v);
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
virtualinvoke v.<org.apache.http.impl.conn.CPool: void shutdown()>();
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object,java.lang.Throwable)>("I/O exception shutting down connection manager", v);
label:
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object)>("Connection manager shut down");
label:
return;
catch java.io.IOException from label to label with label;
}
public void closeIdleConnections(long, java.util.concurrent.TimeUnit)
{
long v;
org.apache.http.impl.conn.CPool v;
java.util.concurrent.TimeUnit v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.commons.logging.Log v, v;
java.lang.String v;
boolean v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,java.util.concurrent.TimeUnit)>(v, 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[])>("Closing connections idle longer than \u \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object)>(v);
label:
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
virtualinvoke v.<org.apache.http.impl.conn.CPool: void closeIdle(long,java.util.concurrent.TimeUnit)>(v, v);
return;
}
public void closeExpiredConnections()
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.commons.logging.Log v;
org.apache.http.impl.conn.CPool v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.commons.logging.Log log>;
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object)>("Closing expired connections");
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
virtualinvoke v.<org.apache.http.impl.conn.CPool: void closeExpired()>();
return;
}
protected void enumAvailable(org.apache.http.pool.PoolEntryCallback)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.pool.PoolEntryCallback v;
org.apache.http.impl.conn.CPool v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.pool.PoolEntryCallback;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
virtualinvoke v.<org.apache.http.impl.conn.CPool: void enumAvailable(org.apache.http.pool.PoolEntryCallback)>(v);
return;
}
protected void enumLeased(org.apache.http.pool.PoolEntryCallback)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.pool.PoolEntryCallback v;
org.apache.http.impl.conn.CPool v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.pool.PoolEntryCallback;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
virtualinvoke v.<org.apache.http.impl.conn.CPool: void enumLeased(org.apache.http.pool.PoolEntryCallback)>(v);
return;
}
public int getMaxTotal()
{
int v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.impl.conn.CPool v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = virtualinvoke v.<org.apache.http.impl.conn.CPool: int getMaxTotal()>();
return v;
}
public void setMaxTotal(int)
{
int v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.impl.conn.CPool v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: int;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
virtualinvoke v.<org.apache.http.impl.conn.CPool: void setMaxTotal(int)>(v);
return;
}
public int getDefaultMaxPerRoute()
{
int v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.impl.conn.CPool v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = virtualinvoke v.<org.apache.http.impl.conn.CPool: int getDefaultMaxPerRoute()>();
return v;
}
public void setDefaultMaxPerRoute(int)
{
int v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.impl.conn.CPool v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: int;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
virtualinvoke v.<org.apache.http.impl.conn.CPool: void setDefaultMaxPerRoute(int)>(v);
return;
}
public int getMaxPerRoute(org.apache.http.conn.routing.HttpRoute)
{
int v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.conn.routing.HttpRoute v;
org.apache.http.impl.conn.CPool v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.conn.routing.HttpRoute;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = virtualinvoke v.<org.apache.http.impl.conn.CPool: int getMaxPerRoute(java.lang.Object)>(v);
return v;
}
public void setMaxPerRoute(org.apache.http.conn.routing.HttpRoute, int)
{
int v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.conn.routing.HttpRoute v;
org.apache.http.impl.conn.CPool v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.conn.routing.HttpRoute;
v := @parameter: int;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
virtualinvoke v.<org.apache.http.impl.conn.CPool: void setMaxPerRoute(java.lang.Object,int)>(v, v);
return;
}
public org.apache.http.pool.PoolStats getTotalStats()
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.impl.conn.CPool v;
org.apache.http.pool.PoolStats v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = virtualinvoke v.<org.apache.http.impl.conn.CPool: org.apache.http.pool.PoolStats getTotalStats()>();
return v;
}
public org.apache.http.pool.PoolStats getStats(org.apache.http.conn.routing.HttpRoute)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.conn.routing.HttpRoute v;
org.apache.http.impl.conn.CPool v;
org.apache.http.pool.PoolStats v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.conn.routing.HttpRoute;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = virtualinvoke v.<org.apache.http.impl.conn.CPool: org.apache.http.pool.PoolStats getStats(java.lang.Object)>(v);
return v;
}
public java.util.Set getRoutes()
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
java.util.Set v;
org.apache.http.impl.conn.CPool v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = virtualinvoke v.<org.apache.http.impl.conn.CPool: java.util.Set getRoutes()>();
return v;
}
public org.apache.http.config.SocketConfig getDefaultSocketConfig()
{
org.apache.http.config.SocketConfig v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData>;
v = virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData: org.apache.http.config.SocketConfig getDefaultSocketConfig()>();
return v;
}
public void setDefaultSocketConfig(org.apache.http.config.SocketConfig)
{
org.apache.http.config.SocketConfig v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.config.SocketConfig;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData>;
virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData: void setDefaultSocketConfig(org.apache.http.config.SocketConfig)>(v);
return;
}
public org.apache.http.config.ConnectionConfig getDefaultConnectionConfig()
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData v;
org.apache.http.config.ConnectionConfig v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData>;
v = virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData: org.apache.http.config.ConnectionConfig getDefaultConnectionConfig()>();
return v;
}
public void setDefaultConnectionConfig(org.apache.http.config.ConnectionConfig)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData v;
org.apache.http.config.ConnectionConfig v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.config.ConnectionConfig;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData>;
virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData: void setDefaultConnectionConfig(org.apache.http.config.ConnectionConfig)>(v);
return;
}
public org.apache.http.config.SocketConfig getSocketConfig(org.apache.http.HttpHost)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData v;
org.apache.http.config.SocketConfig v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.HttpHost v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.HttpHost;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData>;
v = virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData: org.apache.http.config.SocketConfig getSocketConfig(org.apache.http.HttpHost)>(v);
return v;
}
public void setSocketConfig(org.apache.http.HttpHost, org.apache.http.config.SocketConfig)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData v;
org.apache.http.config.SocketConfig v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.HttpHost v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.HttpHost;
v := @parameter: org.apache.http.config.SocketConfig;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData>;
virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData: void setSocketConfig(org.apache.http.HttpHost,org.apache.http.config.SocketConfig)>(v, v);
return;
}
public org.apache.http.config.ConnectionConfig getConnectionConfig(org.apache.http.HttpHost)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.HttpHost v;
org.apache.http.config.ConnectionConfig v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.HttpHost;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData>;
v = virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData: org.apache.http.config.ConnectionConfig getConnectionConfig(org.apache.http.HttpHost)>(v);
return v;
}
public void setConnectionConfig(org.apache.http.HttpHost, org.apache.http.config.ConnectionConfig)
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.HttpHost v;
org.apache.http.config.ConnectionConfig v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: org.apache.http.HttpHost;
v := @parameter: org.apache.http.config.ConnectionConfig;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData configData>;
virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager$ConfigData: void setConnectionConfig(org.apache.http.HttpHost,org.apache.http.config.ConnectionConfig)>(v, v);
return;
}
public int getValidateAfterInactivity()
{
int v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.impl.conn.CPool v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
v = virtualinvoke v.<org.apache.http.impl.conn.CPool: int getValidateAfterInactivity()>();
return v;
}
public void setValidateAfterInactivity(int)
{
int v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.impl.conn.CPool v;
v := @this: org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v := @parameter: int;
v = v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: org.apache.http.impl.conn.CPool pool>;
virtualinvoke v.<org.apache.http.impl.conn.CPool: void setValidateAfterInactivity(int)>(v);
return;
}
}