ProtocolIOSession that implements
server side HTTP/1.1 messaging protocol with full support for
duplexed message transmission and message pipelining.
| Modifier and Type | Class and Description |
|---|---|
| private static class |
| Modifier and Type | Field and Description |
|---|---|
| private final ConnectionReuseStrategy | |
| private final HandlerFactory | |
| private final Http1Config | |
| private final HttpProcessor | |
| private volatile ServerHttp1StreamHandler | |
| private volatile ServerHttp1StreamHandler | |
| private final Http1StreamChannel | |
| private final Queue | |
| private final String | |
| private final Http1StreamListener |
| Access | Constructor and Description |
|---|---|
| public | ServerHttp1StreamDuplexer(final ProtocolIOSession ioSession, final HttpProcessor httpProcessor, final HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, final String scheme, final Http1Config http1Config, final CharCodingConfig charCodingConfig, final ConnectionReuseStrategy connectionReuseStrategy, final NHttpMessageParser<HttpRequest> incomingMessageParser, final NHttpMessageWriter<HttpResponse> outgoingMessageWriter, final ContentLengthStrategy incomingContentStrategy, final ContentLengthStrategy outgoingContentStrategy, final Http1StreamListener streamListener)
|
| connectionReuseStrategy | back to summary |
|---|---|
| private final ConnectionReuseStrategy connectionReuseStrategy | |
| exchangeHandlerFactory | back to summary |
|---|---|
| private final HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory | |
| http1Config | back to summary |
|---|---|
| private final Http1Config http1Config Hides org. | |
| httpProcessor | back to summary |
|---|---|
| private final HttpProcessor httpProcessor | |
| incoming | back to summary |
|---|---|
| private volatile ServerHttp1StreamHandler incoming | |
| outgoing | back to summary |
|---|---|
| private volatile ServerHttp1StreamHandler outgoing | |
| outputChannel | back to summary |
|---|---|
| private final Http1StreamChannel<HttpResponse> outputChannel | |
| pipeline | back to summary |
|---|---|
| private final Queue<ServerHttp1StreamHandler> pipeline | |
| scheme | back to summary |
|---|---|
| private final String scheme | |
| streamListener | back to summary |
|---|---|
| private final Http1StreamListener streamListener | |
| ServerHttp1StreamDuplexer | back to summary |
|---|---|
| public ServerHttp1StreamDuplexer(final ProtocolIOSession ioSession, final HttpProcessor httpProcessor, final HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, final String scheme, final Http1Config http1Config, final CharCodingConfig charCodingConfig, final ConnectionReuseStrategy connectionReuseStrategy, final NHttpMessageParser<HttpRequest> incomingMessageParser, final NHttpMessageWriter<HttpResponse> outgoingMessageWriter, final ContentLengthStrategy incomingContentStrategy, final ContentLengthStrategy outgoingContentStrategy, final Http1StreamListener streamListener) | |
| appendState | back to summary |
|---|---|
| pack-priv void appendState(final StringBuilder buf) Overrides org.
| |
| consumeData | back to summary |
|---|---|
| pack-priv void consumeData(final ByteBuffer src) throws HttpException, IOException Implements abstract org.
| |
| consumeHeader | back to summary |
|---|---|
| pack-priv void consumeHeader(final HttpRequest request, final EntityDetails entityDetails) throws HttpException, IOException Implements abstract org.
| |
| createContentDecoder | back to summary |
|---|---|
| protected ContentDecoder createContentDecoder(final long len, final ReadableByteChannel channel, final SessionInputBuffer buffer, final BasicHttpTransportMetrics metrics) throws HttpException Implements abstract org.
| |
| createContentEncoder | back to summary |
|---|---|
| protected ContentEncoder createContentEncoder(final long len, final WritableByteChannel channel, final SessionOutputBuffer buffer, final BasicHttpTransportMetrics metrics) throws HttpException Implements abstract org.
| |
| dataEnd | back to summary |
|---|---|
| pack-priv void dataEnd(final List<? extends Header> trailers) throws HttpException, IOException Implements abstract org.
| |
| disconnected | back to summary |
|---|---|
| pack-priv void disconnected() Implements abstract org.
| |
| execute | back to summary |
|---|---|
| pack-priv void execute(final RequestExecutionCommand executionCommand) throws HttpException Implements abstract org.
| |
| handleIncomingMessage | back to summary |
|---|---|
| protected boolean handleIncomingMessage(final HttpRequest request) throws HttpException Implements abstract org.
| |
| handleOutgoingMessage | back to summary |
|---|---|
| protected boolean handleOutgoingMessage(final HttpResponse response) throws HttpException Implements abstract org.
| |
| handleTimeout | back to summary |
|---|---|
| pack-priv boolean handleTimeout() Implements abstract org.
| |
| inputEnd | back to summary |
|---|---|
| pack-priv void inputEnd() throws HttpException, IOException Implements abstract org.
| |
| inputIdle | back to summary |
|---|---|
| pack-priv boolean inputIdle() Implements abstract org.
| |
| isOutputReady | back to summary |
|---|---|
| pack-priv boolean isOutputReady() Implements abstract org.
| |
| outputEnd | back to summary |
|---|---|
| pack-priv void outputEnd() throws HttpException, IOException Implements abstract org.
| |
| outputIdle | back to summary |
|---|---|
| pack-priv boolean outputIdle() Implements abstract org.
| |
| parseMessageHead | back to summary |
|---|---|
| pack-priv HttpRequest parseMessageHead(final boolean endOfStream) throws IOException, HttpException Overrides org.
| |
| produceOutput | back to summary |
|---|---|
| pack-priv void produceOutput() throws HttpException, IOException Implements abstract org.
| |
| terminate | back to summary |
|---|---|
| pack-priv void terminate(final Exception exception) Implements abstract org.
| |
| terminateExchange | back to summary |
|---|---|
| pack-priv void terminateExchange(final HttpException ex) throws HttpException, IOException | |
| toString | back to summary |
|---|---|
| public String toString() Overrides java. Doc from java. Returns a string representation of the object. | |
| updateCapacity | back to summary |
|---|---|
| pack-priv void updateCapacity(final CapacityChannel capacityChannel) throws HttpException, IOException Implements abstract org.
| |
| updateInputMetrics | back to summary |
|---|---|
| pack-priv void updateInputMetrics(final HttpRequest request, final BasicHttpConnectionMetrics connMetrics) Implements abstract org.
| |
| updateOutputMetrics | back to summary |
|---|---|
| pack-priv void updateOutputMetrics(final HttpResponse response, final BasicHttpConnectionMetrics connMetrics) Implements abstract org.
| |
| Modifier and Type | Field and Description |
|---|---|
| private final Http1StreamChannel | |
| private volatile boolean | |
| private volatile HttpResponse | |
| private volatile boolean |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public boolean | |
| public void | |
| public void | |
| public void | complete(final List<? extends Header> trailers)
Implements org. |
| public Timeout | |
| public boolean | isCompleted()
Implements org. true if the entity has been transferred in its
entirety.
|
| public void | |
| public void | setSocketTimeout(final Timeout timeout)
Implements org. |
| public void | submit(final HttpResponse response, final boolean endStream, final FlushMode flushMode)
Implements org. |
| public void | |
| public int | write(final ByteBuffer
The buffer from which content is to be retrieved src)Implements org. |
| channel | back to summary |
|---|---|
| private final Http1StreamChannel<HttpResponse> channel | |
| completed | back to summary |
|---|---|
| private volatile boolean completed | |
| delayedResponse | back to summary |
|---|---|
| private volatile HttpResponse delayedResponse | |
| direct | back to summary |
|---|---|
| private volatile boolean direct | |
| DelayedOutputChannel | back to summary |
|---|---|
| private DelayedOutputChannel(final Http1StreamChannel<HttpResponse> channel) | |
| abortGracefully | back to summary |
|---|---|
| public boolean abortGracefully() throws IOException Implements org.
| |
| activate | back to summary |
|---|---|
| public void activate() throws IOException, HttpException Implements org.
| |
| close | back to summary |
|---|---|
| public void close() Implements org.
| |
| complete | back to summary |
|---|---|
| public void complete(final List<? extends Header> trailers) throws IOException Implements org. Doc from org. Terminates the content stream.
| |
| getSocketTimeout | back to summary |
|---|---|
| public Timeout getSocketTimeout() Implements org.
| |
| isCompleted | back to summary |
|---|---|
| public boolean isCompleted() Implements org. Doc from org. Returns
| |
| requestOutput | back to summary |
|---|---|
| public void requestOutput() Implements org.
| |
| setSocketTimeout | back to summary |
|---|---|
| public void setSocketTimeout(final Timeout timeout) Implements org.
| |
| submit | back to summary |
|---|---|
| public void submit(final HttpResponse response, final boolean endStream, final FlushMode flushMode) throws HttpException, IOException Implements org.
| |
| suspendOutput | back to summary |
|---|---|
| public void suspendOutput() throws IOException Implements org.
| |
| write | back to summary |
|---|---|
| public int write(final ByteBuffer src) throws IOException Implements org. Doc from org. Writes a portion of entity content to the underlying channel.
| |