Top Fields Constructors Methods
org.apache.hc.core5.http.impl.nio

pack-priv Class ServerHttp1StreamHandler

extends Object
implements ResourceHolder
Class Inheritance
All Implemented Interfaces
org.apache.hc.core5.http.nio.ResourceHolder
Imports
java.io.IOException, java.nio.ByteBuffer, java.util.List, java.util.concurrent.atomic.AtomicBoolean, org.apache.hc.core5.http.ConnectionReuseStrategy, .EntityDetails, .Header, .HeaderElements, .HttpException, .HttpHeaders, .HttpRequest, .HttpResponse, .HttpStatus, .HttpVersion, .Method, .MisdirectedRequestException, .ProtocolException, .ProtocolVersion, .UnsupportedHttpVersionException, org.apache.hc.core5.http.impl.ServerSupport, org.apache.hc.core5.http.message.BasicHttpResponse, org.apache.hc.core5.http.nio.AsyncPushProducer, .AsyncResponseProducer, .AsyncServerExchangeHandler, .CapacityChannel, .DataStreamChannel, .HandlerFactory, .ResourceHolder, .ResponseChannel, org.apache.hc.core5.http.nio.support.BasicResponseProducer, .ImmediateResponseExchangeHandler, org.apache.hc.core5.http.protocol.HttpContext, .HttpCoreContext, .HttpProcessor

Field Summary

Modifier and TypeField and Description
private final ConnectionReuseStrategy
connectionReuseStrategy

private final HttpCoreContext
context

private final AtomicBoolean
done

private volatile AsyncServerExchangeHandler
exchangeHandler

private final HandlerFactory<AsyncServerExchangeHandler>
exchangeHandlerFactory

private final HttpProcessor
httpProcessor

private final DataStreamChannel
internalDataChannel

private volatile boolean
keepAlive

private final Http1StreamChannel<HttpResponse>
outputChannel

private volatile HttpRequest
receivedRequest

private volatile MessageState
requestState

private final ResponseChannel
responseChannel

private final AtomicBoolean
responseCommitted

private volatile MessageState
responseState

Constructor Summary

AccessConstructor and Description
pack-priv
ServerHttp1StreamHandler(final Http1StreamChannel<HttpResponse> outputChannel, final HttpProcessor httpProcessor, final ConnectionReuseStrategy connectionReuseStrategy, final HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, final HttpCoreContext context)

Method Summary

Modifier and TypeMethod and Description
pack-priv void
activateChannel()

pack-priv void
appendState(final StringBuilder buf)

private void
commitInformation(final HttpResponse response)

private void
commitPromise()

private void
commitResponse(final HttpResponse response, final EntityDetails responseEntityDetails)

pack-priv void
consumeData(final ByteBuffer src)

pack-priv void
consumeHeader(final HttpRequest request, final EntityDetails requestEntityDetails)

pack-priv void
dataEnd(final List<? extends Header> trailers)

pack-priv void
failed(final Exception cause)

pack-priv boolean
isCompleted()

pack-priv boolean
isOutputReady()

pack-priv boolean
isResponseFinal()

pack-priv boolean
keepAlive()

pack-priv void
produceOutput()

public void
releaseResources()

Implements org.apache.hc.core5.http.nio.ResourceHolder.releaseResources.

pack-priv void
terminateExchange(final HttpException ex)

public String
toString()

Overrides java.lang.Object.toString.

Returns a string representation of the object.
pack-priv void
updateCapacity(final CapacityChannel capacityChannel)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAllwaitwaitwait

Field Detail

connectionReuseStrategyback to summary
private final ConnectionReuseStrategy connectionReuseStrategy
contextback to summary
private final HttpCoreContext context
doneback to summary
private final AtomicBoolean done
exchangeHandlerback to summary
private volatile AsyncServerExchangeHandler exchangeHandler
exchangeHandlerFactoryback to summary
private final HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory
httpProcessorback to summary
private final HttpProcessor httpProcessor
internalDataChannelback to summary
private final DataStreamChannel internalDataChannel
keepAliveback to summary
private volatile boolean keepAlive
outputChannelback to summary
private final Http1StreamChannel<HttpResponse> outputChannel
receivedRequestback to summary
private volatile HttpRequest receivedRequest
requestStateback to summary
private volatile MessageState requestState
responseChannelback to summary
private final ResponseChannel responseChannel
responseCommittedback to summary
private final AtomicBoolean responseCommitted
responseStateback to summary
private volatile MessageState responseState

Constructor Detail

ServerHttp1StreamHandlerback to summary
pack-priv ServerHttp1StreamHandler(final Http1StreamChannel<HttpResponse> outputChannel, final HttpProcessor httpProcessor, final ConnectionReuseStrategy connectionReuseStrategy, final HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, final HttpCoreContext context)

Method Detail

activateChannelback to summary
pack-priv void activateChannel() throws IOException, HttpException
appendStateback to summary
pack-priv void appendState(final StringBuilder buf)
commitInformationback to summary
private void commitInformation(final HttpResponse response) throws IOException, HttpException
commitPromiseback to summary
private void commitPromise() throws HttpException
commitResponseback to summary
private void commitResponse(final HttpResponse response, final EntityDetails responseEntityDetails) throws HttpException, IOException
consumeDataback to summary
pack-priv void consumeData(final ByteBuffer src) throws HttpException, IOException
consumeHeaderback to summary
pack-priv void consumeHeader(final HttpRequest request, final EntityDetails requestEntityDetails) throws HttpException, IOException
dataEndback to summary
pack-priv void dataEnd(final List<? extends Header> trailers) throws HttpException, IOException
failedback to summary
pack-priv void failed(final Exception cause)
isCompletedback to summary
pack-priv boolean isCompleted()
isOutputReadyback to summary
pack-priv boolean isOutputReady()
isResponseFinalback to summary
pack-priv boolean isResponseFinal()
keepAliveback to summary
pack-priv boolean keepAlive()
produceOutputback to summary
pack-priv void produceOutput() throws HttpException, IOException
releaseResourcesback to summary
public void releaseResources()

Implements org.apache.hc.core5.http.nio.ResourceHolder.releaseResources.

Annotations
@Override
terminateExchangeback to summary
pack-priv void terminateExchange(final HttpException ex) throws HttpException, IOException
toStringback to summary
public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations
@Override
updateCapacityback to summary
pack-priv void updateCapacity(final CapacityChannel capacityChannel) throws IOException