Modifier and Type	Class and Description
pack-priv static class	AbstractHttp1StreamDuplexer.CapacityWindow
private static enum	AbstractHttp1StreamDuplexer.ConnectionState
pack-priv static enum	AbstractHttp1StreamDuplexer.MessageDelineation

Modifier and Type	Field and Description
private volatile AbstractHttp1StreamDuplexer.CapacityWindow	capacityWindow
private final BasicHttpConnectionMetrics	connMetrics
private volatile AbstractHttp1StreamDuplexer.ConnectionState	connState
private final ByteBuffer	contentBuffer
private volatile EndpointDetails	endpointDetails
private final Http1Config	http1Config
private final SessionInputBufferImpl	inbuf
private final ContentLengthStrategy	incomingContentStrategy
private volatile Message<IncomingMessage, ContentDecoder>	incomingMessage
private final NHttpMessageParser<IncomingMessage>	incomingMessageParser
private final BasicHttpTransportMetrics	inTransportMetrics
private final ProtocolIOSession	ioSession
private final SessionOutputBufferImpl	outbuf
private final ContentLengthStrategy	outgoingContentStrategy
private volatile Message<OutgoingMessage, ContentEncoder>	outgoingMessage
private final NHttpMessageWriter<OutgoingMessage>	outgoingMessageWriter
private final AtomicInteger	outputRequests
private final BasicHttpTransportMetrics	outTransportMetrics
private volatile ProtocolVersion	version

Access	Constructor and Description
pack-priv	AbstractHttp1StreamDuplexer(final ProtocolIOSession ioSession, final Http1Config http1Config, final CharCodingConfig charCodingConfig, final NHttpMessageParser<IncomingMessage> incomingMessageParser, final NHttpMessageWriter<OutgoingMessage> outgoingMessageWriter, final ContentLengthStrategy incomingContentStrategy, final ContentLengthStrategy outgoingContentStrategy)

Method Summary

