public final class org.apache.hc.client.http.impl.async.AsyncConnectExec extends java.lang.Object implements org.apache.hc.client.http.async.AsyncExecChainHandler
{
private static final org.slf4j.Logger LOG;
private final org.apache.hc.core.http.protocol.HttpProcessor proxyHttpProcessor;
private final org.apache.hc.client.http.AuthenticationStrategy proxyAuthStrategy;
private final org.apache.hc.client.http.impl.auth.HttpAuthenticator authenticator;
private final org.apache.hc.client.http.routing.HttpRouteDirector routeDirector;
public void <init>(org.apache.hc.core.http.protocol.HttpProcessor, org.apache.hc.client.http.AuthenticationStrategy)
{
org.apache.hc.core.http.protocol.HttpProcessor v;
org.slf4j.Logger v;
org.apache.hc.client.http.impl.routing.BasicRouteDirector v;
org.apache.hc.client.http.AuthenticationStrategy v;
org.apache.hc.client.http.impl.auth.HttpAuthenticator v;
org.apache.hc.client.http.impl.async.AsyncConnectExec v;
v := @this: org.apache.hc.client.http.impl.async.AsyncConnectExec;
v := @parameter: org.apache.hc.core.http.protocol.HttpProcessor;
v := @parameter: org.apache.hc.client.http.AuthenticationStrategy;
specialinvoke v.<java.lang.Object: void <init>()>();
staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Proxy HTTP processor");
staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Proxy authentication strategy");
v.<org.apache.hc.client.http.impl.async.AsyncConnectExec: org.apache.hc.core.http.protocol.HttpProcessor proxyHttpProcessor> = v;
v.<org.apache.hc.client.http.impl.async.AsyncConnectExec: org.apache.hc.client.http.AuthenticationStrategy proxyAuthStrategy> = v;
v = new org.apache.hc.client.http.impl.auth.HttpAuthenticator;
v = <org.apache.hc.client.http.impl.async.AsyncConnectExec: org.slf4j.Logger LOG>;
specialinvoke v.<org.apache.hc.client.http.impl.auth.HttpAuthenticator: void <init>(org.slf4j.Logger)>(v);
v.<org.apache.hc.client.http.impl.async.AsyncConnectExec: org.apache.hc.client.http.impl.auth.HttpAuthenticator authenticator> = v;
v = new org.apache.hc.client.http.impl.routing.BasicRouteDirector;
specialinvoke v.<org.apache.hc.client.http.impl.routing.BasicRouteDirector: void <init>()>();
v.<org.apache.hc.client.http.impl.async.AsyncConnectExec: org.apache.hc.client.http.routing.HttpRouteDirector routeDirector> = v;
return;
}
public void execute(org.apache.hc.core.http.HttpRequest, org.apache.hc.core.http.nio.AsyncEntityProducer, org.apache.hc.client.http.async.AsyncExecChain$Scope, org.apache.hc.client.http.async.AsyncExecChain, org.apache.hc.client.http.async.AsyncExecCallback) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.client.http.protocol.HttpClientContext v;
org.apache.hc.core.concurrent.Cancellable v;
org.apache.hc.client.http.async.AsyncExecRuntime v;
org.apache.hc.client.http.impl.async.AsyncConnectExec$1 v;
java.lang.String v;
org.apache.hc.client.http.async.AsyncExecCallback v;
boolean v, v, v;
org.slf4j.Logger v, v;
org.apache.hc.client.http.impl.async.AsyncConnectExec$State v;
org.apache.hc.client.http.async.AsyncExecChain$Scope v;
java.lang.Exception v;
org.apache.hc.client.http.HttpRoute v;
org.apache.hc.core.http.HttpRequest v;
org.apache.hc.core.http.nio.AsyncEntityProducer v;
org.apache.hc.client.http.async.AsyncExecChain v;
java.lang.Object v;
org.apache.hc.client.http.impl.async.AsyncConnectExec v;
org.apache.hc.core.concurrent.CancellableDependency v;
v := @this: org.apache.hc.client.http.impl.async.AsyncConnectExec;
v := @parameter: org.apache.hc.core.http.HttpRequest;
v := @parameter: org.apache.hc.core.http.nio.AsyncEntityProducer;
v := @parameter: org.apache.hc.client.http.async.AsyncExecChain$Scope;
v := @parameter: org.apache.hc.client.http.async.AsyncExecChain;
v := @parameter: org.apache.hc.client.http.async.AsyncExecCallback;
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, "Scope");
v = v.<org.apache.hc.client.http.async.AsyncExecChain$Scope: java.lang.String exchangeId>;
v = v.<org.apache.hc.client.http.async.AsyncExecChain$Scope: org.apache.hc.client.http.HttpRoute route>;
v = v.<org.apache.hc.client.http.async.AsyncExecChain$Scope: org.apache.hc.core.concurrent.CancellableDependency cancellableDependency>;
v = v.<org.apache.hc.client.http.async.AsyncExecChain$Scope: org.apache.hc.client.http.protocol.HttpClientContext clientContext>;
v = v.<org.apache.hc.client.http.async.AsyncExecChain$Scope: org.apache.hc.client.http.async.AsyncExecRuntime execRuntime>;
v = new org.apache.hc.client.http.impl.async.AsyncConnectExec$State;
specialinvoke v.<org.apache.hc.client.http.impl.async.AsyncConnectExec$State: void <init>(org.apache.hc.client.http.HttpRoute)>(v);
v = interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecRuntime: boolean isEndpointAcquired()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hc.client.http.protocol.HttpClientContext: java.lang.Object getUserToken()>();
v = <org.apache.hc.client.http.impl.async.AsyncConnectExec: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.async.AsyncConnectExec: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} acquiring connection with route {}", v, v);
label:
v = new org.apache.hc.client.http.impl.async.AsyncConnectExec$1;
specialinvoke v.<org.apache.hc.client.http.impl.async.AsyncConnectExec$1: void <init>(org.apache.hc.client.http.impl.async.AsyncConnectExec,org.apache.hc.client.http.async.AsyncExecChain,org.apache.hc.core.http.HttpRequest,org.apache.hc.core.http.nio.AsyncEntityProducer,org.apache.hc.client.http.async.AsyncExecChain$Scope,org.apache.hc.client.http.async.AsyncExecCallback,org.apache.hc.client.http.impl.async.AsyncConnectExec$State)>(v, v, v, v, v, v, v);
v = interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecRuntime: 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)>(v, v, v, v, v);
interfaceinvoke v.<org.apache.hc.core.concurrent.CancellableDependency: void setDependency(org.apache.hc.core.concurrent.Cancellable)>(v);
goto label;
label:
v = interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecRuntime: boolean isEndpointConnected()>();
if v == 0 goto label;
label:
interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecChain: void proceed(org.apache.hc.core.http.HttpRequest,org.apache.hc.core.http.nio.AsyncEntityProducer,org.apache.hc.client.http.async.AsyncExecChain$Scope,org.apache.hc.client.http.async.AsyncExecCallback)>(v, v, v, v);
label:
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecCallback: void failed(java.lang.Exception)>(v);
goto label;
label:
specialinvoke v.<org.apache.hc.client.http.impl.async.AsyncConnectExec: void proceedToNextHop(org.apache.hc.client.http.impl.async.AsyncConnectExec$State,org.apache.hc.core.http.HttpRequest,org.apache.hc.core.http.nio.AsyncEntityProducer,org.apache.hc.client.http.async.AsyncExecChain$Scope,org.apache.hc.client.http.async.AsyncExecChain,org.apache.hc.client.http.async.AsyncExecCallback)>(v, v, v, v, v, v);
label:
return;
catch org.apache.hc.core.http.HttpException from label to label with label;
catch java.io.IOException from label to label with label;
}
private void proceedToNextHop(org.apache.hc.client.http.impl.async.AsyncConnectExec$State, org.apache.hc.core.http.HttpRequest, org.apache.hc.core.http.nio.AsyncEntityProducer, org.apache.hc.client.http.async.AsyncExecChain$Scope, org.apache.hc.client.http.async.AsyncExecChain, org.apache.hc.client.http.async.AsyncExecCallback)
{
java.lang.IllegalStateException v;
org.apache.hc.client.http.async.AsyncExecRuntime v;
org.apache.hc.client.http.impl.async.AsyncConnectExec$4 v;
org.apache.hc.client.http.impl.async.AsyncConnectExec$3 v;
org.apache.hc.client.http.impl.async.AsyncConnectExec$2 v;
boolean v, v, v, v;
org.apache.hc.client.http.impl.async.AsyncConnectExec$State v;
org.apache.hc.client.http.async.AsyncExecChain$Scope v;
java.lang.Exception v, v;
org.apache.hc.client.http.RouteTracker v;
org.apache.hc.client.http.impl.async.AsyncConnectExec v;
org.apache.hc.client.http.protocol.HttpClientContext v;
org.apache.hc.core.concurrent.Cancellable v, v;
org.apache.hc.client.http.routing.HttpRouteDirector v;
int v;
java.lang.String v, v, v;
org.apache.hc.client.http.async.AsyncExecCallback v;
org.apache.hc.core.http.HttpException v, v;
org.slf4j.Logger v, v, v, v, v, v;
org.apache.hc.client.http.HttpRoute v, v;
org.apache.hc.core.http.HttpHost v, v;
org.apache.hc.core.http.HttpRequest v;
org.apache.hc.core.http.nio.AsyncEntityProducer v;
org.apache.hc.client.http.async.AsyncExecChain v;
org.apache.hc.core.concurrent.CancellableDependency v;
v := @this: org.apache.hc.client.http.impl.async.AsyncConnectExec;
v := @parameter: org.apache.hc.client.http.impl.async.AsyncConnectExec$State;
v := @parameter: org.apache.hc.core.http.HttpRequest;
v := @parameter: org.apache.hc.core.http.nio.AsyncEntityProducer;
v := @parameter: org.apache.hc.client.http.async.AsyncExecChain$Scope;
v := @parameter: org.apache.hc.client.http.async.AsyncExecChain;
v := @parameter: org.apache.hc.client.http.async.AsyncExecCallback;
v = v.<org.apache.hc.client.http.impl.async.AsyncConnectExec$State: org.apache.hc.client.http.RouteTracker tracker>;
v = v.<org.apache.hc.client.http.async.AsyncExecChain$Scope: java.lang.String exchangeId>;
v = v.<org.apache.hc.client.http.async.AsyncExecChain$Scope: org.apache.hc.client.http.HttpRoute route>;
v = v.<org.apache.hc.client.http.async.AsyncExecChain$Scope: org.apache.hc.client.http.async.AsyncExecRuntime execRuntime>;
v = v.<org.apache.hc.client.http.async.AsyncExecChain$Scope: org.apache.hc.core.concurrent.CancellableDependency cancellableDependency>;
v = v.<org.apache.hc.client.http.async.AsyncExecChain$Scope: org.apache.hc.client.http.protocol.HttpClientContext clientContext>;
label:
v = virtualinvoke v.<org.apache.hc.client.http.RouteTracker: org.apache.hc.client.http.HttpRoute toRoute()>();
v = v.<org.apache.hc.client.http.impl.async.AsyncConnectExec: org.apache.hc.client.http.routing.HttpRouteDirector routeDirector>;
v = interfaceinvoke v.<org.apache.hc.client.http.routing.HttpRouteDirector: int nextStep(org.apache.hc.client.http.RouteInfo,org.apache.hc.client.http.RouteInfo)>(v, v);
tableswitch(v)
{
case -1: goto label;
case 0: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
default: goto label;
};
label:
v = new org.apache.hc.client.http.impl.async.AsyncConnectExec$2;
specialinvoke v.<org.apache.hc.client.http.impl.async.AsyncConnectExec$2: void <init>(org.apache.hc.client.http.impl.async.AsyncConnectExec,org.apache.hc.client.http.RouteTracker,org.apache.hc.client.http.HttpRoute,java.lang.String,org.apache.hc.client.http.impl.async.AsyncConnectExec$State,org.apache.hc.core.http.HttpRequest,org.apache.hc.core.http.nio.AsyncEntityProducer,org.apache.hc.client.http.async.AsyncExecChain$Scope,org.apache.hc.client.http.async.AsyncExecChain,org.apache.hc.client.http.async.AsyncExecCallback)>(v, v, v, v, v, v, v, v, v, v);
v = interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecRuntime: org.apache.hc.core.concurrent.Cancellable connectEndpoint(org.apache.hc.client.http.protocol.HttpClientContext,org.apache.hc.core.concurrent.FutureCallback)>(v, v);
interfaceinvoke v.<org.apache.hc.core.concurrent.CancellableDependency: void setDependency(org.apache.hc.core.concurrent.Cancellable)>(v);
return;
label:
v = new org.apache.hc.client.http.impl.async.AsyncConnectExec$3;
specialinvoke v.<org.apache.hc.client.http.impl.async.AsyncConnectExec$3: void <init>(org.apache.hc.client.http.impl.async.AsyncConnectExec,org.apache.hc.client.http.HttpRoute,org.apache.hc.client.http.RouteTracker,java.lang.String,org.apache.hc.client.http.impl.async.AsyncConnectExec$State,org.apache.hc.core.http.HttpRequest,org.apache.hc.core.http.nio.AsyncEntityProducer,org.apache.hc.client.http.async.AsyncExecChain$Scope,org.apache.hc.client.http.async.AsyncExecChain,org.apache.hc.client.http.async.AsyncExecCallback)>(v, v, v, v, v, v, v, v, v, v);
v = interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecRuntime: org.apache.hc.core.concurrent.Cancellable connectEndpoint(org.apache.hc.client.http.protocol.HttpClientContext,org.apache.hc.core.concurrent.FutureCallback)>(v, v);
interfaceinvoke v.<org.apache.hc.core.concurrent.CancellableDependency: void setDependency(org.apache.hc.core.concurrent.Cancellable)>(v);
return;
label:
v = virtualinvoke v.<org.apache.hc.client.http.HttpRoute: org.apache.hc.core.http.HttpHost getProxyHost()>();
v = virtualinvoke v.<org.apache.hc.client.http.HttpRoute: org.apache.hc.core.http.HttpHost getTargetHost()>();
v = <org.apache.hc.client.http.impl.async.AsyncConnectExec: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.async.AsyncConnectExec: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} create tunnel", v);
label:
v = new org.apache.hc.client.http.impl.async.AsyncConnectExec$4;
specialinvoke v.<org.apache.hc.client.http.impl.async.AsyncConnectExec$4: void <init>(org.apache.hc.client.http.impl.async.AsyncConnectExec,org.apache.hc.client.http.async.AsyncExecCallback,org.apache.hc.client.http.async.AsyncExecRuntime,java.lang.String,org.apache.hc.client.http.impl.async.AsyncConnectExec$State,org.apache.hc.core.http.HttpRequest,org.apache.hc.core.http.nio.AsyncEntityProducer,org.apache.hc.client.http.async.AsyncExecChain$Scope,org.apache.hc.client.http.async.AsyncExecChain,org.apache.hc.client.http.RouteTracker)>(v, v, v, v, v, v, v, v, v, v);
specialinvoke v.<org.apache.hc.client.http.impl.async.AsyncConnectExec: void createTunnel(org.apache.hc.client.http.impl.async.AsyncConnectExec$State,org.apache.hc.core.http.HttpHost,org.apache.hc.core.http.HttpHost,org.apache.hc.client.http.async.AsyncExecChain$Scope,org.apache.hc.client.http.async.AsyncExecChain,org.apache.hc.client.http.async.AsyncExecCallback)>(v, v, v, v, v, v);
label:
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecCallback: void failed(java.lang.Exception)>(v);
label:
return;
label:
v = new org.apache.hc.core.http.HttpException;
specialinvoke v.<org.apache.hc.core.http.HttpException: void <init>(java.lang.String)>("Proxy chains are not supported");
interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecCallback: void failed(java.lang.Exception)>(v);
return;
label:
interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecRuntime: void upgradeTls(org.apache.hc.client.http.protocol.HttpClientContext)>(v);
v = <org.apache.hc.client.http.impl.async.AsyncConnectExec: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.async.AsyncConnectExec: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} upgraded to TLS", v);
label:
v = virtualinvoke v.<org.apache.hc.client.http.HttpRoute: boolean isSecure()>();
virtualinvoke v.<org.apache.hc.client.http.RouteTracker: void layerProtocol(boolean)>(v);
goto label;
label:
v = new org.apache.hc.core.http.HttpException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hc.client.http.HttpRoute,org.apache.hc.client.http.HttpRoute)>(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[])>("Unable to establish route: planned = \u; current = \u0001");
specialinvoke v.<org.apache.hc.core.http.HttpException: void <init>(java.lang.String)>(v);
interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecCallback: void failed(java.lang.Exception)>(v);
return;
label:
v = <org.apache.hc.client.http.impl.async.AsyncConnectExec: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.async.AsyncConnectExec: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} route fully established", v);
label:
interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecChain: void proceed(org.apache.hc.core.http.HttpRequest,org.apache.hc.core.http.nio.AsyncEntityProducer,org.apache.hc.client.http.async.AsyncExecChain$Scope,org.apache.hc.client.http.async.AsyncExecCallback)>(v, v, v, v);
label:
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecCallback: void failed(java.lang.Exception)>(v);
goto label;
label:
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("Unknown step indicator \u from RouteDirector.");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
if v > 0 goto label;
return;
catch org.apache.hc.core.http.HttpException from label to label with label;
catch java.io.IOException 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;
}
private void createTunnel(org.apache.hc.client.http.impl.async.AsyncConnectExec$State, org.apache.hc.core.http.HttpHost, org.apache.hc.core.http.HttpHost, org.apache.hc.client.http.async.AsyncExecChain$Scope, org.apache.hc.client.http.async.AsyncExecChain, org.apache.hc.client.http.async.AsyncExecCallback) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.client.http.protocol.HttpClientContext v;
org.apache.hc.core.http.protocol.HttpProcessor v;
org.apache.hc.client.http.async.AsyncExecRuntime v;
org.apache.hc.client.http.impl.async.AsyncConnectExec$5 v;
org.apache.hc.core.http.HttpVersion v;
org.apache.hc.client.http.auth.AuthExchange v;
java.lang.String v;
org.apache.hc.client.http.async.AsyncExecCallback v;
org.apache.hc.core.http.message.BasicHttpRequest v;
org.apache.hc.client.http.impl.async.AsyncConnectExec$State v;
org.apache.hc.client.http.async.AsyncExecChain$Scope v;
org.apache.hc.client.http.impl.auth.HttpAuthenticator v;
org.apache.hc.core.http.HttpHost v, v;
org.apache.hc.client.http.auth.ChallengeType v;
org.apache.hc.client.http.async.AsyncExecChain v;
org.apache.hc.core.http.Method v;
org.apache.hc.client.http.impl.async.AsyncConnectExec v;
v := @this: org.apache.hc.client.http.impl.async.AsyncConnectExec;
v := @parameter: org.apache.hc.client.http.impl.async.AsyncConnectExec$State;
v := @parameter: org.apache.hc.core.http.HttpHost;
v := @parameter: org.apache.hc.core.http.HttpHost;
v := @parameter: org.apache.hc.client.http.async.AsyncExecChain$Scope;
v := @parameter: org.apache.hc.client.http.async.AsyncExecChain;
v := @parameter: org.apache.hc.client.http.async.AsyncExecCallback;
v = v.<org.apache.hc.client.http.async.AsyncExecChain$Scope: org.apache.hc.client.http.async.AsyncExecRuntime execRuntime>;
v = v.<org.apache.hc.client.http.async.AsyncExecChain$Scope: org.apache.hc.client.http.protocol.HttpClientContext clientContext>;
if v == null goto label;
v = virtualinvoke v.<org.apache.hc.client.http.protocol.HttpClientContext: org.apache.hc.client.http.auth.AuthExchange getAuthExchange(org.apache.hc.core.http.HttpHost)>(v);
goto label;
label:
v = new org.apache.hc.client.http.auth.AuthExchange;
specialinvoke v.<org.apache.hc.client.http.auth.AuthExchange: void <init>()>();
label:
v = new org.apache.hc.core.http.message.BasicHttpRequest;
v = <org.apache.hc.core.http.Method: org.apache.hc.core.http.Method CONNECT>;
v = virtualinvoke v.<org.apache.hc.core.http.HttpHost: java.lang.String toHostString()>();
specialinvoke v.<org.apache.hc.core.http.message.BasicHttpRequest: void <init>(org.apache.hc.core.http.Method,org.apache.hc.core.http.HttpHost,java.lang.String)>(v, v, v);
v = <org.apache.hc.core.http.HttpVersion: org.apache.hc.core.http.HttpVersion HTTP_1_1>;
interfaceinvoke v.<org.apache.hc.core.http.HttpRequest: void setVersion(org.apache.hc.core.http.ProtocolVersion)>(v);
v = v.<org.apache.hc.client.http.impl.async.AsyncConnectExec: org.apache.hc.core.http.protocol.HttpProcessor proxyHttpProcessor>;
interfaceinvoke v.<org.apache.hc.core.http.protocol.HttpProcessor: void process(org.apache.hc.core.http.HttpRequest,org.apache.hc.core.http.EntityDetails,org.apache.hc.core.http.protocol.HttpContext)>(v, null, v);
v = v.<org.apache.hc.client.http.impl.async.AsyncConnectExec: org.apache.hc.client.http.impl.auth.HttpAuthenticator authenticator>;
v = <org.apache.hc.client.http.auth.ChallengeType: org.apache.hc.client.http.auth.ChallengeType PROXY>;
virtualinvoke v.<org.apache.hc.client.http.impl.auth.HttpAuthenticator: void addAuthResponse(org.apache.hc.core.http.HttpHost,org.apache.hc.client.http.auth.ChallengeType,org.apache.hc.core.http.HttpRequest,org.apache.hc.client.http.auth.AuthExchange,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v, v, v);
v = new org.apache.hc.client.http.impl.async.AsyncConnectExec$5;
specialinvoke v.<org.apache.hc.client.http.impl.async.AsyncConnectExec$5: void <init>(org.apache.hc.client.http.impl.async.AsyncConnectExec,org.apache.hc.client.http.protocol.HttpClientContext,org.apache.hc.client.http.auth.AuthExchange,org.apache.hc.core.http.HttpHost,org.apache.hc.client.http.impl.async.AsyncConnectExec$State,org.apache.hc.client.http.async.AsyncExecCallback)>(v, v, v, v, v, v);
interfaceinvoke v.<org.apache.hc.client.http.async.AsyncExecChain: void proceed(org.apache.hc.core.http.HttpRequest,org.apache.hc.core.http.nio.AsyncEntityProducer,org.apache.hc.client.http.async.AsyncExecChain$Scope,org.apache.hc.client.http.async.AsyncExecCallback)>(v, null, v, v);
return;
}
private boolean needAuthentication(org.apache.hc.client.http.auth.AuthExchange, org.apache.hc.core.http.HttpHost, org.apache.hc.core.http.HttpResponse, org.apache.hc.client.http.protocol.HttpClientContext)
{
org.apache.hc.client.http.protocol.HttpClientContext v;
org.apache.hc.client.http.AuthenticationStrategy v;
org.apache.hc.client.http.impl.auth.HttpAuthenticator v, v;
org.apache.hc.core.http.HttpHost v;
org.apache.hc.client.http.auth.ChallengeType v, v;
org.apache.hc.client.http.auth.AuthExchange v;
org.apache.hc.core.http.HttpResponse v;
org.apache.hc.client.http.config.RequestConfig v;
org.apache.hc.client.http.impl.async.AsyncConnectExec v;
boolean v, v, v;
v := @this: org.apache.hc.client.http.impl.async.AsyncConnectExec;
v := @parameter: org.apache.hc.client.http.auth.AuthExchange;
v := @parameter: org.apache.hc.core.http.HttpHost;
v := @parameter: org.apache.hc.core.http.HttpResponse;
v := @parameter: org.apache.hc.client.http.protocol.HttpClientContext;
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 isAuthenticationEnabled()>();
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.AsyncConnectExec: org.apache.hc.client.http.impl.auth.HttpAuthenticator authenticator>;
v = <org.apache.hc.client.http.auth.ChallengeType: org.apache.hc.client.http.auth.ChallengeType PROXY>;
v = virtualinvoke v.<org.apache.hc.client.http.impl.auth.HttpAuthenticator: boolean isChallenged(org.apache.hc.core.http.HttpHost,org.apache.hc.client.http.auth.ChallengeType,org.apache.hc.core.http.HttpResponse,org.apache.hc.client.http.auth.AuthExchange,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v, v, v);
if v == 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.AsyncConnectExec: org.apache.hc.client.http.impl.auth.HttpAuthenticator authenticator>;
v = <org.apache.hc.client.http.auth.ChallengeType: org.apache.hc.client.http.auth.ChallengeType PROXY>;
v = v.<org.apache.hc.client.http.impl.async.AsyncConnectExec: org.apache.hc.client.http.AuthenticationStrategy proxyAuthStrategy>;
v = virtualinvoke v.<org.apache.hc.client.http.impl.auth.HttpAuthenticator: boolean updateAuthState(org.apache.hc.core.http.HttpHost,org.apache.hc.client.http.auth.ChallengeType,org.apache.hc.core.http.HttpResponse,org.apache.hc.client.http.AuthenticationStrategy,org.apache.hc.client.http.auth.AuthExchange,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v, v, v, v);
return v;
label:
return 0;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hc/client5/http/impl/async/AsyncConnectExec;");
<org.apache.hc.client.http.impl.async.AsyncConnectExec: org.slf4j.Logger LOG> = v;
return;
}
}