class org.apache.hc.core.http.impl.nio.ClientH2StreamHandler extends java.lang.Object implements org.apache.hc.core.http.impl.nio.H2StreamHandler
{
private final org.apache.hc.core.http.impl.nio.H2StreamChannel outputChannel;
private final org.apache.hc.core.http.nio.DataStreamChannel dataChannel;
private final org.apache.hc.core.http.protocol.HttpProcessor httpProcessor;
private final org.apache.hc.core.http.impl.BasicHttpConnectionMetrics connMetrics;
private final org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler;
private final org.apache.hc.core.http.nio.HandlerFactory pushHandlerFactory;
private final org.apache.hc.core.http.protocol.HttpCoreContext context;
private final java.util.concurrent.atomic.AtomicBoolean requestCommitted;
private final java.util.concurrent.atomic.AtomicBoolean failed;
private final java.util.concurrent.atomic.AtomicBoolean done;
private volatile org.apache.hc.core.http.impl.nio.MessageState requestState;
private volatile org.apache.hc.core.http.impl.nio.MessageState responseState;
void <init>(org.apache.hc.core.http.impl.nio.H2StreamChannel, org.apache.hc.core.http.protocol.HttpProcessor, org.apache.hc.core.http.impl.BasicHttpConnectionMetrics, org.apache.hc.core.http.nio.AsyncClientExchangeHandler, org.apache.hc.core.http.nio.HandlerFactory, org.apache.hc.core.http.protocol.HttpCoreContext)
{
org.apache.hc.core.http.protocol.HttpCoreContext v;
org.apache.hc.core.http.nio.HandlerFactory v;
java.util.concurrent.atomic.AtomicBoolean v, v, v;
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
org.apache.hc.core.http.impl.BasicHttpConnectionMetrics v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
org.apache.hc.core.http.protocol.HttpProcessor v;
org.apache.hc.core.http.impl.nio.H2StreamChannel v;
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler$1 v;
org.apache.hc.core.http.impl.nio.MessageState v, v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v := @parameter: org.apache.hc.core.http.impl.nio.H2StreamChannel;
v := @parameter: org.apache.hc.core.http.protocol.HttpProcessor;
v := @parameter: org.apache.hc.core.http.impl.BasicHttpConnectionMetrics;
v := @parameter: org.apache.hc.core.http.nio.AsyncClientExchangeHandler;
v := @parameter: org.apache.hc.core.http.nio.HandlerFactory;
v := @parameter: org.apache.hc.core.http.protocol.HttpCoreContext;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.H2StreamChannel outputChannel> = v;
v = new org.apache.hc.core.http.impl.nio.ClientH2StreamHandler$1;
specialinvoke v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler$1: void <init>(org.apache.hc.core.http.impl.nio.ClientH2StreamHandler,org.apache.hc.core.http.impl.nio.H2StreamChannel)>(v, v);
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.DataStreamChannel dataChannel> = v;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor> = v;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.BasicHttpConnectionMetrics connMetrics> = v;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler> = v;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.HandlerFactory pushHandlerFactory> = v;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.protocol.HttpCoreContext context> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: java.util.concurrent.atomic.AtomicBoolean requestCommitted> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: java.util.concurrent.atomic.AtomicBoolean failed> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: java.util.concurrent.atomic.AtomicBoolean done> = v;
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState HEADERS>;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState> = v;
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState HEADERS>;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState responseState> = v;
return;
}
public org.apache.hc.core.http.nio.HandlerFactory getPushHandlerFactory()
{
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
org.apache.hc.core.http.nio.HandlerFactory v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.HandlerFactory pushHandlerFactory>;
return v;
}
public boolean isOutputReady()
{
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
int[] v;
int v, v, v;
org.apache.hc.core.http.impl.nio.MessageState v;
boolean v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v = <org.apache.hc.core.http.impl.nio.ClientH2StreamHandler$3: int[] $SwitchMap$org$apache$hc$core5$http$impl$nio$MessageState>;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState>;
v = virtualinvoke v.<org.apache.hc.core.http.impl.nio.MessageState: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
return 1;
label:
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
v = interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: int available()>();
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
label:
return 0;
}
private void commitRequest(org.apache.hc.core.http.HttpRequest, org.apache.hc.core.http.EntityDetails) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.core.http.protocol.HttpCoreContext v, v, v;
org.apache.hc.core.http.impl.DefaultH2RequestConverter v;
org.apache.hc.core.http.H2ConnectionException v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hc.core.http.H2Error v;
org.apache.hc.core.http.impl.BasicHttpConnectionMetrics v;
org.apache.hc.core.http.EntityDetails v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
org.apache.hc.core.http.protocol.HttpProcessor v;
org.apache.hc.core.http.HttpVersion v;
java.lang.String v, v;
org.apache.hc.core.http.impl.nio.MessageState v, v, v;
boolean v, v, v, v;
org.apache.hc.core.http.nio.DataStreamChannel v;
org.apache.hc.core.http.Header v;
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
java.util.List v;
org.apache.hc.core.http.impl.nio.H2StreamChannel v;
org.apache.hc.core.http.HttpRequest v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v := @parameter: org.apache.hc.core.http.HttpRequest;
v := @parameter: org.apache.hc.core.http.EntityDetails;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: java.util.concurrent.atomic.AtomicBoolean requestCommitted>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.protocol.HttpCoreContext context>;
v = <org.apache.hc.core.http.HttpVersion: org.apache.hc.core.http.HttpVersion HTTP_2>;
virtualinvoke v.<org.apache.hc.core.http.protocol.HttpCoreContext: void setProtocolVersion(org.apache.hc.core.http.ProtocolVersion)>(v);
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.protocol.HttpCoreContext context>;
virtualinvoke v.<org.apache.hc.core.http.protocol.HttpCoreContext: java.lang.Object setAttribute(java.lang.String,java.lang.Object)>("http.request", v);
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor>;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.protocol.HttpCoreContext context>;
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, v, v);
v = <org.apache.hc.core.http.impl.DefaultH2RequestConverter: org.apache.hc.core.http.impl.DefaultH2RequestConverter INSTANCE>;
v = virtualinvoke v.<org.apache.hc.core.http.impl.DefaultH2RequestConverter: java.util.List convert(org.apache.hc.core.http.HttpRequest)>(v);
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.H2StreamChannel outputChannel>;
if v != null goto label;
v = 1;
goto label;
label:
v = 0;
label:
interfaceinvoke v.<org.apache.hc.core.http.impl.nio.H2StreamChannel: void submit(java.util.List,boolean)>(v, v);
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.BasicHttpConnectionMetrics connMetrics>;
virtualinvoke v.<org.apache.hc.core.http.impl.BasicHttpConnectionMetrics: void incrementRequestCount()>();
if v != null goto label;
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState COMPLETE>;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState> = v;
goto label;
label:
v = interfaceinvoke v.<org.apache.hc.core.http.HttpRequest: org.apache.hc.core.http.Header getFirstHeader(java.lang.String)>("Expect");
if v == null goto label;
v = "100-continue";
v = interfaceinvoke v.<org.apache.hc.core.http.Header: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v == 0 goto label;
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState ACK>;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState> = v;
goto label;
label:
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState BODY>;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState> = v;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.DataStreamChannel dataChannel>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void produce(org.apache.hc.core.http.nio.DataStreamChannel)>(v);
goto label;
label:
v = new org.apache.hc.core.http.H2ConnectionException;
v = <org.apache.hc.core.http.H2Error: org.apache.hc.core.http.H2Error INTERNAL_ERROR>;
specialinvoke v.<org.apache.hc.core.http.H2ConnectionException: void <init>(org.apache.hc.core.http.H2Error,java.lang.String)>(v, "Request already committed");
throw v;
label:
return;
}
public void produceOutput() throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.core.http.protocol.HttpCoreContext v;
org.apache.hc.core.http.nio.DataStreamChannel v;
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v, v;
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler$2 v;
int[] v;
int v, v;
org.apache.hc.core.http.impl.nio.MessageState v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v = <org.apache.hc.core.http.impl.nio.ClientH2StreamHandler$3: int[] $SwitchMap$org$apache$hc$core5$http$impl$nio$MessageState>;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState>;
v = virtualinvoke v.<org.apache.hc.core.http.impl.nio.MessageState: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
v = new org.apache.hc.core.http.impl.nio.ClientH2StreamHandler$2;
specialinvoke v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler$2: void <init>(org.apache.hc.core.http.impl.nio.ClientH2StreamHandler)>(v);
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.protocol.HttpCoreContext context>;
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);
goto label;
label:
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.DataStreamChannel dataChannel>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void produce(org.apache.hc.core.http.nio.DataStreamChannel)>(v);
label:
return;
}
public void consumePromise(java.util.List) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.core.http.ProtocolException v;
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
java.util.List v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v := @parameter: java.util.List;
v = new org.apache.hc.core.http.ProtocolException;
specialinvoke v.<org.apache.hc.core.http.ProtocolException: void <init>(java.lang.String)>("Unexpected message promise");
throw v;
}
public void consumeHeader(java.util.List, boolean) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.core.http.protocol.HttpCoreContext v, v, v, v;
org.apache.hc.core.http.protocol.HttpProcessor v;
int[] v;
boolean v, v;
org.apache.hc.core.http.nio.DataStreamChannel v;
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
java.util.List v;
org.apache.hc.core.http.impl.DefaultH2ResponseConverter v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hc.core.http.impl.BasicHttpConnectionMetrics v;
org.apache.hc.core.http.message.StatusLine v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v, v, v, v;
org.apache.hc.core.http.impl.IncomingEntityDetails v;
int v, v, v;
org.apache.hc.core.http.HttpResponse v;
java.lang.String v;
org.apache.hc.core.http.impl.nio.MessageState v, v, v, v, v, v;
org.apache.hc.core.http.ProtocolException v, v, v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v := @parameter: java.util.List;
v := @parameter: boolean;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: java.util.concurrent.atomic.AtomicBoolean done>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
v = new org.apache.hc.core.http.ProtocolException;
specialinvoke v.<org.apache.hc.core.http.ProtocolException: void <init>(java.lang.String)>("Unexpected message headers");
throw v;
label:
v = <org.apache.hc.core.http.impl.nio.ClientH2StreamHandler$3: int[] $SwitchMap$org$apache$hc$core5$http$impl$nio$MessageState>;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState responseState>;
v = virtualinvoke v.<org.apache.hc.core.http.impl.nio.MessageState: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = <org.apache.hc.core.http.impl.DefaultH2ResponseConverter: org.apache.hc.core.http.impl.DefaultH2ResponseConverter INSTANCE>;
v = virtualinvoke v.<org.apache.hc.core.http.impl.DefaultH2ResponseConverter: org.apache.hc.core.http.HttpResponse convert(java.util.List)>(v);
v = interfaceinvoke v.<org.apache.hc.core.http.HttpResponse: int getCode()>();
if v >= 100 goto label;
v = new org.apache.hc.core.http.ProtocolException;
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 = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hc.core.http.message.StatusLine)>(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[])>("Invalid response: \u0001");
specialinvoke v.<org.apache.hc.core.http.ProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
if v <= 100 goto label;
if v >= 200 goto label;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.protocol.HttpCoreContext context>;
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);
label:
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState>;
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState ACK>;
if v != v goto label;
if v == 100 goto label;
if v < 200 goto label;
label:
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState BODY>;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState> = v;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.DataStreamChannel dataChannel>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void produce(org.apache.hc.core.http.nio.DataStreamChannel)>(v);
label:
if v >= 200 goto label;
return;
label:
if v == 0 goto label;
v = null;
goto label;
label:
v = new org.apache.hc.core.http.impl.IncomingEntityDetails;
specialinvoke v.<org.apache.hc.core.http.impl.IncomingEntityDetails: void <init>(org.apache.hc.core.http.MessageHeaders,long)>(v, -1L);
label:
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.protocol.HttpCoreContext context>;
virtualinvoke v.<org.apache.hc.core.http.protocol.HttpCoreContext: java.lang.Object setAttribute(java.lang.String,java.lang.Object)>("http.response", v);
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor>;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.protocol.HttpCoreContext context>;
interfaceinvoke v.<org.apache.hc.core.http.protocol.HttpProcessor: void process(org.apache.hc.core.http.HttpResponse,org.apache.hc.core.http.EntityDetails,org.apache.hc.core.http.protocol.HttpContext)>(v, v, v);
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.BasicHttpConnectionMetrics connMetrics>;
virtualinvoke v.<org.apache.hc.core.http.impl.BasicHttpConnectionMetrics: void incrementResponseCount()>();
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.protocol.HttpCoreContext context>;
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);
if v == 0 goto label;
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState COMPLETE>;
goto label;
label:
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState BODY>;
label:
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState responseState> = v;
goto label;
label:
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState COMPLETE>;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState responseState> = v;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void streamEnd(java.util.List)>(v);
goto label;
label:
v = new org.apache.hc.core.http.ProtocolException;
specialinvoke v.<org.apache.hc.core.http.ProtocolException: void <init>(java.lang.String)>("Unexpected message headers");
throw v;
label:
return;
}
public void updateInputCapacity() throws java.io.IOException
{
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
org.apache.hc.core.http.impl.nio.H2StreamChannel v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.H2StreamChannel outputChannel>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void updateCapacity(org.apache.hc.core.http.nio.CapacityChannel)>(v);
return;
}
public void consumeData(java.nio.ByteBuffer, boolean) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.core.http.ProtocolException v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
java.nio.ByteBuffer v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v, v;
org.apache.hc.core.http.impl.nio.MessageState v, v, v;
boolean v, v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: boolean;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: java.util.concurrent.atomic.AtomicBoolean done>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState responseState>;
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState BODY>;
if v == v goto label;
label:
v = new org.apache.hc.core.http.ProtocolException;
specialinvoke v.<org.apache.hc.core.http.ProtocolException: void <init>(java.lang.String)>("Unexpected message data");
throw v;
label:
if v == null goto label;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void consume(java.nio.ByteBuffer)>(v);
label:
if v == 0 goto label;
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState COMPLETE>;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState responseState> = v;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void streamEnd(java.util.List)>(null);
label:
return;
}
public void handle(org.apache.hc.core.http.HttpException, boolean) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.core.http.HttpException v;
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
boolean v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v := @parameter: org.apache.hc.core.http.HttpException;
v := @parameter: boolean;
throw v;
}
public void failed(java.lang.Exception)
{
java.lang.Throwable v;
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v, v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
java.lang.Exception v;
boolean v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v := @parameter: java.lang.Exception;
label:
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: java.util.concurrent.atomic.AtomicBoolean failed>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
if v == null goto label;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void failed(java.lang.Exception)>(v);
label:
virtualinvoke v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: void releaseResources()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: void releaseResources()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void releaseResources()
{
org.apache.hc.core.http.nio.AsyncClientExchangeHandler v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
org.apache.hc.core.http.impl.nio.MessageState v, v;
boolean v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: java.util.concurrent.atomic.AtomicBoolean done>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState COMPLETE>;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState responseState> = v;
v = <org.apache.hc.core.http.impl.nio.MessageState: org.apache.hc.core.http.impl.nio.MessageState COMPLETE>;
v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState> = v;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.nio.AsyncClientExchangeHandler exchangeHandler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncClientExchangeHandler: void releaseResources()>();
label:
return;
}
public java.lang.String toString()
{
org.apache.hc.core.http.impl.nio.ClientH2StreamHandler v;
java.lang.String v;
org.apache.hc.core.http.impl.nio.MessageState v, v;
v := @this: org.apache.hc.core.http.impl.nio.ClientH2StreamHandler;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState>;
v = v.<org.apache.hc.core.http.impl.nio.ClientH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState responseState>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hc.core.http.impl.nio.MessageState,org.apache.hc.core.http.impl.nio.MessageState)>(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[])>("[requestState=\u, responseState=\u]");
return v;
}
}