Modifier and Type	Method and Description
pack-priv void	appendState(final StringBuilder buf)
public void	close() Implements org.apache.hc.core5.http.HttpConnection.close. Closes this connection gracefully.
public void	close(final CloseMode How to close the receiver. closeMode) Implements org.apache.hc.core5.io.ModalCloseable.close. Closes this process or endpoint and releases any system resources associated with it.
pack-priv void	commitMessageHead(final OutgoingMessage messageHead, final boolean endStream, final FlushMode flushMode)
pack-priv abstract void	consumeData(ByteBuffer src)
pack-priv abstract void	consumeHeader(IncomingMessage messageHead, EntityDetails entityDetails)
pack-priv abstract ContentDecoder	createContentDecoder(long contentLength, ReadableByteChannel channel, SessionInputBuffer buffer, BasicHttpTransportMetrics metrics)
pack-priv abstract ContentEncoder	createContentEncoder(long contentLength, WritableByteChannel channel, SessionOutputBuffer buffer, BasicHttpTransportMetrics metrics)
pack-priv abstract void	dataEnd(List<? extends Header> trailers)
pack-priv abstract void	disconnected()
pack-priv AbstractHttp1StreamDuplexer.MessageDelineation	endOutputStream(final List<? extends Header> trailers)
pack-priv abstract void	execute(RequestExecutionCommand executionCommand)
public EndpointDetails	getEndpointDetails() Implements org.apache.hc.core5.http.HttpConnection.getEndpointDetails. Returns this connection's endpoint details.
public String	getId() Implements org.apache.hc.core5.util.Identifiable.getId.
public SocketAddress	getLocalAddress() Implements org.apache.hc.core5.http.HttpConnection.getLocalAddress. Returns this connection's local address or `null` if it is not bound yet.
public ProtocolVersion	getProtocolVersion() Implements org.apache.hc.core5.http.HttpConnection.getProtocolVersion. Returns this connection's protocol version or `null` if unknown.
public SocketAddress	getRemoteAddress() Implements org.apache.hc.core5.http.HttpConnection.getRemoteAddress. Returns this connection's remote address or `null` if it is not connected yet or unconnected.
pack-priv Timeout	getSessionTimeout()
public Timeout	getSocketTimeout() Implements org.apache.hc.core5.http.SocketModalCloseable.getSocketTimeout. Returns the socket timeout value.
public SSLSession	getSSLSession() Implements org.apache.hc.core5.http.HttpConnection.getSSLSession. Returns this connection's SSL session or `null` if TLS has not been activated.
pack-priv abstract boolean	handleIncomingMessage(IncomingMessage incomingMessage)
pack-priv abstract boolean	handleOutgoingMessage(OutgoingMessage outgoingMessage)
pack-priv abstract boolean	handleTimeout()
pack-priv abstract void	inputEnd()
pack-priv abstract boolean	inputIdle()
pack-priv boolean	isActive()
public boolean	isOpen() Implements org.apache.hc.core5.http.HttpConnection.isOpen. Checks if this connection is open.
pack-priv boolean	isOutputCompleted()
pack-priv abstract boolean	isOutputReady()
pack-priv boolean	isShuttingDown()
public final void	onConnect()
public final void	onDisconnect()
public final void	onException(final Exception ex)
public final void	onInput(final ByteBuffer src)
public final void	onOutput()
public final void	onTimeout(final Timeout timeout)
pack-priv abstract void	outputEnd()
pack-priv abstract boolean	outputIdle()
pack-priv IncomingMessage	parseMessageHead(final boolean endOfStream)
private void	processCommands()
pack-priv abstract void	produceOutput()
pack-priv void	requestSessionInput()
pack-priv void	requestSessionOutput()
pack-priv void	requestShutdown(final CloseMode closeMode)
pack-priv void	setSessionTimeout(final Timeout timeout)
public void	setSocketTimeout(final Timeout timeout value timeout) Implements org.apache.hc.core5.http.SocketModalCloseable.setSocketTimeout. Sets the socket timeout value.
pack-priv void	shutdownSession(final CloseMode closeMode)
pack-priv void	shutdownSession(final Exception cause)
pack-priv int	streamOutput(final ByteBuffer src)
pack-priv void	suspendSessionInput()
pack-priv void	suspendSessionOutput()
pack-priv abstract void	terminate(final Exception exception)
pack-priv abstract void	updateCapacity(CapacityChannel capacityChannel)
pack-priv abstract void	updateInputMetrics(IncomingMessage incomingMessage, BasicHttpConnectionMetrics connMetrics)
pack-priv abstract void	updateOutputMetrics(OutgoingMessage outgoingMessage, BasicHttpConnectionMetrics connMetrics)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

capacityWindow	back to summary
private volatile AbstractHttp1StreamDuplexer.CapacityWindow capacityWindow

connMetrics	back to summary
private final BasicHttpConnectionMetrics connMetrics

connState	back to summary
private volatile AbstractHttp1StreamDuplexer.ConnectionState connState

contentBuffer	back to summary
private final ByteBuffer contentBuffer

endpointDetails	back to summary
private volatile EndpointDetails endpointDetails

http1Config	back to summary
private final Http1Config http1Config

inbuf	back to summary
private final SessionInputBufferImpl inbuf

incomingContentStrategy	back to summary
private final ContentLengthStrategy incomingContentStrategy

incomingMessage	back to summary
private volatile Message<IncomingMessage, ContentDecoder> incomingMessage

incomingMessageParser	back to summary
private final NHttpMessageParser<IncomingMessage> incomingMessageParser

inTransportMetrics	back to summary
private final BasicHttpTransportMetrics inTransportMetrics

ioSession	back to summary
private final ProtocolIOSession ioSession

outbuf	back to summary
private final SessionOutputBufferImpl outbuf

outgoingContentStrategy	back to summary
private final ContentLengthStrategy outgoingContentStrategy

outgoingMessage	back to summary
private volatile Message<OutgoingMessage, ContentEncoder> outgoingMessage

outgoingMessageWriter	back to summary
private final NHttpMessageWriter<OutgoingMessage> outgoingMessageWriter

outputRequests	back to summary
private final AtomicInteger outputRequests

