public class org.apache.hc.core.http.impl.bootstrap.HttpRequester extends java.lang.Object implements org.apache.hc.core.pool.ConnPoolControl, org.apache.hc.core.io.ModalCloseable
{
private final org.apache.hc.core.http.impl.io.HttpRequestExecutor requestExecutor;
private final org.apache.hc.core.http.protocol.HttpProcessor httpProcessor;
private final org.apache.hc.core.pool.ManagedConnPool connPool;
private final org.apache.hc.core.http.io.SocketConfig socketConfig;
private final org.apache.hc.core.http.io.HttpConnectionFactory connectFactory;
private final javax.net.ssl.SSLSocketFactory sslSocketFactory;
private final org.apache.hc.core.function.Callback sslSetupHandler;
private final org.apache.hc.core.http.io.ssl.SSLSessionVerifier sslSessionVerifier;
private final org.apache.hc.core.function.Resolver addressResolver;
public void <init>(org.apache.hc.core.http.impl.io.HttpRequestExecutor, org.apache.hc.core.http.protocol.HttpProcessor, org.apache.hc.core.pool.ManagedConnPool, org.apache.hc.core.http.io.SocketConfig, org.apache.hc.core.http.io.HttpConnectionFactory, javax.net.ssl.SSLSocketFactory, org.apache.hc.core.function.Callback, org.apache.hc.core.http.io.ssl.SSLSessionVerifier, org.apache.hc.core.function.Resolver)
{
org.apache.hc.core.http.io.HttpConnectionFactory v, v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.http.config.CharCodingConfig v;
org.apache.hc.core.function.Resolver v, v;
org.apache.hc.core.pool.ManagedConnPool v;
org.apache.hc.core.http.protocol.HttpProcessor v;
org.apache.hc.core.http.io.ssl.SSLSessionVerifier v;
org.apache.hc.core.http.config.Http1Config v;
org.apache.hc.core.http.impl.io.HttpRequestExecutor v;
org.apache.hc.core.http.impl.io.DefaultBHttpClientConnectionFactory v;
org.apache.hc.core.function.Callback v;
org.apache.hc.core.http.io.SocketConfig v, v;
javax.net.ssl.SSLSocketFactory v;
javax.net.SocketFactory v;
java.lang.Object v, v, v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.http.impl.io.HttpRequestExecutor;
v := @parameter: org.apache.hc.core.http.protocol.HttpProcessor;
v := @parameter: org.apache.hc.core.pool.ManagedConnPool;
v := @parameter: org.apache.hc.core.http.io.SocketConfig;
v := @parameter: org.apache.hc.core.http.io.HttpConnectionFactory;
v := @parameter: javax.net.ssl.SSLSocketFactory;
v := @parameter: org.apache.hc.core.function.Callback;
v := @parameter: org.apache.hc.core.http.io.ssl.SSLSessionVerifier;
v := @parameter: org.apache.hc.core.function.Resolver;
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, "Request executor");
v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.impl.io.HttpRequestExecutor requestExecutor> = v;
v = staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "HTTP processor");
v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor> = 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.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool> = v;
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:
v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.SocketConfig socketConfig> = v;
if v == null goto label;
v = v;
goto label;
label:
v = new org.apache.hc.core.http.impl.io.DefaultBHttpClientConnectionFactory;
v = v;
v = <org.apache.hc.core.http.config.Http1Config: org.apache.hc.core.http.config.Http1Config DEFAULT>;
v = <org.apache.hc.core.http.config.CharCodingConfig: org.apache.hc.core.http.config.CharCodingConfig DEFAULT>;
specialinvoke v.<org.apache.hc.core.http.impl.io.DefaultBHttpClientConnectionFactory: void <init>(org.apache.hc.core.http.config.Http1Config,org.apache.hc.core.http.config.CharCodingConfig)>(v, v);
label:
v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.HttpConnectionFactory connectFactory> = v;
if v != null goto label;
v = staticinvoke <javax.net.ssl.SSLSocketFactory: javax.net.SocketFactory getDefault()>();
label:
v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: javax.net.ssl.SSLSocketFactory sslSocketFactory> = v;
v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.function.Callback sslSetupHandler> = v;
v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.ssl.SSLSessionVerifier sslSessionVerifier> = v;
if v == null goto label;
v = v;
goto label;
label:
v = <org.apache.hc.core.http.impl.DefaultAddressResolver: org.apache.hc.core.http.impl.DefaultAddressResolver INSTANCE>;
label:
v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.function.Resolver addressResolver> = v;
return;
}
public org.apache.hc.core.pool.PoolStats getTotalStats()
{
org.apache.hc.core.pool.PoolStats v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
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.core.http.HttpHost)
{
org.apache.hc.core.pool.PoolStats v;
org.apache.hc.core.http.HttpHost v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.http.HttpHost;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
v = interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: org.apache.hc.core.pool.PoolStats getStats(java.lang.Object)>(v);
return v;
}
public void setMaxTotal(int)
{
int v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: int;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void setMaxTotal(int)>(v);
return;
}
public int getMaxTotal()
{
int v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
v = interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: int getMaxTotal()>();
return v;
}
public void setDefaultMaxPerRoute(int)
{
int v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: int;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void setDefaultMaxPerRoute(int)>(v);
return;
}
public int getDefaultMaxPerRoute()
{
int v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
v = interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: int getDefaultMaxPerRoute()>();
return v;
}
public void setMaxPerRoute(org.apache.hc.core.http.HttpHost, int)
{
org.apache.hc.core.http.HttpHost v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
int v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.http.HttpHost;
v := @parameter: int;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void setMaxPerRoute(java.lang.Object,int)>(v, v);
return;
}
public int getMaxPerRoute(org.apache.hc.core.http.HttpHost)
{
org.apache.hc.core.http.HttpHost v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
int v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.http.HttpHost;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
v = interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: int getMaxPerRoute(java.lang.Object)>(v);
return v;
}
public void closeIdle(org.apache.hc.core.util.TimeValue)
{
org.apache.hc.core.util.TimeValue v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.util.TimeValue;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void closeIdle(org.apache.hc.core.util.TimeValue)>(v);
return;
}
public void closeExpired()
{
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void closeExpired()>();
return;
}
public java.util.Set getRoutes()
{
java.util.Set v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
v = interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: java.util.Set getRoutes()>();
return v;
}
public org.apache.hc.core.http.ClassicHttpResponse execute(org.apache.hc.core.http.io.HttpClientConnection, org.apache.hc.core.http.ClassicHttpRequest, org.apache.hc.core.http.io.HttpResponseInformationCallback, org.apache.hc.core.http.protocol.HttpContext) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.http.impl.io.HttpRequestExecutor v, v, v;
org.apache.hc.core.http.protocol.HttpContext v;
org.apache.hc.core.http.io.HttpClientConnection v;
org.apache.hc.core.http.ClassicHttpRequest v;
org.apache.hc.core.http.ConnectionClosedException v;
org.apache.hc.core.http.protocol.HttpProcessor v, v;
org.apache.hc.core.http.io.HttpResponseInformationCallback v;
org.apache.hc.core.http.ClassicHttpResponse v;
boolean v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.http.io.HttpClientConnection;
v := @parameter: org.apache.hc.core.http.ClassicHttpRequest;
v := @parameter: org.apache.hc.core.http.io.HttpResponseInformationCallback;
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, "HTTP connection");
staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "HTTP request");
staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "HTTP context");
v = interfaceinvoke v.<org.apache.hc.core.http.io.HttpClientConnection: boolean isOpen()>();
if v != 0 goto label;
v = new org.apache.hc.core.http.ConnectionClosedException;
specialinvoke v.<org.apache.hc.core.http.ConnectionClosedException: void <init>()>();
throw v;
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.impl.io.HttpRequestExecutor requestExecutor>;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor>;
virtualinvoke v.<org.apache.hc.core.http.impl.io.HttpRequestExecutor: void preProcess(org.apache.hc.core.http.ClassicHttpRequest,org.apache.hc.core.http.protocol.HttpProcessor,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v);
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.impl.io.HttpRequestExecutor requestExecutor>;
v = virtualinvoke v.<org.apache.hc.core.http.impl.io.HttpRequestExecutor: org.apache.hc.core.http.ClassicHttpResponse execute(org.apache.hc.core.http.ClassicHttpRequest,org.apache.hc.core.http.io.HttpClientConnection,org.apache.hc.core.http.io.HttpResponseInformationCallback,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v, v);
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.impl.io.HttpRequestExecutor requestExecutor>;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor>;
virtualinvoke v.<org.apache.hc.core.http.impl.io.HttpRequestExecutor: void postProcess(org.apache.hc.core.http.ClassicHttpResponse,org.apache.hc.core.http.protocol.HttpProcessor,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v);
return v;
}
public org.apache.hc.core.http.ClassicHttpResponse execute(org.apache.hc.core.http.io.HttpClientConnection, org.apache.hc.core.http.ClassicHttpRequest, org.apache.hc.core.http.protocol.HttpContext) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.core.http.ClassicHttpRequest v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.http.protocol.HttpContext v;
org.apache.hc.core.http.ClassicHttpResponse v;
org.apache.hc.core.http.io.HttpClientConnection v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.http.io.HttpClientConnection;
v := @parameter: org.apache.hc.core.http.ClassicHttpRequest;
v := @parameter: org.apache.hc.core.http.protocol.HttpContext;
v = virtualinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.ClassicHttpResponse execute(org.apache.hc.core.http.io.HttpClientConnection,org.apache.hc.core.http.ClassicHttpRequest,org.apache.hc.core.http.io.HttpResponseInformationCallback,org.apache.hc.core.http.protocol.HttpContext)>(v, v, null, v);
return v;
}
public boolean keepAlive(org.apache.hc.core.http.io.HttpClientConnection, org.apache.hc.core.http.ClassicHttpRequest, org.apache.hc.core.http.ClassicHttpResponse, org.apache.hc.core.http.protocol.HttpContext) throws java.io.IOException
{
org.apache.hc.core.http.ClassicHttpRequest v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.http.impl.io.HttpRequestExecutor v;
org.apache.hc.core.http.protocol.HttpContext v;
org.apache.hc.core.http.ClassicHttpResponse v;
org.apache.hc.core.http.io.HttpClientConnection v;
boolean v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.http.io.HttpClientConnection;
v := @parameter: org.apache.hc.core.http.ClassicHttpRequest;
v := @parameter: org.apache.hc.core.http.ClassicHttpResponse;
v := @parameter: org.apache.hc.core.http.protocol.HttpContext;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.impl.io.HttpRequestExecutor requestExecutor>;
v = virtualinvoke v.<org.apache.hc.core.http.impl.io.HttpRequestExecutor: boolean keepAlive(org.apache.hc.core.http.ClassicHttpRequest,org.apache.hc.core.http.ClassicHttpResponse,org.apache.hc.core.http.io.HttpClientConnection,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v, v);
if v != 0 goto label;
interfaceinvoke v.<org.apache.hc.core.http.io.HttpClientConnection: void close()>();
label:
return v;
}
public java.lang.Object execute(org.apache.hc.core.http.io.HttpClientConnection, org.apache.hc.core.http.ClassicHttpRequest, org.apache.hc.core.http.protocol.HttpContext, org.apache.hc.core.http.io.HttpClientResponseHandler) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
java.lang.Throwable v;
org.apache.hc.core.http.io.HttpClientResponseHandler v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.http.impl.io.HttpRequestExecutor v;
org.apache.hc.core.http.protocol.HttpContext v;
org.apache.hc.core.http.io.HttpClientConnection v;
java.lang.Exception v;
org.apache.hc.core.http.ClassicHttpRequest v;
org.apache.hc.core.http.ClassicHttpResponse v;
org.apache.hc.core.io.CloseMode v;
java.lang.Object v;
org.apache.hc.core.http.HttpEntity v;
boolean v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.http.io.HttpClientConnection;
v := @parameter: org.apache.hc.core.http.ClassicHttpRequest;
v := @parameter: org.apache.hc.core.http.protocol.HttpContext;
v := @parameter: org.apache.hc.core.http.io.HttpClientResponseHandler;
label:
v = virtualinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.ClassicHttpResponse execute(org.apache.hc.core.http.io.HttpClientConnection,org.apache.hc.core.http.ClassicHttpRequest,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v);
label:
v = interfaceinvoke v.<org.apache.hc.core.http.io.HttpClientResponseHandler: java.lang.Object handleResponse(org.apache.hc.core.http.ClassicHttpResponse)>(v);
v = interfaceinvoke v.<org.apache.hc.core.http.ClassicHttpResponse: org.apache.hc.core.http.HttpEntity getEntity()>();
staticinvoke <org.apache.hc.core.http.io.entity.EntityUtils: void consume(org.apache.hc.core.http.HttpEntity)>(v);
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.impl.io.HttpRequestExecutor requestExecutor>;
v = virtualinvoke v.<org.apache.hc.core.http.impl.io.HttpRequestExecutor: boolean keepAlive(org.apache.hc.core.http.ClassicHttpRequest,org.apache.hc.core.http.ClassicHttpResponse,org.apache.hc.core.http.io.HttpClientConnection,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v, v);
if v != 0 goto label;
interfaceinvoke v.<org.apache.hc.core.http.io.HttpClientConnection: void close()>();
label:
interfaceinvoke v.<org.apache.hc.core.http.ClassicHttpResponse: void close()>();
label:
return v;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = <org.apache.hc.core.io.CloseMode: org.apache.hc.core.io.CloseMode IMMEDIATE>;
interfaceinvoke v.<org.apache.hc.core.http.io.HttpClientConnection: void close(org.apache.hc.core.io.CloseMode)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
catch org.apache.hc.core.http.HttpException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.RuntimeException from label to label with label;
}
private java.net.Socket createSocket(org.apache.hc.core.http.HttpHost) throws java.io.IOException
{
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
java.net.SocketAddress v, v;
org.apache.hc.core.function.Resolver v;
org.apache.hc.core.http.io.ssl.SSLSessionVerifier v, v;
java.net.Proxy v;
boolean v, v, v, v, v;
org.apache.hc.core.util.TimeValue v;
javax.net.ssl.SSLHandshakeException v;
org.apache.hc.core.function.Callback v, v;
org.apache.hc.core.http.io.SocketConfig v, v, v, v, v, v, v, v, v, v, v;
org.apache.hc.core.util.Timeout v;
javax.net.ssl.SSLSocketFactory v;
java.lang.Throwable v, v, v;
java.net.Socket v, v, v, v;
javax.net.ssl.SSLParameters v;
java.net.Proxy$Type v;
javax.net.ssl.SSLSession v;
int v, v, v, v, v, v, v;
java.lang.String v, v, v;
java.security.PrivilegedActionException v;
java.io.IOException v;
org.apache.hc.core.http.URIScheme v;
org.apache.hc.core.http.HttpHost v;
java.lang.Object v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester$1 v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.http.HttpHost;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.SocketConfig socketConfig>;
v = virtualinvoke v.<org.apache.hc.core.http.io.SocketConfig: java.net.SocketAddress getSocksProxyAddress()>();
if v == null goto label;
v = new java.net.Socket;
v = new java.net.Proxy;
v = <java.net.Proxy$Type: java.net.Proxy$Type SOCKS>;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.SocketConfig socketConfig>;
v = virtualinvoke v.<org.apache.hc.core.http.io.SocketConfig: java.net.SocketAddress getSocksProxyAddress()>();
specialinvoke v.<java.net.Proxy: void <init>(java.net.Proxy$Type,java.net.SocketAddress)>(v, v);
specialinvoke v.<java.net.Socket: void <init>(java.net.Proxy)>(v);
v = v;
goto label;
label:
v = new java.net.Socket;
specialinvoke v.<java.net.Socket: void <init>()>();
v = v;
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.SocketConfig socketConfig>;
v = virtualinvoke v.<org.apache.hc.core.http.io.SocketConfig: org.apache.hc.core.util.Timeout getSoTimeout()>();
v = virtualinvoke v.<org.apache.hc.core.util.Timeout: int toMillisecondsIntBound()>();
virtualinvoke v.<java.net.Socket: void setSoTimeout(int)>(v);
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.SocketConfig socketConfig>;
v = virtualinvoke v.<org.apache.hc.core.http.io.SocketConfig: boolean isSoReuseAddress()>();
virtualinvoke v.<java.net.Socket: void setReuseAddress(boolean)>(v);
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.SocketConfig socketConfig>;
v = virtualinvoke v.<org.apache.hc.core.http.io.SocketConfig: boolean isTcpNoDelay()>();
virtualinvoke v.<java.net.Socket: void setTcpNoDelay(boolean)>(v);
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.SocketConfig socketConfig>;
v = virtualinvoke v.<org.apache.hc.core.http.io.SocketConfig: boolean isSoKeepAlive()>();
virtualinvoke v.<java.net.Socket: void setKeepAlive(boolean)>(v);
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.SocketConfig socketConfig>;
v = virtualinvoke v.<org.apache.hc.core.http.io.SocketConfig: int getRcvBufSize()>();
if v <= 0 goto label;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.SocketConfig socketConfig>;
v = virtualinvoke v.<org.apache.hc.core.http.io.SocketConfig: int getRcvBufSize()>();
virtualinvoke v.<java.net.Socket: void setReceiveBufferSize(int)>(v);
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.SocketConfig socketConfig>;
v = virtualinvoke v.<org.apache.hc.core.http.io.SocketConfig: int getSndBufSize()>();
if v <= 0 goto label;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.SocketConfig socketConfig>;
v = virtualinvoke v.<org.apache.hc.core.http.io.SocketConfig: int getSndBufSize()>();
virtualinvoke v.<java.net.Socket: void setSendBufferSize(int)>(v);
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.SocketConfig socketConfig>;
v = virtualinvoke v.<org.apache.hc.core.http.io.SocketConfig: org.apache.hc.core.util.TimeValue getSoLinger()>();
v = virtualinvoke v.<org.apache.hc.core.util.TimeValue: int toMillisecondsIntBound()>();
if v < 0 goto label;
virtualinvoke v.<java.net.Socket: void setSoLinger(boolean,int)>(1, v);
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.function.Resolver addressResolver>;
v = interfaceinvoke v.<org.apache.hc.core.function.Resolver: java.lang.Object resolve(java.lang.Object)>(v);
label:
v = new org.apache.hc.core.http.impl.bootstrap.HttpRequester$1;
specialinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester$1: void <init>(org.apache.hc.core.http.impl.bootstrap.HttpRequester,java.net.Socket,java.net.InetSocketAddress)>(v, v, v);
staticinvoke <java.security.AccessController: java.lang.Object doPrivileged(java.security.PrivilegedExceptionAction)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.security.PrivilegedActionException: java.lang.Throwable getCause()>();
v = v instanceof java.io.IOException;
v = virtualinvoke v.<java.security.PrivilegedActionException: java.lang.Throwable getCause()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Throwable)>(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[])>("method contract violation only checked exceptions are wrapped: \u0001");
staticinvoke <org.apache.hc.core.util.Asserts: void check(boolean,java.lang.String)>(v, v);
v = virtualinvoke v.<java.security.PrivilegedActionException: java.lang.Throwable getCause()>();
throw v;
label:
v = <org.apache.hc.core.http.URIScheme: org.apache.hc.core.http.URIScheme HTTPS>;
v = virtualinvoke v.<org.apache.hc.core.http.HttpHost: java.lang.String getSchemeName()>();
v = virtualinvoke v.<org.apache.hc.core.http.URIScheme: boolean same(java.lang.String)>(v);
if v == 0 goto label;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: javax.net.ssl.SSLSocketFactory sslSocketFactory>;
v = virtualinvoke v.<org.apache.hc.core.http.HttpHost: java.lang.String getHostName()>();
v = virtualinvoke v.<java.net.InetSocketAddress: int getPort()>();
v = virtualinvoke v.<javax.net.ssl.SSLSocketFactory: java.net.Socket createSocket(java.net.Socket,java.lang.String,int,boolean)>(v, v, v, 1);
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.function.Callback sslSetupHandler>;
if v == null goto label;
v = virtualinvoke v.<javax.net.ssl.SSLSocket: javax.net.ssl.SSLParameters getSSLParameters()>();
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.function.Callback sslSetupHandler>;
interfaceinvoke v.<org.apache.hc.core.function.Callback: void execute(java.lang.Object)>(v);
virtualinvoke v.<javax.net.ssl.SSLSocket: void setSSLParameters(javax.net.ssl.SSLParameters)>(v);
label:
virtualinvoke v.<javax.net.ssl.SSLSocket: void startHandshake()>();
v = virtualinvoke v.<javax.net.ssl.SSLSocket: javax.net.ssl.SSLSession getSession()>();
if v != null goto label;
v = new javax.net.ssl.SSLHandshakeException;
specialinvoke v.<javax.net.ssl.SSLHandshakeException: void <init>(java.lang.String)>("SSL session not available");
throw v;
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.ssl.SSLSessionVerifier sslSessionVerifier>;
if v == null goto label;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.ssl.SSLSessionVerifier sslSessionVerifier>;
interfaceinvoke v.<org.apache.hc.core.http.io.ssl.SSLSessionVerifier: void verify(org.apache.hc.core.http.HttpHost,javax.net.ssl.SSLSession)>(v, v);
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.apache.hc.core.io.Closer: void closeQuietly(java.io.Closeable)>(v);
throw v;
label:
return v;
label:
return v;
catch java.security.PrivilegedActionException from label to label with label;
catch java.io.IOException from label to label with label;
}
public org.apache.hc.core.http.ClassicHttpResponse execute(org.apache.hc.core.http.HttpHost, org.apache.hc.core.http.ClassicHttpRequest, org.apache.hc.core.http.io.HttpResponseInformationCallback, org.apache.hc.core.util.Timeout, org.apache.hc.core.http.protocol.HttpContext) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
java.util.concurrent.TimeoutException v;
org.apache.hc.core.pool.ManagedConnPool v;
java.util.concurrent.Future v;
org.apache.hc.core.net.URIAuthority v, v;
org.apache.hc.core.http.io.HttpResponseInformationCallback v;
java.lang.Thread v;
org.apache.hc.core.http.ClassicHttpResponse v;
org.apache.hc.core.io.ModalCloseable v;
boolean v;
org.apache.hc.core.http.impl.io.HttpRequestExecutor v;
org.apache.hc.core.http.ConnectionRequestTimeoutException v;
org.apache.hc.core.util.Timeout v, v;
java.lang.Exception v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester$PoolEntryHolder v;
org.apache.hc.core.http.HttpEntity v;
java.net.Socket v;
org.apache.hc.core.http.io.HttpConnectionFactory v;
org.apache.hc.core.http.protocol.HttpContext v;
long v;
java.io.InterruptedIOException v;
org.apache.hc.core.http.io.HttpClientConnection v;
int v;
java.lang.String v, v;
org.apache.hc.core.http.HttpException v;
java.util.concurrent.ExecutionException v;
java.util.concurrent.TimeUnit v;
org.apache.hc.core.http.ClassicHttpRequest v;
org.apache.hc.core.http.HttpHost v;
java.lang.InterruptedException v;
java.lang.Object v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester$2 v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.http.HttpHost;
v := @parameter: org.apache.hc.core.http.ClassicHttpRequest;
v := @parameter: org.apache.hc.core.http.io.HttpResponseInformationCallback;
v := @parameter: org.apache.hc.core.util.Timeout;
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, "HTTP host");
staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "HTTP request");
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
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, null, v, null);
v = staticinvoke <org.apache.hc.core.util.Timeout: org.apache.hc.core.util.Timeout defaultsToDisabled(org.apache.hc.core.util.Timeout)>(v);
label:
v = virtualinvoke v.<org.apache.hc.core.util.Timeout: long getDuration()>();
v = virtualinvoke v.<org.apache.hc.core.util.Timeout: java.util.concurrent.TimeUnit getTimeUnit()>();
v = interfaceinvoke v.<java.util.concurrent.Future: java.lang.Object get(long,java.util.concurrent.TimeUnit)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
v = new java.io.InterruptedIOException;
v = virtualinvoke v.<java.lang.InterruptedException: java.lang.String getMessage()>();
specialinvoke v.<java.io.InterruptedIOException: void <init>(java.lang.String)>(v);
throw v;
label:
v := @caughtexception;
v = new org.apache.hc.core.http.HttpException;
specialinvoke v.<org.apache.hc.core.http.HttpException: void <init>(java.lang.String,java.lang.Throwable)>("Unexpected failure leasing connection", v);
throw v;
label:
v := @caughtexception;
v = new org.apache.hc.core.http.ConnectionRequestTimeoutException;
specialinvoke v.<org.apache.hc.core.http.ConnectionRequestTimeoutException: void <init>(java.lang.String)>("Connection request timeout");
throw v;
label:
v = new org.apache.hc.core.http.impl.bootstrap.HttpRequester$PoolEntryHolder;
specialinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester$PoolEntryHolder: void <init>(org.apache.hc.core.http.impl.bootstrap.HttpRequester,org.apache.hc.core.pool.PoolEntry)>(v, v);
label:
v = virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: org.apache.hc.core.io.ModalCloseable getConnection()>();
if v != null goto label;
v = specialinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: java.net.Socket createSocket(org.apache.hc.core.http.HttpHost)>(v);
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.io.HttpConnectionFactory connectFactory>;
interfaceinvoke v.<org.apache.hc.core.http.io.HttpConnectionFactory: org.apache.hc.core.http.HttpConnection createConnection(java.net.Socket)>(v);
virtualinvoke v.<org.apache.hc.core.pool.PoolEntry: void assignConnection(org.apache.hc.core.io.ModalCloseable)>(v);
label:
v = interfaceinvoke v.<org.apache.hc.core.http.ClassicHttpRequest: org.apache.hc.core.net.URIAuthority getAuthority()>();
if v != null goto label;
v = new org.apache.hc.core.net.URIAuthority;
v = virtualinvoke v.<org.apache.hc.core.http.HttpHost: java.lang.String getHostName()>();
v = virtualinvoke v.<org.apache.hc.core.http.HttpHost: int getPort()>();
specialinvoke v.<org.apache.hc.core.net.URIAuthority: void <init>(java.lang.String,int)>(v, v);
interfaceinvoke v.<org.apache.hc.core.http.ClassicHttpRequest: void setAuthority(org.apache.hc.core.net.URIAuthority)>(v);
label:
v = virtualinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.ClassicHttpResponse execute(org.apache.hc.core.http.io.HttpClientConnection,org.apache.hc.core.http.ClassicHttpRequest,org.apache.hc.core.http.io.HttpResponseInformationCallback,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v, v);
v = interfaceinvoke v.<org.apache.hc.core.http.ClassicHttpResponse: org.apache.hc.core.http.HttpEntity getEntity()>();
if v == null goto label;
v = new org.apache.hc.core.http.impl.bootstrap.HttpRequester$2;
specialinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester$2: void <init>(org.apache.hc.core.http.impl.bootstrap.HttpRequester,org.apache.hc.core.http.HttpEntity,org.apache.hc.core.http.impl.bootstrap.HttpRequester$PoolEntryHolder,org.apache.hc.core.http.ClassicHttpRequest,org.apache.hc.core.http.ClassicHttpResponse,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v, v, v, v);
interfaceinvoke v.<org.apache.hc.core.http.ClassicHttpResponse: void setEntity(org.apache.hc.core.http.HttpEntity)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester$PoolEntryHolder: org.apache.hc.core.http.io.HttpClientConnection getConnection()>();
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.impl.io.HttpRequestExecutor requestExecutor>;
v = virtualinvoke v.<org.apache.hc.core.http.impl.io.HttpRequestExecutor: boolean keepAlive(org.apache.hc.core.http.ClassicHttpRequest,org.apache.hc.core.http.ClassicHttpResponse,org.apache.hc.core.http.io.HttpClientConnection,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v, v);
if v != 0 goto label;
interfaceinvoke v.<org.apache.hc.core.http.io.HttpClientConnection: void close()>();
label:
virtualinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester$PoolEntryHolder: void releaseConnection()>();
label:
return v;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester$PoolEntryHolder: void discardConnection()>();
throw v;
catch java.lang.InterruptedException from label to label with label;
catch java.util.concurrent.ExecutionException from label to label with label;
catch java.util.concurrent.TimeoutException from label to label with label;
catch org.apache.hc.core.http.HttpException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.RuntimeException from label to label with label;
}
public org.apache.hc.core.http.ClassicHttpResponse execute(org.apache.hc.core.http.HttpHost, org.apache.hc.core.http.ClassicHttpRequest, org.apache.hc.core.util.Timeout, org.apache.hc.core.http.protocol.HttpContext) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.core.http.ClassicHttpRequest v;
org.apache.hc.core.http.HttpHost v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.http.protocol.HttpContext v;
org.apache.hc.core.http.ClassicHttpResponse v;
org.apache.hc.core.util.Timeout v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.http.HttpHost;
v := @parameter: org.apache.hc.core.http.ClassicHttpRequest;
v := @parameter: org.apache.hc.core.util.Timeout;
v := @parameter: org.apache.hc.core.http.protocol.HttpContext;
v = virtualinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.ClassicHttpResponse execute(org.apache.hc.core.http.HttpHost,org.apache.hc.core.http.ClassicHttpRequest,org.apache.hc.core.http.io.HttpResponseInformationCallback,org.apache.hc.core.util.Timeout,org.apache.hc.core.http.protocol.HttpContext)>(v, v, null, v, v);
return v;
}
public java.lang.Object execute(org.apache.hc.core.http.HttpHost, org.apache.hc.core.http.ClassicHttpRequest, org.apache.hc.core.util.Timeout, org.apache.hc.core.http.protocol.HttpContext, org.apache.hc.core.http.io.HttpClientResponseHandler) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
java.lang.Throwable v;
org.apache.hc.core.http.io.HttpClientResponseHandler v;
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.http.protocol.HttpContext v;
org.apache.hc.core.util.Timeout v;
org.apache.hc.core.http.ClassicHttpRequest v;
org.apache.hc.core.http.HttpHost v;
org.apache.hc.core.http.ClassicHttpResponse v;
java.lang.Object v;
org.apache.hc.core.http.HttpEntity v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.http.HttpHost;
v := @parameter: org.apache.hc.core.http.ClassicHttpRequest;
v := @parameter: org.apache.hc.core.util.Timeout;
v := @parameter: org.apache.hc.core.http.protocol.HttpContext;
v := @parameter: org.apache.hc.core.http.io.HttpClientResponseHandler;
v = virtualinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.http.ClassicHttpResponse execute(org.apache.hc.core.http.HttpHost,org.apache.hc.core.http.ClassicHttpRequest,org.apache.hc.core.http.io.HttpResponseInformationCallback,org.apache.hc.core.util.Timeout,org.apache.hc.core.http.protocol.HttpContext)>(v, v, null, v, v);
label:
v = interfaceinvoke v.<org.apache.hc.core.http.io.HttpClientResponseHandler: java.lang.Object handleResponse(org.apache.hc.core.http.ClassicHttpResponse)>(v);
v = interfaceinvoke v.<org.apache.hc.core.http.ClassicHttpResponse: org.apache.hc.core.http.HttpEntity getEntity()>();
staticinvoke <org.apache.hc.core.http.io.entity.EntityUtils: void consume(org.apache.hc.core.http.HttpEntity)>(v);
label:
interfaceinvoke v.<org.apache.hc.core.http.ClassicHttpResponse: void close()>();
return v;
label:
v := @caughtexception;
throw v;
catch java.lang.Throwable from label to label with label;
}
public org.apache.hc.core.pool.ConnPoolControl getConnPoolControl()
{
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
return v;
}
public void close(org.apache.hc.core.io.CloseMode)
{
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.pool.ManagedConnPool v;
org.apache.hc.core.io.CloseMode v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v := @parameter: org.apache.hc.core.io.CloseMode;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void close(org.apache.hc.core.io.CloseMode)>(v);
return;
}
public void close() throws java.io.IOException
{
org.apache.hc.core.http.impl.bootstrap.HttpRequester v;
org.apache.hc.core.pool.ManagedConnPool v;
v := @this: org.apache.hc.core.http.impl.bootstrap.HttpRequester;
v = v.<org.apache.hc.core.http.impl.bootstrap.HttpRequester: org.apache.hc.core.pool.ManagedConnPool connPool>;
interfaceinvoke v.<org.apache.hc.core.pool.ManagedConnPool: void close()>();
return;
}
}