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

Class ClientHttp1StreamDuplexer

java.lang.Object

org.apache.hc.core5.http.impl.nio.AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

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

All Implemented Interfaces:

Closeable, AutoCloseable, HttpConnection, SocketModalCloseable, ModalCloseable, Identifiable

@Internal
public class ClientHttp1StreamDuplexer
extends AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

I/O event handler for events fired by ProtocolIOSession that implements client side HTTP/1.1 messaging protocol with full support for duplexed message transmission and message pipelining.

Since:

5.0

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hc.core5.http.impl.nio.AbstractHttp1StreamDuplexer

AbstractHttp1StreamDuplexer.CapacityWindow, AbstractHttp1StreamDuplexer.MessageDelineation

Field Summary

Fields

Modifier and Type	Field	Description
private final ConnectionReuseStrategy	connectionReuseStrategy
private final Http1Config	http1Config
private final HttpProcessor	httpProcessor
private ClientHttp1StreamHandler	incoming
private ClientHttp1StreamHandler	outgoing
private final Http1StreamChannel<HttpRequest>	outputChannel
private final Queue<ClientHttp1StreamHandler>	pipeline
private final Http1StreamListener	streamListener

Constructor Summary

Constructors

Constructor

Description

ClientHttp1StreamDuplexer(ProtocolIOSession ioSession, HttpProcessor httpProcessor, Http1Config http1Config, CharCodingConfig charCodingConfig, ConnectionReuseStrategy connectionReuseStrategy, NHttpMessageParser<HttpResponse> incomingMessageParser, NHttpMessageWriter<HttpRequest> outgoingMessageWriter, ContentLengthStrategy incomingContentStrategy, ContentLengthStrategy outgoingContentStrategy, Http1StreamListener streamListener)

Method Summary

Modifier and Type	Method	Description
(package private) void	appendState(StringBuilder buf)
(package private) void	consumeData(ByteBuffer src)
(package private) void	consumeHeader(HttpResponse response, EntityDetails entityDetails)
protected ContentDecoder	createContentDecoder(long len, ReadableByteChannel channel, SessionInputBuffer buffer, BasicHttpTransportMetrics metrics)
protected ContentEncoder	createContentEncoder(long len, WritableByteChannel channel, SessionOutputBuffer buffer, BasicHttpTransportMetrics metrics)
(package private) void	dataEnd(List<? extends Header> trailers)
(package private) void	disconnected()
(package private) void	execute(RequestExecutionCommand executionCommand)
protected boolean	handleIncomingMessage(HttpResponse response)
protected boolean	handleOutgoingMessage(HttpRequest request)
(package private) boolean	handleTimeout()
(package private) void	inputEnd()
(package private) boolean	inputIdle()
(package private) boolean	isOutputReady()
(package private) void	outputEnd()
(package private) boolean	outputIdle()
(package private) void	produceOutput()
(package private) void	terminate(Exception exception)
String	toString()
(package private) void	updateCapacity(CapacityChannel capacityChannel)
(package private) void	updateInputMetrics(HttpResponse response, BasicHttpConnectionMetrics connMetrics)
(package private) void	updateOutputMetrics(HttpRequest request, BasicHttpConnectionMetrics connMetrics)

Methods inherited from class org.apache.hc.core5.http.impl.nio.AbstractHttp1StreamDuplexer

close, close, commitMessageHead, endOutputStream, getEndpointDetails, getId, getLocalAddress, getProtocolVersion, getRemoteAddress, getSessionTimeout, getSocketTimeout, getSSLSession, isActive, isOpen, isOutputCompleted, isShuttingDown, onConnect, onDisconnect, onException, onInput, onOutput, onTimeout, parseMessageHead, requestSessionInput, requestSessionOutput, requestShutdown, setSessionTimeout, setSocketTimeout, shutdownSession, shutdownSession, streamOutput, suspendSessionInput, suspendSessionOutput

Methods inherited from class java.lang.Object

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

Field Details

httpProcessor

private final HttpProcessor httpProcessor

connectionReuseStrategy

private final ConnectionReuseStrategy connectionReuseStrategy

http1Config

