class org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime extends java.lang.Object implements org.apache.hc.client.http.async.AsyncExecRuntime
{
private final org.slf4j.Logger log;
private final org.apache.hc.client.http.nio.AsyncClientConnectionManager manager;
private final org.apache.hc.core.reactor.ConnectionInitiator connectionInitiator;
private final org.apache.hc.core.http.nio.HandlerFactory pushHandlerFactory;
private final org.apache.hc.core.http.HttpVersionPolicy versionPolicy;
private final java.util.concurrent.atomic.AtomicReference endpointRef;
private volatile boolean reusable;
private volatile java.lang.Object state;
private volatile org.apache.hc.core.util.TimeValue validDuration;
void <init>(org.slf4j.Logger, org.apache.hc.client.http.nio.AsyncClientConnectionManager, org.apache.hc.core.reactor.ConnectionInitiator, org.apache.hc.core.http.nio.HandlerFactory, org.apache.hc.core.http.HttpVersionPolicy)
{
org.apache.hc.client.http.nio.AsyncClientConnectionManager v;
org.apache.hc.core.util.TimeValue v;
org.slf4j.Logger v;
org.apache.hc.core.http.nio.HandlerFactory v;
org.apache.hc.core.reactor.ConnectionInitiator v;
java.util.concurrent.atomic.AtomicReference v;
org.apache.hc.core.http.HttpVersionPolicy v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v := @parameter: org.slf4j.Logger;
v := @parameter: org.apache.hc.client.http.nio.AsyncClientConnectionManager;
v := @parameter: org.apache.hc.core.reactor.ConnectionInitiator;
v := @parameter: org.apache.hc.core.http.nio.HandlerFactory;
v := @parameter: org.apache.hc.core.http.HttpVersionPolicy;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log> = v;
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.client.http.nio.AsyncClientConnectionManager manager> = v;
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.reactor.ConnectionInitiator connectionInitiator> = v;
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.http.nio.HandlerFactory pushHandlerFactory> = v;
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.http.HttpVersionPolicy versionPolicy> = v;
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>()>();
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.util.concurrent.atomic.AtomicReference endpointRef> = v;
v = <org.apache.hc.core.util.TimeValue: org.apache.hc.core.util.TimeValue NEG_ONE_MILLISECOND>;
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.util.TimeValue validDuration> = v;
return;
}
public boolean isEndpointAcquired()
{
java.lang.Object v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
java.util.concurrent.atomic.AtomicReference v;
boolean v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.util.concurrent.atomic.AtomicReference endpointRef>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public org.apache.hc.core.concurrent.Cancellable acquireEndpoint(java.lang.String, org.apache.hc.client.http.HttpRoute, java.lang.Object, org.apache.hc.client.http.protocol.HttpClientContext, org.apache.hc.core.concurrent.FutureCallback)
{
org.apache.hc.client.http.nio.AsyncClientConnectionManager v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime$1 v;
org.apache.hc.client.http.protocol.HttpClientContext v;
org.apache.hc.core.concurrent.Cancellable v, v;
java.util.concurrent.atomic.AtomicReference v;
java.util.concurrent.Future v;
org.apache.hc.core.concurrent.FutureCallback v;
java.lang.String v;
org.apache.hc.client.http.config.RequestConfig v;
boolean v;
org.slf4j.Logger v, v;
org.apache.hc.core.util.Timeout v;
org.apache.hc.client.http.HttpRoute v;
java.lang.Object v, v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hc.client.http.HttpRoute;
v := @parameter: java.lang.Object;
v := @parameter: org.apache.hc.client.http.protocol.HttpClientContext;
v := @parameter: org.apache.hc.core.concurrent.FutureCallback;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.util.concurrent.atomic.AtomicReference endpointRef>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v != null goto label;
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.lang.Object state> = v;
v = virtualinvoke v.<org.apache.hc.client.http.protocol.HttpClientContext: org.apache.hc.client.http.config.RequestConfig getRequestConfig()>();
v = virtualinvoke v.<org.apache.hc.client.http.config.RequestConfig: org.apache.hc.core.util.Timeout getConnectionRequestTimeout()>();
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} acquiring endpoint ({})", v, v);
label:
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.client.http.nio.AsyncClientConnectionManager manager>;
v = new org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime$1;
specialinvoke v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime$1: void <init>(org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime,java.lang.String,org.apache.hc.core.concurrent.FutureCallback)>(v, v, v);
v = interfaceinvoke v.<org.apache.hc.client.http.nio.AsyncClientConnectionManager: java.util.concurrent.Future lease(java.lang.String,org.apache.hc.client.http.HttpRoute,java.lang.Object,org.apache.hc.core.util.Timeout,org.apache.hc.core.concurrent.FutureCallback)>(v, v, v, v, v);
v = staticinvoke <org.apache.hc.client.http.impl.Operations: org.apache.hc.core.concurrent.Cancellable cancellable(java.util.concurrent.Future)>(v);
return v;
label:
interfaceinvoke v.<org.apache.hc.core.concurrent.FutureCallback: void completed(java.lang.Object)>(v);
v = staticinvoke <org.apache.hc.client.http.impl.Operations: org.apache.hc.core.concurrent.Cancellable nonCancellable()>();
return v;
}
private void discardEndpoint(org.apache.hc.client.http.nio.AsyncConnectionEndpoint)
{
java.lang.Throwable v;
org.apache.hc.client.http.nio.AsyncClientConnectionManager v, v;
org.apache.hc.core.io.CloseMode v;
java.lang.String v, v, v;
boolean v, v, v;
org.apache.hc.core.util.TimeValue v, v;
org.slf4j.Logger v, v, v, v, v, v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
org.apache.hc.client.http.nio.AsyncConnectionEndpoint v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v := @parameter: org.apache.hc.client.http.nio.AsyncConnectionEndpoint;
label:
v = <org.apache.hc.core.io.CloseMode: org.apache.hc.core.io.CloseMode IMMEDIATE>;
virtualinvoke v.<org.apache.hc.client.http.nio.AsyncConnectionEndpoint: void close(org.apache.hc.core.io.CloseMode)>(v);
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} endpoint closed", v);
label:
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} discarding endpoint", v);
label:
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.client.http.nio.AsyncClientConnectionManager manager>;
v = <org.apache.hc.core.util.TimeValue: org.apache.hc.core.util.TimeValue ZERO_MILLISECONDS>;
interfaceinvoke v.<org.apache.hc.client.http.nio.AsyncClientConnectionManager: void release(org.apache.hc.client.http.nio.AsyncConnectionEndpoint,java.lang.Object,org.apache.hc.core.util.TimeValue)>(v, null, v);
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} discarding endpoint", v);
label:
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.client.http.nio.AsyncClientConnectionManager manager>;
v = <org.apache.hc.core.util.TimeValue: org.apache.hc.core.util.TimeValue ZERO_MILLISECONDS>;
interfaceinvoke v.<org.apache.hc.client.http.nio.AsyncClientConnectionManager: void release(org.apache.hc.client.http.nio.AsyncConnectionEndpoint,java.lang.Object,org.apache.hc.core.util.TimeValue)>(v, null, v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void releaseEndpoint()
{
org.apache.hc.client.http.nio.AsyncClientConnectionManager v;
org.apache.hc.core.util.TimeValue v;
org.slf4j.Logger v, v;
java.util.concurrent.atomic.AtomicReference v;
java.lang.Object v, v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
java.lang.String v;
boolean v, v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.util.concurrent.atomic.AtomicReference endpointRef>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object getAndSet(java.lang.Object)>(null);
if v == null goto label;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: boolean reusable>;
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} releasing valid endpoint", v);
label:
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.client.http.nio.AsyncClientConnectionManager manager>;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.lang.Object state>;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.util.TimeValue validDuration>;
interfaceinvoke v.<org.apache.hc.client.http.nio.AsyncClientConnectionManager: void release(org.apache.hc.client.http.nio.AsyncConnectionEndpoint,java.lang.Object,org.apache.hc.core.util.TimeValue)>(v, v, v);
goto label;
label:
specialinvoke v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: void discardEndpoint(org.apache.hc.client.http.nio.AsyncConnectionEndpoint)>(v);
label:
return;
}
public void discardEndpoint()
{
java.lang.Object v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.util.concurrent.atomic.AtomicReference endpointRef>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object getAndSet(java.lang.Object)>(null);
if v == null goto label;
specialinvoke v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: void discardEndpoint(org.apache.hc.client.http.nio.AsyncConnectionEndpoint)>(v);
label:
return;
}
public boolean validateConnection()
{
java.util.concurrent.atomic.AtomicReference v, v;
java.lang.Object v, v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
boolean v, v, v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: boolean reusable>;
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.util.concurrent.atomic.AtomicReference endpointRef>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.hc.client.http.nio.AsyncConnectionEndpoint: boolean isConnected()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
label:
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.util.concurrent.atomic.AtomicReference endpointRef>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object getAndSet(java.lang.Object)>(null);
if v == null goto label;
specialinvoke v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: void discardEndpoint(org.apache.hc.client.http.nio.AsyncConnectionEndpoint)>(v);
label:
return 0;
}
org.apache.hc.client.http.nio.AsyncConnectionEndpoint ensureValid()
{
java.lang.IllegalStateException v;
java.lang.Object v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.util.concurrent.atomic.AtomicReference endpointRef>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Endpoint not acquired / already released");
throw v;
label:
return v;
}
public boolean isEndpointConnected()
{
java.lang.Object v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
java.util.concurrent.atomic.AtomicReference v;
boolean v, v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.util.concurrent.atomic.AtomicReference endpointRef>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.hc.client.http.nio.AsyncConnectionEndpoint: boolean isConnected()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public org.apache.hc.core.concurrent.Cancellable connectEndpoint(org.apache.hc.client.http.protocol.HttpClientContext, org.apache.hc.core.concurrent.FutureCallback)
{
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime$2 v;
org.apache.hc.client.http.nio.AsyncClientConnectionManager v;
org.apache.hc.client.http.protocol.HttpClientContext v;
org.apache.hc.core.concurrent.Cancellable v, v;
org.apache.hc.core.http.HttpVersionPolicy v;
java.util.concurrent.Future v;
org.apache.hc.core.concurrent.FutureCallback v;
java.lang.String v;
org.apache.hc.client.http.config.RequestConfig v;
boolean v, v;
org.slf4j.Logger v, v;
org.apache.hc.core.reactor.ConnectionInitiator v;
org.apache.hc.core.util.Timeout v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
org.apache.hc.client.http.nio.AsyncConnectionEndpoint v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v := @parameter: org.apache.hc.client.http.protocol.HttpClientContext;
v := @parameter: org.apache.hc.core.concurrent.FutureCallback;
v = virtualinvoke v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.client.http.nio.AsyncConnectionEndpoint ensureValid()>();
v = virtualinvoke v.<org.apache.hc.client.http.nio.AsyncConnectionEndpoint: boolean isConnected()>();
if v == 0 goto label;
interfaceinvoke v.<org.apache.hc.core.concurrent.FutureCallback: void completed(java.lang.Object)>(v);
v = staticinvoke <org.apache.hc.client.http.impl.Operations: org.apache.hc.core.concurrent.Cancellable nonCancellable()>();
return v;
label:
v = virtualinvoke v.<org.apache.hc.client.http.protocol.HttpClientContext: org.apache.hc.client.http.config.RequestConfig getRequestConfig()>();
v = virtualinvoke v.<org.apache.hc.client.http.config.RequestConfig: org.apache.hc.core.util.Timeout getConnectTimeout()>();
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} connecting endpoint ({})", v, v);
label:
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.client.http.nio.AsyncClientConnectionManager manager>;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.reactor.ConnectionInitiator connectionInitiator>;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.http.HttpVersionPolicy versionPolicy>;
v = new org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime$2;
specialinvoke v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime$2: void <init>(org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime,org.apache.hc.core.concurrent.FutureCallback)>(v, v);
v = interfaceinvoke v.<org.apache.hc.client.http.nio.AsyncClientConnectionManager: java.util.concurrent.Future connect(org.apache.hc.client.http.nio.AsyncConnectionEndpoint,org.apache.hc.core.reactor.ConnectionInitiator,org.apache.hc.core.util.Timeout,java.lang.Object,org.apache.hc.core.http.protocol.HttpContext,org.apache.hc.core.concurrent.FutureCallback)>(v, v, v, v, v, v);
v = staticinvoke <org.apache.hc.client.http.impl.Operations: org.apache.hc.core.concurrent.Cancellable cancellable(java.util.concurrent.Future)>(v);
return v;
}
public void upgradeTls(org.apache.hc.client.http.protocol.HttpClientContext)
{
org.apache.hc.client.http.nio.AsyncClientConnectionManager v;
org.slf4j.Logger v, v;
org.apache.hc.client.http.protocol.HttpClientContext v;
org.apache.hc.core.http.HttpVersionPolicy v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
org.apache.hc.client.http.nio.AsyncConnectionEndpoint v;
java.lang.String v;
boolean v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v := @parameter: org.apache.hc.client.http.protocol.HttpClientContext;
v = virtualinvoke v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.client.http.nio.AsyncConnectionEndpoint ensureValid()>();
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} upgrading endpoint", v);
label:
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.client.http.nio.AsyncClientConnectionManager manager>;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.http.HttpVersionPolicy versionPolicy>;
interfaceinvoke v.<org.apache.hc.client.http.nio.AsyncClientConnectionManager: void upgrade(org.apache.hc.client.http.nio.AsyncConnectionEndpoint,java.lang.Object,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v);
return;
}
public org.apache.hc.core.concurrent.Cancellable execute(java.lang.String, org.apache.hc.core.http.nio.AsyncClientExchangeHandler, org.apache.hc.client.http.protocol.HttpClientContext)
{
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime$4 v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime$3 v;
org.apache.hc.client.http.protocol.HttpClientContext v;
org.apache.hc.core.concurrent.Cancellable v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
java.lang.String v, v;
org.apache.hc.client.http.config.RequestConfig v, v;
boolean v, v, v;
org.slf4j.Logger v, v;
org.apache.hc.core.util.Timeout v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
org.apache.hc.client.http.nio.AsyncConnectionEndpoint v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hc.core.http.nio.AsyncClientExchangeHandler;
v := @parameter: org.apache.hc.client.http.protocol.HttpClientContext;
v = virtualinvoke v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.client.http.nio.AsyncConnectionEndpoint ensureValid()>();
v = virtualinvoke v.<org.apache.hc.client.http.nio.AsyncConnectionEndpoint: boolean isConnected()>();
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = staticinvoke <org.apache.hc.client.http.impl.ConnPoolSupport: java.lang.String getId(java.lang.Object)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} start execution {}", v, v);
label:
v = virtualinvoke v.<org.apache.hc.client.http.protocol.HttpClientContext: org.apache.hc.client.http.config.RequestConfig getRequestConfig()>();
v = virtualinvoke v.<org.apache.hc.client.http.config.RequestConfig: org.apache.hc.core.util.Timeout getResponseTimeout()>();
if v == null goto label;
virtualinvoke v.<org.apache.hc.client.http.nio.AsyncConnectionEndpoint: void setSocketTimeout(org.apache.hc.core.util.Timeout)>(v);
label:
virtualinvoke v.<org.apache.hc.client.http.nio.AsyncConnectionEndpoint: void execute(java.lang.String,org.apache.hc.core.http.nio.AsyncClientExchangeHandler,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v);
v = virtualinvoke v.<org.apache.hc.client.http.protocol.HttpClientContext: org.apache.hc.client.http.config.RequestConfig getRequestConfig()>();
v = virtualinvoke v.<org.apache.hc.client.http.config.RequestConfig: boolean isHardCancellationEnabled()>();
if v == 0 goto label;
v = new org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime$3;
specialinvoke v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime$3: void <init>(org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime,org.apache.hc.core.http.nio.AsyncClientExchangeHandler)>(v, v);
return v;
label:
v = new org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime$4;
specialinvoke v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime$4: void <init>(org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime,org.apache.hc.client.http.nio.AsyncConnectionEndpoint,java.lang.String,org.apache.hc.core.http.nio.AsyncClientExchangeHandler,org.apache.hc.client.http.protocol.HttpClientContext)>(v, v, v, v, v);
virtualinvoke v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.concurrent.Cancellable connectEndpoint(org.apache.hc.client.http.protocol.HttpClientContext,org.apache.hc.core.concurrent.FutureCallback)>(v, v);
label:
v = staticinvoke <org.apache.hc.client.http.impl.Operations: org.apache.hc.core.concurrent.Cancellable nonCancellable()>();
return v;
}
public void markConnectionReusable(java.lang.Object, org.apache.hc.core.util.TimeValue)
{
java.lang.Object v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
org.apache.hc.core.util.TimeValue v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v := @parameter: java.lang.Object;
v := @parameter: org.apache.hc.core.util.TimeValue;
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: boolean reusable> = 1;
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.lang.Object state> = v;
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.util.TimeValue validDuration> = v;
return;
}
public void markConnectionNonReusable()
{
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: boolean reusable> = 0;
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: java.lang.Object state> = null;
v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.util.TimeValue validDuration> = null;
return;
}
public org.apache.hc.client.http.async.AsyncExecRuntime fork()
{
org.apache.hc.client.http.nio.AsyncClientConnectionManager v;
org.slf4j.Logger v;
org.apache.hc.core.http.nio.HandlerFactory v;
org.apache.hc.core.reactor.ConnectionInitiator v;
org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime v, v;
org.apache.hc.core.http.HttpVersionPolicy v;
v := @this: org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v = new org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.slf4j.Logger log>;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.client.http.nio.AsyncClientConnectionManager manager>;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.reactor.ConnectionInitiator connectionInitiator>;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.http.nio.HandlerFactory pushHandlerFactory>;
v = v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: org.apache.hc.core.http.HttpVersionPolicy versionPolicy>;
specialinvoke v.<org.apache.hc.client.http.impl.async.InternalHttpAsyncExecRuntime: void <init>(org.slf4j.Logger,org.apache.hc.client.http.nio.AsyncClientConnectionManager,org.apache.hc.core.reactor.ConnectionInitiator,org.apache.hc.core.http.nio.HandlerFactory,org.apache.hc.core.http.HttpVersionPolicy)>(v, v, v, v, v);
return v;
}
}