public class org.apache.http.impl.client.AutoRetryHttpClient extends java.lang.Object implements org.apache.http.client.HttpClient
{
private final org.apache.http.client.HttpClient backend;
private final org.apache.http.client.ServiceUnavailableRetryStrategy retryStrategy;
private final org.apache.commons.logging.Log log;
public void <init>(org.apache.http.client.HttpClient, org.apache.http.client.ServiceUnavailableRetryStrategy)
{
org.apache.http.impl.client.AutoRetryHttpClient v;
org.apache.http.client.HttpClient v;
java.lang.Class v;
org.apache.commons.logging.Log v;
org.apache.http.client.ServiceUnavailableRetryStrategy v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v := @parameter: org.apache.http.client.HttpClient;
v := @parameter: org.apache.http.client.ServiceUnavailableRetryStrategy;
specialinvoke v.<java.lang.Object: void <init>()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.apache.commons.logging.LogFactory: org.apache.commons.logging.Log getLog(java.lang.Class)>(v);
v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.commons.logging.Log log> = v;
staticinvoke <org.apache.http.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "HttpClient");
staticinvoke <org.apache.http.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "ServiceUnavailableRetryStrategy");
v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.http.client.HttpClient backend> = v;
v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.http.client.ServiceUnavailableRetryStrategy retryStrategy> = v;
return;
}
public void <init>()
{
org.apache.http.impl.client.DefaultHttpClient v;
org.apache.http.impl.client.AutoRetryHttpClient v;
org.apache.http.impl.client.DefaultServiceUnavailableRetryStrategy v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v = new org.apache.http.impl.client.DefaultHttpClient;
specialinvoke v.<org.apache.http.impl.client.DefaultHttpClient: void <init>()>();
v = new org.apache.http.impl.client.DefaultServiceUnavailableRetryStrategy;
specialinvoke v.<org.apache.http.impl.client.DefaultServiceUnavailableRetryStrategy: void <init>()>();
specialinvoke v.<org.apache.http.impl.client.AutoRetryHttpClient: void <init>(org.apache.http.client.HttpClient,org.apache.http.client.ServiceUnavailableRetryStrategy)>(v, v);
return;
}
public void <init>(org.apache.http.client.ServiceUnavailableRetryStrategy)
{
org.apache.http.impl.client.DefaultHttpClient v;
org.apache.http.client.ServiceUnavailableRetryStrategy v;
org.apache.http.impl.client.AutoRetryHttpClient v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v := @parameter: org.apache.http.client.ServiceUnavailableRetryStrategy;
v = new org.apache.http.impl.client.DefaultHttpClient;
specialinvoke v.<org.apache.http.impl.client.DefaultHttpClient: void <init>()>();
specialinvoke v.<org.apache.http.impl.client.AutoRetryHttpClient: void <init>(org.apache.http.client.HttpClient,org.apache.http.client.ServiceUnavailableRetryStrategy)>(v, v);
return;
}
public void <init>(org.apache.http.client.HttpClient)
{
org.apache.http.impl.client.AutoRetryHttpClient v;
org.apache.http.client.HttpClient v;
org.apache.http.impl.client.DefaultServiceUnavailableRetryStrategy v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v := @parameter: org.apache.http.client.HttpClient;
v = new org.apache.http.impl.client.DefaultServiceUnavailableRetryStrategy;
specialinvoke v.<org.apache.http.impl.client.DefaultServiceUnavailableRetryStrategy: void <init>()>();
specialinvoke v.<org.apache.http.impl.client.AutoRetryHttpClient: void <init>(org.apache.http.client.HttpClient,org.apache.http.client.ServiceUnavailableRetryStrategy)>(v, v);
return;
}
public org.apache.http.HttpResponse execute(org.apache.http.HttpHost, org.apache.http.HttpRequest) throws java.io.IOException
{
org.apache.http.impl.client.AutoRetryHttpClient v;
org.apache.http.HttpResponse v;
org.apache.http.HttpHost v;
org.apache.http.HttpRequest v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v := @parameter: org.apache.http.HttpHost;
v := @parameter: org.apache.http.HttpRequest;
v = virtualinvoke v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.http.HttpResponse execute(org.apache.http.HttpHost,org.apache.http.HttpRequest,org.apache.http.protocol.HttpContext)>(v, v, null);
return v;
}
public java.lang.Object execute(org.apache.http.HttpHost, org.apache.http.HttpRequest, org.apache.http.client.ResponseHandler) throws java.io.IOException
{
org.apache.http.impl.client.AutoRetryHttpClient v;
java.lang.Object v;
org.apache.http.client.ResponseHandler v;
org.apache.http.HttpHost v;
org.apache.http.HttpRequest v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v := @parameter: org.apache.http.HttpHost;
v := @parameter: org.apache.http.HttpRequest;
v := @parameter: org.apache.http.client.ResponseHandler;
v = virtualinvoke v.<org.apache.http.impl.client.AutoRetryHttpClient: java.lang.Object execute(org.apache.http.HttpHost,org.apache.http.HttpRequest,org.apache.http.client.ResponseHandler,org.apache.http.protocol.HttpContext)>(v, v, v, null);
return v;
}
public java.lang.Object execute(org.apache.http.HttpHost, org.apache.http.HttpRequest, org.apache.http.client.ResponseHandler, org.apache.http.protocol.HttpContext) throws java.io.IOException
{
org.apache.http.impl.client.AutoRetryHttpClient v;
org.apache.http.protocol.HttpContext v;
org.apache.http.HttpResponse v;
java.lang.Object v;
org.apache.http.client.ResponseHandler v;
org.apache.http.HttpHost v;
org.apache.http.HttpRequest v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v := @parameter: org.apache.http.HttpHost;
v := @parameter: org.apache.http.HttpRequest;
v := @parameter: org.apache.http.client.ResponseHandler;
v := @parameter: org.apache.http.protocol.HttpContext;
v = virtualinvoke v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.http.HttpResponse execute(org.apache.http.HttpHost,org.apache.http.HttpRequest,org.apache.http.protocol.HttpContext)>(v, v, v);
v = interfaceinvoke v.<org.apache.http.client.ResponseHandler: java.lang.Object handleResponse(org.apache.http.HttpResponse)>(v);
return v;
}
public org.apache.http.HttpResponse execute(org.apache.http.client.methods.HttpUriRequest) throws java.io.IOException
{
org.apache.http.HttpResponse v;
org.apache.http.client.methods.HttpUriRequest v;
org.apache.http.impl.client.AutoRetryHttpClient v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v := @parameter: org.apache.http.client.methods.HttpUriRequest;
v = virtualinvoke v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.http.HttpResponse execute(org.apache.http.client.methods.HttpUriRequest,org.apache.http.protocol.HttpContext)>(v, null);
return v;
}
public org.apache.http.HttpResponse execute(org.apache.http.client.methods.HttpUriRequest, org.apache.http.protocol.HttpContext) throws java.io.IOException
{
org.apache.http.impl.client.AutoRetryHttpClient v;
org.apache.http.client.methods.HttpUriRequest v;
org.apache.http.protocol.HttpContext v;
int v;
org.apache.http.HttpResponse v;
java.lang.String v, v;
java.net.URI v;
org.apache.http.HttpHost v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v := @parameter: org.apache.http.client.methods.HttpUriRequest;
v := @parameter: org.apache.http.protocol.HttpContext;
v = interfaceinvoke v.<org.apache.http.client.methods.HttpUriRequest: java.net.URI getURI()>();
v = new org.apache.http.HttpHost;
v = virtualinvoke v.<java.net.URI: java.lang.String getHost()>();
v = virtualinvoke v.<java.net.URI: int getPort()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
specialinvoke v.<org.apache.http.HttpHost: void <init>(java.lang.String,int,java.lang.String)>(v, v, v);
v = virtualinvoke v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.http.HttpResponse execute(org.apache.http.HttpHost,org.apache.http.HttpRequest,org.apache.http.protocol.HttpContext)>(v, v, v);
return v;
}
public java.lang.Object execute(org.apache.http.client.methods.HttpUriRequest, org.apache.http.client.ResponseHandler) throws java.io.IOException
{
org.apache.http.impl.client.AutoRetryHttpClient v;
java.lang.Object v;
org.apache.http.client.methods.HttpUriRequest v;
org.apache.http.client.ResponseHandler v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v := @parameter: org.apache.http.client.methods.HttpUriRequest;
v := @parameter: org.apache.http.client.ResponseHandler;
v = virtualinvoke v.<org.apache.http.impl.client.AutoRetryHttpClient: java.lang.Object execute(org.apache.http.client.methods.HttpUriRequest,org.apache.http.client.ResponseHandler,org.apache.http.protocol.HttpContext)>(v, v, null);
return v;
}
public java.lang.Object execute(org.apache.http.client.methods.HttpUriRequest, org.apache.http.client.ResponseHandler, org.apache.http.protocol.HttpContext) throws java.io.IOException
{
org.apache.http.impl.client.AutoRetryHttpClient v;
org.apache.http.protocol.HttpContext v;
org.apache.http.HttpResponse v;
java.lang.Object v;
org.apache.http.client.methods.HttpUriRequest v;
org.apache.http.client.ResponseHandler v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v := @parameter: org.apache.http.client.methods.HttpUriRequest;
v := @parameter: org.apache.http.client.ResponseHandler;
v := @parameter: org.apache.http.protocol.HttpContext;
v = virtualinvoke v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.http.HttpResponse execute(org.apache.http.client.methods.HttpUriRequest,org.apache.http.protocol.HttpContext)>(v, v);
v = interfaceinvoke v.<org.apache.http.client.ResponseHandler: java.lang.Object handleResponse(org.apache.http.HttpResponse)>(v);
return v;
}
public org.apache.http.HttpResponse execute(org.apache.http.HttpHost, org.apache.http.HttpRequest, org.apache.http.protocol.HttpContext) throws java.io.IOException
{
org.apache.http.impl.client.AutoRetryHttpClient v;
long v;
java.io.InterruptedIOException v;
org.apache.http.client.HttpClient v;
java.lang.Thread v;
int v;
java.lang.String v;
boolean v;
org.apache.http.HttpEntity v, v;
java.io.IOException v;
org.apache.http.client.ServiceUnavailableRetryStrategy v, v;
java.lang.RuntimeException v;
org.apache.http.HttpRequest v;
java.lang.InterruptedException v;
org.apache.http.protocol.HttpContext v;
org.apache.http.HttpResponse v;
org.apache.commons.logging.Log v, v;
org.apache.http.HttpHost v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v := @parameter: org.apache.http.HttpHost;
v := @parameter: org.apache.http.HttpRequest;
v := @parameter: org.apache.http.protocol.HttpContext;
v = 1;
label:
v = v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.http.client.HttpClient backend>;
v = interfaceinvoke v.<org.apache.http.client.HttpClient: org.apache.http.HttpResponse execute(org.apache.http.HttpHost,org.apache.http.HttpRequest,org.apache.http.protocol.HttpContext)>(v, v, v);
label:
v = v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.http.client.ServiceUnavailableRetryStrategy retryStrategy>;
v = interfaceinvoke v.<org.apache.http.client.ServiceUnavailableRetryStrategy: boolean retryRequest(org.apache.http.HttpResponse,int,org.apache.http.protocol.HttpContext)>(v, v, v);
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.HttpEntity getEntity()>();
staticinvoke <org.apache.http.util.EntityUtils: void consume(org.apache.http.HttpEntity)>(v);
v = v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.http.client.ServiceUnavailableRetryStrategy retryStrategy>;
v = interfaceinvoke v.<org.apache.http.client.ServiceUnavailableRetryStrategy: long getRetryInterval()>();
label:
v = v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.commons.logging.Log log>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("Wait for \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void trace(java.lang.Object)>(v);
staticinvoke <java.lang.Thread: void sleep(long)>(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;
specialinvoke v.<java.io.InterruptedIOException: void <init>()>();
throw v;
label:
return v;
label:
v := @caughtexception;
label:
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.HttpEntity getEntity()>();
staticinvoke <org.apache.http.util.EntityUtils: void consume(org.apache.http.HttpEntity)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.commons.logging.Log log>;
interfaceinvoke v.<org.apache.commons.logging.Log: void warn(java.lang.Object,java.lang.Throwable)>("I/O error consuming response content", v);
label:
throw v;
label:
v = v + 1;
goto label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.RuntimeException from label to label with label;
catch java.io.IOException from label to label with label;
}
public org.apache.http.conn.ClientConnectionManager getConnectionManager()
{
org.apache.http.impl.client.AutoRetryHttpClient v;
org.apache.http.client.HttpClient v;
org.apache.http.conn.ClientConnectionManager v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v = v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.http.client.HttpClient backend>;
v = interfaceinvoke v.<org.apache.http.client.HttpClient: org.apache.http.conn.ClientConnectionManager getConnectionManager()>();
return v;
}
public org.apache.http.params.HttpParams getParams()
{
org.apache.http.impl.client.AutoRetryHttpClient v;
org.apache.http.client.HttpClient v;
org.apache.http.params.HttpParams v;
v := @this: org.apache.http.impl.client.AutoRetryHttpClient;
v = v.<org.apache.http.impl.client.AutoRetryHttpClient: org.apache.http.client.HttpClient backend>;
v = interfaceinvoke v.<org.apache.http.client.HttpClient: org.apache.http.params.HttpParams getParams()>();
return v;
}
}