outTransportMetrics	back to summary
private final BasicHttpTransportMetrics outTransportMetrics

version	back to summary
private volatile ProtocolVersion version

Constructor Detail

AbstractHttp1StreamDuplexer	back to summary
pack-priv AbstractHttp1StreamDuplexer(final ProtocolIOSession ioSession, final Http1Config http1Config, final CharCodingConfig charCodingConfig, final NHttpMessageParser<IncomingMessage> incomingMessageParser, final NHttpMessageWriter<OutgoingMessage> outgoingMessageWriter, final ContentLengthStrategy incomingContentStrategy, final ContentLengthStrategy outgoingContentStrategy)

Method Detail

appendState	back to summary
pack-priv void appendState(final StringBuilder buf)

close back to summary

close	back to summary
public void close() throws IOException Implements org.apache.hc.core5.http.HttpConnection.close. Doc from org.apache.hc.core5.http.HttpConnection.close. Closes this connection gracefully. This method will attempt to flush the internal output buffer prior to closing the underlying socket. This method MUST NOT be called from a different thread to force shutdown of the connection. Use `shutdown` instead. Annotations @Override Exceptions IOException: Doc from java.io.Closeable.close. if an I/O error occurs

public void close() throws IOException

Implements org.apache.hc.core5.http.HttpConnection.close.

Doc from org.apache.hc.core5.http.HttpConnection.close.

Closes this connection gracefully. This method will attempt to flush the internal output buffer prior to closing the underlying socket. This method MUST NOT be called from a different thread to force shutdown of the connection. Use shutdown instead.

Annotations

@Override

Exceptions

IOException:

Doc from java.io.Closeable.close.

if an I/O error occurs

close	back to summary
public void close(final CloseMode closeMode) Implements org.apache.hc.core5.io.ModalCloseable.close. Doc from org.apache.hc.core5.io.ModalCloseable.close. Closes this process or endpoint and releases any system resources associated with it. If the endpoint or the process is already closed then invoking this method has no effect. Parameters closeMode:CloseMode How to close the receiver. Annotations @Override

back to summary

public void close(final CloseMode closeMode)

Implements org.apache.hc.core5.io.ModalCloseable.close.

Doc from org.apache.hc.core5.io.ModalCloseable.close.

Closes this process or endpoint and releases any system resources associated with it. If the endpoint or the process is already closed then invoking this method has no effect.

Parameters

closeMode:CloseMode: How to close the receiver.

Annotations

@Override

commitMessageHead	back to summary
pack-priv void commitMessageHead(final OutgoingMessage messageHead, final boolean endStream, final FlushMode flushMode) throws HttpException, IOException

consumeData	back to summary
pack-priv abstract void consumeData(ByteBuffer src) throws HttpException, IOException

consumeHeader	back to summary
pack-priv abstract void consumeHeader(IncomingMessage messageHead, EntityDetails entityDetails) throws HttpException, IOException

createContentDecoder	back to summary
pack-priv abstract ContentDecoder createContentDecoder(long contentLength, ReadableByteChannel channel, SessionInputBuffer buffer, BasicHttpTransportMetrics metrics) throws HttpException

createContentEncoder	back to summary
pack-priv abstract ContentEncoder createContentEncoder(long contentLength, WritableByteChannel channel, SessionOutputBuffer buffer, BasicHttpTransportMetrics metrics) throws HttpException

dataEnd	back to summary
pack-priv abstract void dataEnd(List<? extends Header> trailers) throws HttpException, IOException

disconnected	back to summary
pack-priv abstract void disconnected()

endOutputStream	back to summary
pack-priv AbstractHttp1StreamDuplexer.MessageDelineation endOutputStream(final List<? extends Header> trailers) throws IOException

execute	back to summary
pack-priv abstract void execute(RequestExecutionCommand executionCommand) throws HttpException, IOException

getEndpointDetails	back to summary
public EndpointDetails getEndpointDetails() Implements org.apache.hc.core5.http.HttpConnection.getEndpointDetails. Doc from org.apache.hc.core5.http.HttpConnection.getEndpointDetails. Returns this connection's endpoint details. Returns:EndpointDetails this connection's endpoint details. Annotations @Override

