Package org.apache.hc.core5.http2.impl.nio

Class ServerPushH2StreamHandler

java.lang.Object

org.apache.hc.core5.http2.impl.nio.ServerPushH2StreamHandler

All Implemented Interfaces:

ResourceHolder, H2StreamHandler

class ServerPushH2StreamHandler
extends Object
implements H2StreamHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final BasicHttpConnectionMetrics	connMetrics
private final HttpCoreContext	context
private final DataStreamChannel	dataChannel
private final AtomicBoolean	done
private final AtomicBoolean	failed
private final HttpProcessor	httpProcessor
private final H2StreamChannel	outputChannel
private final AsyncPushProducer	pushProducer
private MessageState	requestState
private final AtomicBoolean	responseCommitted
private MessageState	responseState

Constructor Summary

Constructors

Constructor	Description
ServerPushH2StreamHandler(H2StreamChannel outputChannel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, AsyncPushProducer pushProducer, HttpCoreContext context)

Method Summary

Modifier and Type	Method	Description
private void	commitInformation(HttpResponse response)
private void	commitPromise(HttpRequest promise, AsyncPushProducer pushProducer)
private void	commitResponse(HttpResponse response, EntityDetails responseEntityDetails)
void	consumeData(ByteBuffer src, boolean endStream)
void	consumeHeader(List<Header> requestHeaders, boolean requestEndStream)
void	consumePromise(List<Header> headers)
void	failed(Exception cause)
HandlerFactory<AsyncPushConsumer>	getPushHandlerFactory()
void	handle(HttpException ex, boolean endStream)
boolean	isOutputReady()
void	produceOutput()
void	releaseResources()
String	toString()
void	updateInputCapacity()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

outputChannel

private final H2StreamChannel outputChannel

dataChannel

private final DataStreamChannel dataChannel

httpProcessor

private final HttpProcessor httpProcessor

connMetrics

private final BasicHttpConnectionMetrics connMetrics

pushProducer

private final AsyncPushProducer pushProducer

context

private final HttpCoreContext context

responseCommitted

private final AtomicBoolean responseCommitted

failed

private final AtomicBoolean failed

done

private final AtomicBoolean done

requestState

private volatile MessageState requestState

responseState

private volatile MessageState responseState

Constructor Details

ServerPushH2StreamHandler

ServerPushH2StreamHandler(H2StreamChannel outputChannel,
 HttpProcessor httpProcessor,
 BasicHttpConnectionMetrics connMetrics,
 AsyncPushProducer pushProducer,
 HttpCoreContext context)

Method Details

getPushHandlerFactory

public HandlerFactory<AsyncPushConsumer> getPushHandlerFactory()

Specified by:

getPushHandlerFactory in interface H2StreamHandler

consumePromise

public void consumePromise(List<Header> headers)
                    throws HttpException,
IOException

Specified by:

consumePromise in interface H2StreamHandler

Throws:

HttpException

IOException

consumeHeader

public void consumeHeader(List<Header> requestHeaders,
 boolean requestEndStream)
                   throws HttpException,
IOException

Specified by:

consumeHeader in interface H2StreamHandler

Throws:

HttpException

IOException

updateInputCapacity

public void updateInputCapacity()
                         throws IOException

Specified by:

updateInputCapacity in interface H2StreamHandler

Throws:

IOException

consumeData

public void consumeData(ByteBuffer src,
 boolean endStream)
                 throws HttpException,
IOException

Specified by:

consumeData in interface H2StreamHandler

Throws:

HttpException

IOException

isOutputReady

public boolean isOutputReady()

Specified by:

isOutputReady in interface H2StreamHandler

commitInformation

private void commitInformation(HttpResponse response)
                        throws IOException,
HttpException

Throws:

IOException

HttpException

commitResponse

private void commitResponse(HttpResponse response,
 EntityDetails responseEntityDetails)
                     throws HttpException,
IOException

Throws:

HttpException

IOException

commitPromise

private void commitPromise(HttpRequest promise,
 AsyncPushProducer pushProducer)
                    throws HttpException,
IOException

Throws:

HttpException

IOException

produceOutput

public void produceOutput()
                   throws HttpException,
IOException

Specified by:

produceOutput in interface H2StreamHandler

Throws:

HttpException

IOException

handle

public void handle(HttpException ex,
 boolean endStream)
            throws HttpException,
IOException

Specified by:

handle in interface H2StreamHandler

Throws:

HttpException

IOException

failed

public void failed(Exception cause)

Specified by:

failed in interface H2StreamHandler

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface ResourceHolder

toString

public String toString()

Overrides:

toString in class Object