Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	HttpClientConnection.ClientReadListener
private class	HttpClientConnection.ClientStatisticsImpl

Field Summary

Modifier and Type	Field and Description
private final ByteBufferPool	bufferPool
private final HttpClientConnection.ClientReadListener	clientReadListener
private final ClientStatistics	clientStatistics
private static final int	CLOSE_REQ
private static final int	CLOSED
private final List<ChannelListener<ClientConnection>>	closeListeners
private final ChannelListener.SimpleSetter<HttpClientConnection>	closeSetter
private final StreamConnection	connection
private HttpClientExchange	currentRequest
private ClientConnection	http2Delegate The actual connection if this has been upgraded to h2c
private boolean	http2Tried
private boolean	http2UpgradeReceived
private static final Logger	log
private final OptionMap	options
private final StreamSinkConduit	originalSinkConduit
private final Deque<HttpClientExchange>	pendingQueue
private HttpResponseBuilder	pendingResponse
private PooledByteBuffer	pooledBuffer
private final PushBackStreamSourceConduit	pushBackStreamSourceConduit
private int	read
private int	requestCount
public final ConduitListener<StreamSinkConduit>	requestFinishListener
public final ConduitListener<StreamSourceConduit>	responseFinishedListener
private int	state
private static final int	UPGRADE_REQUESTED
private static final int	UPGRADED
private int	written

Constructor Summary

Access	Constructor and Description
pack-priv	HttpClientConnection(final StreamConnection connection, final OptionMap options, final ByteBufferPool bufferPool)

Method Summary

Modifier and Type	Method and Description
public void	addCloseListener(ChannelListener<ClientConnection> The close listener listener) Implements io.undertow.client.ClientConnection.addCloseListener. Adds a close listener, than will be invoked with the connection is closed
public void	close() Implements java.io.Closeable.close, java.nio.channels.Channel.close. Closes this stream and releases any system resources associated with it.
protected void	doHttp2Upgrade()
public void	exchangeDone() Notification that the current request is finished
public ByteBufferPool	getBufferPool() Implements io.undertow.client.ClientConnection.getBufferPool.
public ChannelListener.Setter<? extends HttpClientConnection>	getCloseSetter() Implements io.undertow.client.ClientConnection.getCloseSetter.
pack-priv StreamConnection	getConnection()
public XnioIoThread	getIoThread() Implements io.undertow.client.ClientConnection.getIoThread.
public SocketAddress	getLocalAddress() Implements io.undertow.client.ClientConnection.getLocalAddress.
public <A extends SocketAddress> A	getLocalAddress(Class<A> type) Implements io.undertow.client.ClientConnection.getLocalAddress.
public <T> T	getOption(Option<T> option) Implements io.undertow.client.ClientConnection.getOption.
public SocketAddress	getPeerAddress() Implements io.undertow.client.ClientConnection.getPeerAddress.
public <A extends SocketAddress> A	getPeerAddress(Class<A> type) Implements io.undertow.client.ClientConnection.getPeerAddress.
public ClientStatistics	getStatistics() Implements io.undertow.client.ClientConnection.getStatistics.
public XnioWorker	getWorker() Implements io.undertow.client.ClientConnection.getWorker.
private void	handleError(Throwable exception)
private void	handleError(IOException exception)
private void	initiateRequest(HttpClientExchange httpClientExchange)
public boolean	isMultiplexingSupported() Implements io.undertow.client.ClientConnection.isMultiplexingSupported.
public boolean	isOpen() Implements io.undertow.client.ClientConnection.isOpen. Tells whether or not this channel is open.
public boolean	isPushSupported() Implements io.undertow.client.ClientConnection.isPushSupported.
public boolean	isUpgraded() Implements io.undertow.client.ClientConnection.isUpgraded.
public boolean	isUpgradeSupported() Implements io.undertow.client.ClientConnection.isUpgradeSupported.
public StreamConnection	performUpgrade() Implements io.undertow.client.ClientConnection.performUpgrade. Upgrade the connection, if the underlying protocol supports it.
private void	prepareResponseChannel(ClientResponse response, ClientExchange exchange)
public void	requestDataSent()
public void	sendRequest(final ClientRequest The request to send. request, final ClientCallback<ClientExchange> clientCallback) Implements io.undertow.client.ClientConnection.sendRequest. Sends a client request.
public <T> T	setOption(Option<T> option, T value) Implements io.undertow.client.ClientConnection.setOption.
public boolean	supportsOption(Option<?> option) Implements io.undertow.client.ClientConnection.supportsOption.