private final Http1Config http1Config

streamListener

private final Http1StreamListener streamListener

pipeline

private final Queue<ClientHttp1StreamHandler> pipeline

outputChannel

private final Http1StreamChannel<HttpRequest> outputChannel

outgoing

private volatile ClientHttp1StreamHandler outgoing

incoming

private volatile ClientHttp1StreamHandler incoming

Constructor Details

ClientHttp1StreamDuplexer

public ClientHttp1StreamDuplexer(ProtocolIOSession ioSession,
 HttpProcessor httpProcessor,
 Http1Config http1Config,
 CharCodingConfig charCodingConfig,
 ConnectionReuseStrategy connectionReuseStrategy,
 NHttpMessageParser<HttpResponse> incomingMessageParser,
 NHttpMessageWriter<HttpRequest> outgoingMessageWriter,
 ContentLengthStrategy incomingContentStrategy,
 ContentLengthStrategy outgoingContentStrategy,
 Http1StreamListener streamListener)

Method Details

terminate

void terminate(Exception exception)

Specified by:

terminate in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

disconnected

void disconnected()

Specified by:

disconnected in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

updateInputMetrics

void updateInputMetrics(HttpResponse response,
 BasicHttpConnectionMetrics connMetrics)

Specified by:

updateInputMetrics in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

updateOutputMetrics

void updateOutputMetrics(HttpRequest request,
 BasicHttpConnectionMetrics connMetrics)

Specified by:

updateOutputMetrics in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

handleIncomingMessage

protected boolean handleIncomingMessage(HttpResponse response)
                                 throws HttpException

Specified by:

handleIncomingMessage in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

Throws:

HttpException

createContentDecoder

protected ContentDecoder createContentDecoder(long len,
 ReadableByteChannel channel,
 SessionInputBuffer buffer,
 BasicHttpTransportMetrics metrics)
                                       throws HttpException

Specified by:

createContentDecoder in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

Throws:

HttpException

handleOutgoingMessage

protected boolean handleOutgoingMessage(HttpRequest request)
                                 throws HttpException

Specified by:

handleOutgoingMessage in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

Throws:

HttpException

createContentEncoder

protected ContentEncoder createContentEncoder(long len,
 WritableByteChannel channel,
 SessionOutputBuffer buffer,
 BasicHttpTransportMetrics metrics)
                                       throws HttpException

Specified by:

createContentEncoder in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

Throws:

HttpException

inputIdle

boolean inputIdle()

Specified by:

inputIdle in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

outputIdle

boolean outputIdle()

Specified by:

outputIdle in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

outputEnd

void outputEnd()
        throws HttpException,
IOException

Specified by:

outputEnd in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

Throws:

HttpException

IOException

execute

void execute(RequestExecutionCommand executionCommand)
      throws HttpException,
IOException

Specified by:

execute in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

Throws:

HttpException

IOException

isOutputReady

boolean isOutputReady()

Specified by:

isOutputReady in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

produceOutput

void produceOutput()
            throws HttpException,
IOException

Specified by:

produceOutput in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

Throws:

HttpException

IOException

consumeHeader

void consumeHeader(HttpResponse response,
 EntityDetails entityDetails)
            throws HttpException,
IOException

Specified by:

consumeHeader in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

Throws:

HttpException

IOException

consumeData

void consumeData(ByteBuffer src)
          throws HttpException,
IOException

Specified by:

consumeData in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

Throws:

HttpException

IOException

updateCapacity

void updateCapacity(CapacityChannel capacityChannel)
             throws HttpException,
IOException

Specified by:

updateCapacity in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

Throws:

HttpException

IOException

dataEnd

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

Specified by:

dataEnd in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

Throws:

HttpException

IOException

inputEnd

void inputEnd()
       throws HttpException,
IOException

Specified by:

inputEnd in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

Throws:

HttpException

IOException

handleTimeout

boolean handleTimeout()

Specified by:

handleTimeout in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

appendState

void appendState(StringBuilder buf)

Overrides:

appendState in class AbstractHttp1StreamDuplexer<HttpResponse,HttpRequest>

toString

public String toString()

Overrides:

toString in class Object