getEndpointDetails

back to summary

public EndpointDetails getEndpointDetails()

Implements org.apache.hc.core5.http.HttpConnection.getEndpointDetails.

Doc from org.apache.hc.core5.http.HttpConnection.getEndpointDetails.

Returns this connection's endpoint details.

Returns:EndpointDetails

this connection's endpoint details.

Annotations

@Override

getId	back to summary
public String getId() Implements org.apache.hc.core5.util.Identifiable.getId. Annotations @Override

getId

back to summary

public String getId()

Implements org.apache.hc.core5.util.Identifiable.getId.

Annotations

@Override

getLocalAddress back to summary

getLocalAddress	back to summary
public SocketAddress getLocalAddress() Implements org.apache.hc.core5.http.HttpConnection.getLocalAddress. Doc from org.apache.hc.core5.http.HttpConnection.getLocalAddress. Returns this connection's local address or `null` if it is not bound yet. Returns:SocketAddress this connection's local address or `null` if it is not bound yet. Annotations @Override

public SocketAddress getLocalAddress()

Implements org.apache.hc.core5.http.HttpConnection.getLocalAddress.

Doc from org.apache.hc.core5.http.HttpConnection.getLocalAddress.

Returns this connection's local address or null if it is not bound yet.

Returns:SocketAddress

this connection's local address or null if it is not bound yet.

Annotations

@Override

getProtocolVersion back to summary

getProtocolVersion	back to summary
public ProtocolVersion getProtocolVersion() Implements org.apache.hc.core5.http.HttpConnection.getProtocolVersion. Doc from org.apache.hc.core5.http.HttpConnection.getProtocolVersion. Returns this connection's protocol version or `null` if unknown. Returns:ProtocolVersion this connection's protocol version or `null` if unknown. Annotations @Override

public ProtocolVersion getProtocolVersion()

Implements org.apache.hc.core5.http.HttpConnection.getProtocolVersion.

Doc from org.apache.hc.core5.http.HttpConnection.getProtocolVersion.

Returns this connection's protocol version or null if unknown.

Returns:ProtocolVersion

this connection's protocol version or null if unknown.

Annotations

@Override

getRemoteAddress back to summary

getRemoteAddress	back to summary
public SocketAddress getRemoteAddress() Implements org.apache.hc.core5.http.HttpConnection.getRemoteAddress. Doc from org.apache.hc.core5.http.HttpConnection.getRemoteAddress. Returns this connection's remote address or `null` if it is not connected yet or unconnected. Returns:SocketAddress this connection's remote address or `null` if it is not connected yet or unconnected. Annotations @Override

public SocketAddress getRemoteAddress()

Implements org.apache.hc.core5.http.HttpConnection.getRemoteAddress.

Doc from org.apache.hc.core5.http.HttpConnection.getRemoteAddress.

Returns this connection's remote address or null if it is not connected yet or unconnected.

Returns:SocketAddress

this connection's remote address or null if it is not connected yet or unconnected.

Annotations

@Override

getSessionTimeout	back to summary
pack-priv Timeout getSessionTimeout()

getSocketTimeout	back to summary
public Timeout getSocketTimeout() Implements org.apache.hc.core5.http.SocketModalCloseable.getSocketTimeout. Doc from org.apache.hc.core5.http.SocketModalCloseable.getSocketTimeout. Returns the socket timeout value. Returns:Timeout timeout value. Annotations @Override

getSocketTimeout

back to summary

public Timeout getSocketTimeout()

Implements org.apache.hc.core5.http.SocketModalCloseable.getSocketTimeout.

Doc from org.apache.hc.core5.http.SocketModalCloseable.getSocketTimeout.

Returns the socket timeout value.

Returns:Timeout

timeout value.

Annotations

@Override

getSSLSession back to summary

getSSLSession	back to summary
public SSLSession getSSLSession() Implements org.apache.hc.core5.http.HttpConnection.getSSLSession. Doc from org.apache.hc.core5.http.HttpConnection.getSSLSession. Returns this connection's SSL session or `null` if TLS has not been activated. Returns:SSLSession this connection's SSL session or `null` if TLS has not been activated. Annotations @Override