Inherited from io.undertow.util.AbstractAttachable:: addToAttachmentList createAttachmentMap getAttachment getAttachmentList putAttachment removeAttachment

Field Detail

bufferPool	back to summary
private final ByteBufferPool bufferPool

clientReadListener	back to summary
private final HttpClientConnection.ClientReadListener clientReadListener

clientStatistics	back to summary
private final ClientStatistics clientStatistics

CLOSE_REQ	back to summary
private static final int CLOSE_REQ

CLOSED	back to summary
private static final int CLOSED

closeListeners	back to summary
private final List<ChannelListener<ClientConnection>> closeListeners

closeSetter	back to summary
private final ChannelListener.SimpleSetter<HttpClientConnection> closeSetter

connection	back to summary
private final StreamConnection connection

currentRequest	back to summary
private HttpClientExchange currentRequest

http2Delegate	back to summary
private ClientConnection http2Delegate The actual connection if this has been upgraded to h2c

http2Tried	back to summary
private boolean http2Tried

http2UpgradeReceived	back to summary
private boolean http2UpgradeReceived

log	back to summary
private static final Logger log

options	back to summary
private final OptionMap options

originalSinkConduit	back to summary
private final StreamSinkConduit originalSinkConduit

pendingQueue	back to summary
private final Deque<HttpClientExchange> pendingQueue

pendingResponse	back to summary
private HttpResponseBuilder pendingResponse

pooledBuffer	back to summary
private PooledByteBuffer pooledBuffer

pushBackStreamSourceConduit	back to summary
private final PushBackStreamSourceConduit pushBackStreamSourceConduit

read	back to summary
private int read

requestCount	back to summary
private int requestCount

requestFinishListener	back to summary
public final ConduitListener<StreamSinkConduit> requestFinishListener

responseFinishedListener	back to summary
public final ConduitListener<StreamSourceConduit> responseFinishedListener

state	back to summary
private int state

UPGRADE_REQUESTED	back to summary
private static final int UPGRADE_REQUESTED

UPGRADED	back to summary
private static final int UPGRADED

written	back to summary
private int written

Constructor Detail

HttpClientConnection	back to summary
pack-priv HttpClientConnection(final StreamConnection connection, final OptionMap options, final ByteBufferPool bufferPool)

Method Detail

addCloseListener	back to summary
public void addCloseListener(ChannelListener<ClientConnection> listener) Implements io.undertow.client.ClientConnection.addCloseListener. Doc from io.undertow.client.ClientConnection.addCloseListener. Adds a close listener, than will be invoked with the connection is closed Parameters listener:ChannelListener<ClientConnection> The close listener Annotations @Override

addCloseListener

back to summary

public void addCloseListener(ChannelListener<ClientConnection> listener)

Implements io.undertow.client.ClientConnection.addCloseListener.

Doc from io.undertow.client.ClientConnection.addCloseListener.

Adds a close listener, than will be invoked with the connection is closed

Parameters

listener:ChannelListener<ClientConnection>: The close listener

Annotations

@Override

close back to summary

close	back to summary
public void close() throws IOException Implements java.io.Closeable.close, java.nio.channels.Channel.close. Doc from java.io.Closeable.close. Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect. As noted in `AutoCloseable#close()`, cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the `Closeable` as closed, prior to throwing the `IOException`. Exceptions IOException: if an I/O error occurs

public void close() throws IOException

Implements java.io.Closeable.close, java.nio.channels.Channel.close.

Doc from java.io.Closeable.close.

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

As noted in AutoCloseable#close(), cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the Closeable as closed, prior to throwing the IOException.

Exceptions

IOException:: if an I/O error occurs

doHttp2Upgrade	back to summary
protected void doHttp2Upgrade()

exchangeDone	back to summary
public void exchangeDone() Notification that the current request is finished

getBufferPool	back to summary
public ByteBufferPool getBufferPool() Implements io.undertow.client.ClientConnection.getBufferPool. Returns:ByteBufferPool Doc from io.undertow.client.ClientConnection.getBufferPool. The buffer pool used by the client Annotations @Override

