Class ServerHttp1StreamHandler

java.lang.Object

org.apache.hc.core5.http.impl.nio.ServerHttp1StreamHandler

All Implemented Interfaces:

ResourceHolder

class ServerHttp1StreamHandler
extends Object
implements ResourceHolder

Field Summary

Fields

Modifier and Type	Field	Description
private final ConnectionReuseStrategy	connectionReuseStrategy
private final HttpCoreContext	context
private final AtomicBoolean	done
private final Callback<Exception>	exceptionCallback
private AsyncServerExchangeHandler	exchangeHandler
private final HandlerFactory<AsyncServerExchangeHandler>	exchangeHandlerFactory
private final Http1Config	http1Config
private final HttpProcessor	httpProcessor
private final DataStreamChannel	internalDataChannel
private boolean	keepAlive
private final Http1StreamChannel<HttpResponse>	outputChannel
private HttpRequest	receivedRequest
private final AtomicReference<MessageState>	requestState
private final ResponseChannel	responseChannel
private final AtomicBoolean	responseCommitted
private final AtomicReference<MessageState>	responseState

Constructor Summary

Constructors

Constructor	Description
ServerHttp1StreamHandler(Http1StreamChannel<HttpResponse> outputChannel, HttpProcessor httpProcessor, Http1Config http1Config, ConnectionReuseStrategy connectionReuseStrategy, HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, Callback<Exception> exceptionCallback, HttpCoreContext context)

Method Summary

Modifier and Type	Method	Description
(package private) void	activateChannel()
(package private) void	appendState(StringBuilder buf)
private void	commitInformation(HttpResponse response)
private void	commitPromise()
private void	commitResponse(HttpResponse response, EntityDetails responseEntityDetails)
(package private) void	consumeData(ByteBuffer src)
(package private) void	consumeHeader(HttpRequest request, EntityDetails requestEntityDetails)
(package private) void	dataEnd(List<? extends Header> trailers)
(package private) void	failed(Exception cause)
(package private) boolean	isCompleted()
(package private) boolean	isOutputReady()
(package private) boolean	isResponseFinal()
(package private) boolean	keepAlive()
(package private) void	produceOutput()
void	releaseResources()
private void	terminate()
(package private) void	terminateExchange(HttpException ex)
String	toString()
(package private) void	updateCapacity(CapacityChannel capacityChannel)

Methods inherited from class Object

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

Field Details

outputChannel

private final Http1StreamChannel<HttpResponse> outputChannel

internalDataChannel

private final DataStreamChannel internalDataChannel

responseChannel

private final ResponseChannel responseChannel

httpProcessor

private final HttpProcessor httpProcessor

http1Config

private final Http1Config http1Config

connectionReuseStrategy

private final ConnectionReuseStrategy connectionReuseStrategy

exchangeHandlerFactory

private final HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory

exceptionCallback

private final Callback<Exception> exceptionCallback

context

private final HttpCoreContext context

requestState

private final AtomicReference<MessageState> requestState

responseState

private final AtomicReference<MessageState> responseState

responseCommitted

private final AtomicBoolean responseCommitted

done

private final AtomicBoolean done

keepAlive

private volatile boolean keepAlive

exchangeHandler

private volatile AsyncServerExchangeHandler exchangeHandler

receivedRequest

private volatile HttpRequest receivedRequest

Constructor Details

ServerHttp1StreamHandler

ServerHttp1StreamHandler(Http1StreamChannel<HttpResponse> outputChannel,
 HttpProcessor httpProcessor,
 Http1Config http1Config,
 ConnectionReuseStrategy connectionReuseStrategy,
 HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory,
 Callback<Exception> exceptionCallback,
 HttpCoreContext context)

Method Details

commitResponse

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

Throws:

HttpException

IOException

commitInformation

private void commitInformation(HttpResponse response)
                        throws IOException,
HttpException

Throws:

IOException

HttpException

commitPromise

private void commitPromise()
                    throws HttpException

Throws:

HttpException

terminate

private void terminate()

activateChannel

void activateChannel()
              throws IOException,
HttpException

Throws:

IOException

HttpException

isResponseFinal

boolean isResponseFinal()

keepAlive

boolean keepAlive()

isCompleted

boolean isCompleted()

terminateExchange

void terminateExchange(HttpException ex)
                throws HttpException,
IOException

Throws:

HttpException

IOException

consumeHeader

void consumeHeader(HttpRequest request,
 EntityDetails requestEntityDetails)
            throws HttpException,
IOException

Throws:

HttpException

IOException

isOutputReady

boolean isOutputReady()

produceOutput

void produceOutput()
            throws IOException

Throws:

IOException

consumeData

void consumeData(ByteBuffer src)
          throws HttpException,
IOException

Throws:

HttpException

IOException

updateCapacity

void updateCapacity(CapacityChannel capacityChannel)
             throws IOException

Throws:

IOException

dataEnd

void dataEnd(List<? extends Header> trailers)
      throws HttpException,
IOException

Throws:

HttpException

IOException

failed

void failed(Exception cause)

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface ResourceHolder

appendState

void appendState(StringBuilder buf)

toString

public String toString()

Overrides:

toString in class Object