public SSLSession getSSLSession()

Implements org.apache.hc.core5.http.HttpConnection.getSSLSession.

Doc from org.apache.hc.core5.http.HttpConnection.getSSLSession.

Returns this connection's SSL session or null if TLS has not been activated.

Returns:SSLSession

this connection's SSL session or null if TLS has not been activated.

Annotations

@Override

handleIncomingMessage	back to summary
pack-priv abstract boolean handleIncomingMessage(IncomingMessage incomingMessage) throws HttpException

handleOutgoingMessage	back to summary
pack-priv abstract boolean handleOutgoingMessage(OutgoingMessage outgoingMessage) throws HttpException

handleTimeout	back to summary
pack-priv abstract boolean handleTimeout()

inputEnd	back to summary
pack-priv abstract void inputEnd() throws HttpException, IOException

inputIdle	back to summary
pack-priv abstract boolean inputIdle()

isActive	back to summary
pack-priv boolean isActive()

isOpen

back to summary

public boolean isOpen()

Implements org.apache.hc.core5.http.HttpConnection.isOpen.

Doc from org.apache.hc.core5.http.HttpConnection.isOpen.

Checks if this connection is open.

Returns:boolean

true if it is open, false if it is closed.

Annotations

@Override

isOutputCompleted	back to summary
pack-priv boolean isOutputCompleted()

isOutputReady	back to summary
pack-priv abstract boolean isOutputReady()

isShuttingDown	back to summary
pack-priv boolean isShuttingDown()

onConnect	back to summary
public final void onConnect() throws HttpException, IOException

onDisconnect	back to summary
public final void onDisconnect()

onException	back to summary
public final void onException(final Exception ex)

onInput	back to summary
public final void onInput(final ByteBuffer src) throws HttpException, IOException

onOutput	back to summary
public final void onOutput() throws IOException, HttpException

onTimeout	back to summary
public final void onTimeout(final Timeout timeout) throws IOException, HttpException

outputEnd	back to summary
pack-priv abstract void outputEnd() throws HttpException, IOException

outputIdle	back to summary
pack-priv abstract boolean outputIdle()

parseMessageHead	back to summary
pack-priv IncomingMessage parseMessageHead(final boolean endOfStream) throws IOException, HttpException

processCommands	back to summary
private void processCommands() throws HttpException, IOException

produceOutput	back to summary
pack-priv abstract void produceOutput() throws HttpException, IOException

requestSessionInput	back to summary
pack-priv void requestSessionInput()

requestSessionOutput	back to summary
pack-priv void requestSessionOutput()

requestShutdown	back to summary
pack-priv void requestShutdown(final CloseMode closeMode)

setSessionTimeout	back to summary
pack-priv void setSessionTimeout(final Timeout timeout)

setSocketTimeout

back to summary

public void setSocketTimeout(final Timeout timeout)

Implements org.apache.hc.core5.http.SocketModalCloseable.setSocketTimeout.

Doc from org.apache.hc.core5.http.SocketModalCloseable.setSocketTimeout.

Sets the socket timeout value.

Parameters

timeout:Timeout: timeout value

Annotations

@Override

shutdownSession	back to summary
pack-priv void shutdownSession(final CloseMode closeMode)

shutdownSession	back to summary
pack-priv void shutdownSession(final Exception cause)

streamOutput	back to summary
pack-priv int streamOutput(final ByteBuffer src) throws IOException

suspendSessionInput	back to summary
pack-priv void suspendSessionInput()

suspendSessionOutput	back to summary
pack-priv void suspendSessionOutput() throws IOException

terminate	back to summary
pack-priv abstract void terminate(final Exception exception)

updateCapacity	back to summary
pack-priv abstract void updateCapacity(CapacityChannel capacityChannel) throws HttpException, IOException

updateInputMetrics	back to summary
pack-priv abstract void updateInputMetrics(IncomingMessage incomingMessage, BasicHttpConnectionMetrics connMetrics)