getBufferPool

back to summary

public ByteBufferPool getBufferPool()

Implements io.undertow.client.ClientConnection.getBufferPool.

Returns:ByteBufferPool

Doc from io.undertow.client.ClientConnection.getBufferPool.

The buffer pool used by the client

Annotations

@Override

getCloseSetter	back to summary
public ChannelListener.Setter<? extends HttpClientConnection> getCloseSetter() Implements io.undertow.client.ClientConnection.getCloseSetter. Annotations @Override

getCloseSetter

back to summary

public ChannelListener.Setter<? extends HttpClientConnection> getCloseSetter()

Implements io.undertow.client.ClientConnection.getCloseSetter.

Annotations

@Override

getConnection	back to summary
pack-priv StreamConnection getConnection()

getIoThread	back to summary
public XnioIoThread getIoThread() Implements io.undertow.client.ClientConnection.getIoThread. Annotations @Override

getIoThread

back to summary

public XnioIoThread getIoThread()

Implements io.undertow.client.ClientConnection.getIoThread.

Annotations

@Override

getLocalAddress	back to summary
public SocketAddress getLocalAddress() Implements io.undertow.client.ClientConnection.getLocalAddress. Annotations @Override

getLocalAddress

back to summary

public SocketAddress getLocalAddress()

Implements io.undertow.client.ClientConnection.getLocalAddress.

Annotations

@Override

getLocalAddress	back to summary
public <A extends SocketAddress> A getLocalAddress(Class<A> type) Implements io.undertow.client.ClientConnection.getLocalAddress. Annotations @Override

getLocalAddress

back to summary

public <A extends SocketAddress> A getLocalAddress(Class<A> type)

Implements io.undertow.client.ClientConnection.getLocalAddress.

Annotations

@Override

getOption	back to summary
public <T> T getOption(Option<T> option) throws IOException Implements io.undertow.client.ClientConnection.getOption. Annotations @Override

getOption

back to summary

public <T> T getOption(Option<T> option) throws IOException

Implements io.undertow.client.ClientConnection.getOption.

Annotations

@Override

getPeerAddress	back to summary
public SocketAddress getPeerAddress() Implements io.undertow.client.ClientConnection.getPeerAddress. Annotations @Override

getPeerAddress

back to summary

public SocketAddress getPeerAddress()

Implements io.undertow.client.ClientConnection.getPeerAddress.

Annotations

@Override

getPeerAddress	back to summary
public <A extends SocketAddress> A getPeerAddress(Class<A> type) Implements io.undertow.client.ClientConnection.getPeerAddress. Annotations @Override

getPeerAddress

back to summary

public <A extends SocketAddress> A getPeerAddress(Class<A> type)

Implements io.undertow.client.ClientConnection.getPeerAddress.

Annotations

@Override

getStatistics back to summary

getStatistics	back to summary
public ClientStatistics getStatistics() Implements io.undertow.client.ClientConnection.getStatistics. Returns:ClientStatistics Doc from io.undertow.client.ClientConnection.getStatistics. the statistics information, or `null` if statistics are not supported or disabled Annotations @Override

public ClientStatistics getStatistics()

Implements io.undertow.client.ClientConnection.getStatistics.

Returns:ClientStatistics

Doc from io.undertow.client.ClientConnection.getStatistics.

the statistics information, or null if statistics are not supported or disabled

Annotations

@Override

getWorker	back to summary
public XnioWorker getWorker() Implements io.undertow.client.ClientConnection.getWorker. Annotations @Override

getWorker

back to summary

public XnioWorker getWorker()

Implements io.undertow.client.ClientConnection.getWorker.

Annotations

@Override

handleError	back to summary
private void handleError(Throwable exception)

handleError	back to summary
private void handleError(IOException exception)

initiateRequest	back to summary
private void initiateRequest(HttpClientExchange httpClientExchange)

isMultiplexingSupported back to summary

public boolean isMultiplexingSupported()

Implements io.undertow.client.ClientConnection.isMultiplexingSupported.

Returns:boolean

Doc from io.undertow.client.ClientConnection.isMultiplexingSupported.

true if this client supports multiplexing

Annotations

@Override

isOpen back to summary

public boolean isOpen()

