class org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler extends java.lang.Object implements org.apache.hc.core.http.impl.nio.H2StreamHandler
{
private final org.apache.hc.core.http.impl.nio.H2StreamChannel internalOutputChannel;
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.HandlerFactory pushHandlerFactory;
private final org.apache.hc.core.http.protocol.HttpCoreContext context;
private final java.util.concurrent.atomic.AtomicBoolean failed;
private final java.util.concurrent.atomic.AtomicBoolean done;
private volatile org.apache.hc.core.http.HttpRequest request;
private volatile org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler;
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.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;
org.apache.hc.core.http.impl.BasicHttpConnectionMetrics 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.ClientPushH2StreamHandler v;
org.apache.hc.core.http.impl.nio.MessageState v, v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
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.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.ClientPushH2StreamHandler: org.apache.hc.core.http.impl.nio.H2StreamChannel internalOutputChannel> = v;
v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor> = v;
v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.impl.BasicHttpConnectionMetrics connMetrics> = v;
v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.HandlerFactory pushHandlerFactory> = v;
v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: 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.ClientPushH2StreamHandler: 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.ClientPushH2StreamHandler: 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.ClientPushH2StreamHandler: 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.ClientPushH2StreamHandler: 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.nio.HandlerFactory v;
org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.HandlerFactory pushHandlerFactory>;
return v;
}
public boolean isOutputReady()
{
org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
return 0;
}
public void produceOutput() throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
return;
}
public void consumePromise(java.util.List) 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.impl.DefaultH2RequestConverter v;
org.apache.hc.core.http.H2ConnectionException v;
org.apache.hc.core.http.H2Error v, v, v;
org.apache.hc.core.http.impl.BasicHttpConnectionMetrics v;
org.apache.hc.core.http.protocol.HttpProcessor v;
org.apache.hc.core.http.HttpVersion v;
java.lang.String v;
org.apache.hc.core.http.impl.nio.MessageState v, v, v;
org.apache.hc.core.http.nio.HandlerFactory v, v;
org.apache.hc.core.http.ProtocolException v;
org.apache.hc.core.http.nio.ResourceHolder v;
java.util.List v;
org.apache.hc.core.http.H2StreamResetException v, v;
org.apache.hc.core.http.HttpRequest v, v, v, v;
org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
v := @parameter: java.util.List;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: 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 HEADERS>;
if v != v goto label;
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: org.apache.hc.core.http.HttpRequest convert(java.util.List)>(v);
v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.HttpRequest request> = v;
label:
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.HandlerFactory pushHandlerFactory>;
if v == null goto label;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.HandlerFactory pushHandlerFactory>;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.HttpRequest request>;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.protocol.HttpCoreContext context>;
v = interfaceinvoke v.<org.apache.hc.core.http.nio.HandlerFactory: org.apache.hc.core.http.nio.ResourceHolder create(org.apache.hc.core.http.HttpRequest,org.apache.hc.core.http.protocol.HttpContext)>(v, v);
goto label;
label:
v = null;
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hc.core.http.H2StreamResetException;
v = <org.apache.hc.core.http.H2Error: org.apache.hc.core.http.H2Error PROTOCOL_ERROR>;
v = virtualinvoke v.<org.apache.hc.core.http.ProtocolException: java.lang.String getMessage()>();
specialinvoke v.<org.apache.hc.core.http.H2StreamResetException: void <init>(org.apache.hc.core.http.H2Error,java.lang.String)>(v, v);
throw v;
label:
if v != null goto label;
v = new org.apache.hc.core.http.H2StreamResetException;
v = <org.apache.hc.core.http.H2Error: org.apache.hc.core.http.H2Error REFUSED_STREAM>;
specialinvoke v.<org.apache.hc.core.http.H2StreamResetException: void <init>(org.apache.hc.core.http.H2Error,java.lang.String)>(v, "Stream refused");
throw v;
label:
v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler> = v;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: 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.ClientPushH2StreamHandler: org.apache.hc.core.http.protocol.HttpCoreContext context>;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.HttpRequest request>;
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.ClientPushH2StreamHandler: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor>;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.HttpRequest request>;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: 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, null, v);
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.impl.BasicHttpConnectionMetrics connMetrics>;
virtualinvoke v.<org.apache.hc.core.http.impl.BasicHttpConnectionMetrics: void incrementRequestCount()>();
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.ClientPushH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState> = 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 PROTOCOL_ERROR>;
specialinvoke v.<org.apache.hc.core.http.H2ConnectionException: void <init>(org.apache.hc.core.http.H2Error,java.lang.String)>(v, "Unexpected promise");
throw v;
label:
return;
catch org.apache.hc.core.http.ProtocolException from label to label with label;
}
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;
org.apache.hc.core.http.impl.BasicHttpConnectionMetrics v;
org.apache.hc.core.http.protocol.HttpProcessor v;
org.apache.hc.core.http.impl.IncomingEntityDetails v;
org.apache.hc.core.http.HttpResponse v;
org.apache.hc.core.http.impl.nio.MessageState v, v, v, v;
boolean v;
org.apache.hc.core.http.nio.AsyncPushConsumer v, v, v;
org.apache.hc.core.http.ProtocolException v;
java.util.List v;
org.apache.hc.core.http.HttpRequest v, v, v;
org.apache.hc.core.http.impl.DefaultH2ResponseConverter v;
org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
v := @parameter: java.util.List;
v := @parameter: boolean;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: 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 HEADERS>;
if v != v goto label;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.HttpRequest request>;
staticinvoke <org.apache.hc.core.util.Asserts: void notNull(java.lang.Object,java.lang.String)>(v, "Request");
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler>;
staticinvoke <org.apache.hc.core.util.Asserts: void notNull(java.lang.Object,java.lang.String)>(v, "Exchange handler");
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);
if v == 0 goto label;
v = null;
goto label;
label:
v = new org.apache.hc.core.http.impl.IncomingEntityDetails;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.HttpRequest request>;
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.ClientPushH2StreamHandler: 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.ClientPushH2StreamHandler: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor>;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: 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.ClientPushH2StreamHandler: 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.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler>;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.HttpRequest request>;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.protocol.HttpCoreContext context>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncPushConsumer: void consumePromise(org.apache.hc.core.http.HttpRequest,org.apache.hc.core.http.HttpResponse,org.apache.hc.core.http.EntityDetails,org.apache.hc.core.http.protocol.HttpContext)>(v, 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>;
v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState responseState> = v;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncPushConsumer: void streamEnd(java.util.List)>(null);
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.ClientPushH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState responseState> = 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.AsyncPushConsumer v, v;
org.apache.hc.core.http.impl.nio.H2StreamChannel v;
org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler>;
staticinvoke <org.apache.hc.core.util.Asserts: void notNull(java.lang.Object,java.lang.String)>(v, "Exchange handler");
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler>;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.impl.nio.H2StreamChannel internalOutputChannel>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncPushConsumer: 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.nio.AsyncPushConsumer v, v, v;
org.apache.hc.core.http.ProtocolException v;
java.nio.ByteBuffer v;
org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler v;
org.apache.hc.core.http.impl.nio.MessageState v, v, v;
boolean v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: boolean;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: 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;
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:
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler>;
staticinvoke <org.apache.hc.core.util.Asserts: void notNull(java.lang.Object,java.lang.String)>(v, "Exchange handler");
if v == null goto label;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncPushConsumer: 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.ClientPushH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState responseState> = v;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncPushConsumer: void streamEnd(java.util.List)>(null);
label:
return;
}
public boolean isDone()
{
org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler v;
org.apache.hc.core.http.impl.nio.MessageState v, v;
boolean v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: 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 COMPLETE>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void failed(java.lang.Exception)
{
java.lang.Throwable v;
org.apache.hc.core.http.nio.AsyncPushConsumer v, v;
org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler v;
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.Exception v;
boolean v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
v := @parameter: java.lang.Exception;
label:
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: 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.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler>;
if v == null goto label;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncPushConsumer: void failed(java.lang.Exception)>(v);
label:
virtualinvoke v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: void releaseResources()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: void releaseResources()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void handle(org.apache.hc.core.http.HttpException, boolean) throws org.apache.hc.core.http.HttpException
{
org.apache.hc.core.http.HttpException v;
boolean v;
org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
v := @parameter: org.apache.hc.core.http.HttpException;
v := @parameter: boolean;
throw v;
}
public void releaseResources()
{
org.apache.hc.core.http.nio.AsyncPushConsumer v, v;
org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hc.core.http.impl.nio.MessageState v, v;
boolean v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: 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.ClientPushH2StreamHandler: 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.ClientPushH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState> = v;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler>;
if v == null goto label;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.nio.AsyncPushConsumer exchangeHandler>;
interfaceinvoke v.<org.apache.hc.core.http.nio.AsyncPushConsumer: void releaseResources()>();
label:
return;
}
public java.lang.String toString()
{
org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler v;
java.lang.String v;
org.apache.hc.core.http.impl.nio.MessageState v, v;
v := @this: org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: org.apache.hc.core.http.impl.nio.MessageState requestState>;
v = v.<org.apache.hc.core.http.impl.nio.ClientPushH2StreamHandler: 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;
}
}