updateOutputMetrics	back to summary
pack-priv abstract void updateOutputMetrics(OutgoingMessage outgoingMessage, BasicHttpConnectionMetrics connMetrics)

org.apache.hc.core5.http.impl.nio back to summary

pack-priv Class AbstractHttp1StreamDuplexer.CapacityWindow

Class Inheritance

extends Object
implements CapacityChannel

java.lang.Object
org.apache.hc.core5.http.impl.nio.AbstractHttp1StreamDuplexer.CapacityWindow

All Implemented Interfaces

org.apache.hc.core5.http.nio.CapacityChannel

Field Summary

Modifier and Type	Field and Description
private boolean	closed
private final IOSession	ioSession
private final Object	lock
private int	window

Constructor Summary

Access	Constructor and Description
pack-priv	CapacityWindow(final int window, final IOSession ioSession)

Method Summary

Modifier and Type	Method and Description
pack-priv void	close() Closes the capacity channel, preventing user code from accidentally requesting read events outside of the context of the request the channel was created for
pack-priv int	getWindow()
pack-priv int	removeCapacity(final int delta) Internal method for removing capacity.
public void	update(final int non-negative number of extra bytes the consumer can accept. increment) Implements org.apache.hc.core5.http.nio.CapacityChannel.update. Updates data capacity information through this channel.
private void	updateWindow(final int delta)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

closed	back to summary
private boolean closed

ioSession	back to summary
private final IOSession ioSession

lock	back to summary
private final Object lock

window	back to summary
private int window

Constructor Detail

CapacityWindow	back to summary
pack-priv CapacityWindow(final int window, final IOSession ioSession)

Method Detail

close	back to summary
pack-priv void close() Closes the capacity channel, preventing user code from accidentally requesting read events outside of the context of the request the channel was created for

getWindow	back to summary
pack-priv int getWindow()

removeCapacity	back to summary
pack-priv int removeCapacity(final int delta) Internal method for removing capacity. We don't need to check if this channel is closed in it.

update

back to summary

public void update(final int increment) throws IOException

Implements org.apache.hc.core5.http.nio.CapacityChannel.update.

Doc from org.apache.hc.core5.http.nio.CapacityChannel.update.

Updates data capacity information through this channel. The total number of bytes the consumer is capable of accepting is incremented by the given increment number.

Parameters

increment:int: non-negative number of extra bytes the consumer can accept.

Annotations

@Override

updateWindow	back to summary
private void updateWindow(final int delta)

Modifier and Type	Field and Description
public static final AbstractHttp1StreamDuplexer.ConnectionState	ACTIVE
public static final AbstractHttp1StreamDuplexer.ConnectionState	GRACEFUL_SHUTDOWN
public static final AbstractHttp1StreamDuplexer.ConnectionState	READY
public static final AbstractHttp1StreamDuplexer.ConnectionState	SHUTDOWN

Modifier and Type	Method and Description
public static AbstractHttp1StreamDuplexer.ConnectionState	valueOf(String name)
public static AbstractHttp1StreamDuplexer.ConnectionState[]	values()

Modifier and Type	Field and Description
public static final AbstractHttp1StreamDuplexer.MessageDelineation	CHUNK_CODED
public static final AbstractHttp1StreamDuplexer.MessageDelineation	MESSAGE_HEAD
public static final AbstractHttp1StreamDuplexer.MessageDelineation	NONE

Modifier and Type	Method and Description
public static AbstractHttp1StreamDuplexer.MessageDelineation	valueOf(String name)
public static AbstractHttp1StreamDuplexer.MessageDelineation[]	values()

pack-priv abstract Class AbstractHttp1StreamDuplexer<IncomingMessage extends org.apache.hc.core5.http.HttpMessage, OutgoingMessage extends org.apache.hc.core5.http.HttpMessage>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class AbstractHttp1StreamDuplexer.CapacityWindow

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Enum AbstractHttp1StreamDuplexer.ConnectionState

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Enum AbstractHttp1StreamDuplexer.MessageDelineation

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail