final class org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler extends java.lang.Object implements org.apache.hc.core.http.nio.AsyncClientExchangeHandler, org.apache.hc.core.util.Identifiable
{
private final org.slf4j.Logger log;
private final java.lang.String exchangeId;
private final org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler;
void <init>(org.slf4j.Logger, java.lang.String, org.apache.hc.core.http.nio.AsyncClientExchangeHandler)
{
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
org.slf4j.Logger v;
java.lang.String v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v := @parameter: org.slf4j.Logger;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hc.core.http.nio.AsyncClientExchangeHandler;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.slf4j.Logger log> = v;
v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: java.lang.String exchangeId> = v;
v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler> = v;
return;
}
public java.lang.String getId()
{
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
java.lang.String v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: java.lang.String exchangeId>;
return v;
}
public void releaseResources()
{
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void releaseResources()>();
return;
}
public void produceRequest(org.apache.hc.core.http.nio.RequestChannel, org.apache.hc.core.http.protocol.HttpContext) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
org.apache.hc.core.http.protocol.HttpContext v;
org.apache.hc.core.http.nio.RequestChannel v;
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler$1 v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v := @parameter: org.apache.hc.core.http.nio.RequestChannel;
v := @parameter: org.apache.hc.core.http.protocol.HttpContext;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler>;
v = new org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler$1;
specialinvoke v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler$1: void <init>(org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler,org.apache.hc.core.http.nio.RequestChannel)>(v, v);
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void produceRequest(org.apache.hc.core.http.nio.RequestChannel,org.apache.hc.core.http.protocol.HttpContext)>(v, v);
return;
}
public int available()
{
int v;
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler>;
v = interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: int available()>();
return v;
}
public void produce(org.apache.hc.core.http.nio.DataStreamChannel) throws java.io.IOException
{
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
org.slf4j.Logger v, v;
org.apache.hc.core.http.nio.DataStreamChannel v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
java.lang.String v;
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler$2 v;
boolean v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v := @parameter: org.apache.hc.core.http.nio.DataStreamChannel;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: 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.LoggingAsyncClientExchangeHandler: org.slf4j.Logger log>;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: java.lang.String exchangeId>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} produce request data", v);
label:
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler>;
v = new org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler$2;
specialinvoke v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler$2: void <init>(org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler,org.apache.hc.core.http.nio.DataStreamChannel)>(v, v);
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void produce(org.apache.hc.core.http.nio.DataStreamChannel)>(v);
return;
}
public void consumeInformation(org.apache.hc.core.http.HttpResponse, org.apache.hc.core.http.protocol.HttpContext) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
org.slf4j.Logger v, v;
org.apache.hc.core.http.protocol.HttpContext v;
org.apache.hc.core.http.message.StatusLine v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
org.apache.hc.core.http.HttpResponse v;
java.lang.String v;
boolean v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v := @parameter: org.apache.hc.core.http.HttpResponse;
v := @parameter: org.apache.hc.core.http.protocol.HttpContext;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: 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.LoggingAsyncClientExchangeHandler: org.slf4j.Logger log>;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: java.lang.String exchangeId>;
v = new org.apache.hc.core.http.message.StatusLine;
specialinvoke v.<org.apache.hc.core.http.message.StatusLine: void <init>(org.apache.hc.core.http.HttpResponse)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} information response {}", v, v);
label:
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void consumeInformation(org.apache.hc.core.http.HttpResponse,org.apache.hc.core.http.protocol.HttpContext)>(v, v);
return;
}
public void consumeResponse(org.apache.hc.core.http.HttpResponse, org.apache.hc.core.http.EntityDetails, org.apache.hc.core.http.protocol.HttpContext) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
java.lang.Object[] v;
org.slf4j.Logger v, v;
org.apache.hc.core.http.protocol.HttpContext v;
long v;
org.apache.hc.core.http.EntityDetails v;
org.apache.hc.core.http.message.StatusLine v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
org.apache.hc.core.http.HttpResponse v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v := @parameter: org.apache.hc.core.http.HttpResponse;
v := @parameter: org.apache.hc.core.http.EntityDetails;
v := @parameter: org.apache.hc.core.http.protocol.HttpContext;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: 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.LoggingAsyncClientExchangeHandler: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: java.lang.String exchangeId>;
v[0] = v;
v = new org.apache.hc.core.http.message.StatusLine;
specialinvoke v.<org.apache.hc.core.http.message.StatusLine: void <init>(org.apache.hc.core.http.HttpResponse)>(v);
v[1] = v;
if v == null goto label;
v = interfaceinvoke v.<org.apache.hc.core.http.EntityDetails: long getContentLength()>();
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[])>("entity len \u0001");
goto label;
label:
v = " null entity";
label:
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("{} consume response {}, {}", v);
label:
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void consumeResponse(org.apache.hc.core.http.HttpResponse,org.apache.hc.core.http.EntityDetails,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v);
return;
}
public void updateCapacity(org.apache.hc.core.http.nio.CapacityChannel) throws java.io.IOException
{
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
org.apache.hc.core.http.nio.CapacityChannel v;
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler$3 v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v := @parameter: org.apache.hc.core.http.nio.CapacityChannel;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler>;
v = new org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler$3;
specialinvoke v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler$3: void <init>(org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler,org.apache.hc.core.http.nio.CapacityChannel)>(v, v);
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void updateCapacity(org.apache.hc.core.http.nio.CapacityChannel)>(v);
return;
}
public void consume(java.nio.ByteBuffer) throws java.io.IOException
{
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
org.slf4j.Logger v, v;
java.lang.Integer v;
java.nio.ByteBuffer v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
int v;
java.lang.String v;
boolean v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v := @parameter: java.nio.ByteBuffer;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: 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.LoggingAsyncClientExchangeHandler: org.slf4j.Logger log>;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: java.lang.String exchangeId>;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} consume response data, len {} bytes", v, v);
label:
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void consume(java.nio.ByteBuffer)>(v);
return;
}
public void streamEnd(java.util.List) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
java.util.List v;
org.slf4j.Logger v, v;
java.lang.String v;
boolean v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v := @parameter: java.util.List;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: 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.LoggingAsyncClientExchangeHandler: org.slf4j.Logger log>;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: java.lang.String exchangeId>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} end of response data", v);
label:
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void streamEnd(java.util.List)>(v);
return;
}
public void failed(java.lang.Exception)
{
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
org.slf4j.Logger v, v;
java.lang.Exception v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v := @parameter: java.lang.Exception;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: 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.LoggingAsyncClientExchangeHandler: org.slf4j.Logger log>;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: java.lang.String exchangeId>;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} execution failed: {}", v, v);
label:
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void failed(java.lang.Exception)>(v);
return;
}
public void cancel()
{
org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
org.slf4j.Logger v, v;
java.lang.String v;
boolean v;
v := @this: org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: 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.LoggingAsyncClientExchangeHandler: org.slf4j.Logger log>;
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: java.lang.String exchangeId>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} execution cancelled", v);
label:
v = v.<org.apache.hc.client.http.impl.async.LoggingAsyncClientExchangeHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler handler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void cancel()>();
return;
}
}