Implements io.undertow.client.ClientConnection.isOpen.

Doc from java.nio.channels.Channel.isOpen.

Tells whether or not this channel is open.

Returns:boolean

true if, and only if, this channel is open

Annotations

@Override

isPushSupported back to summary

public boolean isPushSupported()

Implements io.undertow.client.ClientConnection.isPushSupported.

Returns:boolean

Doc from io.undertow.client.ClientConnection.isPushSupported.

true if this connection support server push

Annotations

@Override

isUpgraded

back to summary

public boolean isUpgraded()

Implements io.undertow.client.ClientConnection.isUpgraded.

Annotations

@Override

isUpgradeSupported

back to summary

public boolean isUpgradeSupported()

Implements io.undertow.client.ClientConnection.isUpgradeSupported.

Annotations

@Override

performUpgrade

back to summary

public StreamConnection performUpgrade() throws IOException

Implements io.undertow.client.ClientConnection.performUpgrade.

Doc from io.undertow.client.ClientConnection.performUpgrade.

Upgrade the connection, if the underlying protocol supports it. This should only be called after an upgrade request has been submitted and the target server has accepted the upgrade.

Returns:StreamConnection: The resulting StreamConnection

prepareResponseChannel	back to summary
private void prepareResponseChannel(ClientResponse response, ClientExchange exchange)

requestDataSent	back to summary
public void requestDataSent()

sendRequest back to summary

public void sendRequest(final ClientRequest request, final ClientCallback<ClientExchange> clientCallback)

Implements io.undertow.client.ClientConnection.sendRequest.

Doc from io.undertow.client.ClientConnection.sendRequest.

Sends a client request. The request object should not be modified after it has been submitted to the connection.

Request objects can be queued. Once the request is in a state that it is ready to be sent the clientCallback is invoked to provide the caller with the ClientExchange

If isMultiplexingSupported() returns true then multiple requests may be active at the same time, and a later request may complete before an earlier one.

Note that the request header may not be written out until after the callback has been invoked. This allows the client to write out a header with a gathering write if the request contains content.

Parameters

request:ClientRequest: The request to send.

Annotations

@Override

setOption

back to summary

public <T> T setOption(Option<T> option, T value) throws IllegalArgumentException, IOException

Implements io.undertow.client.ClientConnection.setOption.

Annotations

@Override

supportsOption

back to summary

public boolean supportsOption(Option<?> option)

Implements io.undertow.client.ClientConnection.supportsOption.

Annotations

@Override

io.undertow.client.http back to summary

pack-priv Class HttpClientConnection.ClientReadListener

Class Inheritance

extends Object
implements ChannelListener<StreamSourceChannel>

java.lang.Object
io.undertow.client.http.HttpClientConnection.ClientReadListener

All Implemented Interfaces

org.xnio.ChannelListener, java.util.EventListener

Constructor Summary

Access	Constructor and Description
pack-priv	ClientReadListener()

Method Summary

Modifier and Type	Method and Description
public void	handleEvent(StreamSourceChannel the channel event channel) Implements org.xnio.ChannelListener.handleEvent. Handle the event on this channel.

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

Constructor Detail

ClientReadListener	back to summary
pack-priv ClientReadListener()

Method Detail

handleEvent

back to summary

public void handleEvent(StreamSourceChannel channel)

Implements org.xnio.ChannelListener.handleEvent.

Doc from org.xnio.ChannelListener.handleEvent.

Handle the event on this channel.

Parameters

channel:StreamSourceChannel: the channel event

io.undertow.client.http back to summary

private Class HttpClientConnection.ClientStatisticsImpl

Class Inheritance

extends Object
implements ClientStatistics

java.lang.Object
io.undertow.client.http.HttpClientConnection.ClientStatisticsImpl

All Implemented Interfaces

io.undertow.client.ClientStatistics

Constructor Summary

Access	Constructor and Description
private	ClientStatisticsImpl()

Method Summary

Modifier and Type	Method and Description
public long	getRead() Implements io.undertow.client.ClientStatistics.getRead.
public long	getRequests() Implements io.undertow.client.ClientStatistics.getRequests.
public long	getWritten() Implements io.undertow.client.ClientStatistics.getWritten.
public void	reset() Implements io.undertow.client.ClientStatistics.reset.