Top Description Inners Constructors Methods

io.undertow.client.http2

public Class Http2ClearClientProvider

Class Inheritance

extends Object
implements ClientProvider

java.lang.Object
io.undertow.client.http2.Http2ClearClientProvider

All Implemented Interfaces

io.undertow.client.ClientProvider

Imports

java.io.IOException, java.net.InetSocketAddress, .URI, .URISyntaxException, java.nio.ByteBuffer, java.util.Arrays, .HashMap, .HashSet, .Map, .Set, io.undertow.client.ClientStatistics, .ClientCallback, .ClientConnection, .ClientProvider, io.undertow.conduits.ByteActivityCallback, .BytesReceivedStreamSourceConduit, .BytesSentStreamSinkConduit, org.xnio.ChannelListener, .IoFuture, .OptionMap, .StreamConnection, .XnioIoThread, .XnioWorker, io.undertow.connector.ByteBufferPool, .PooledByteBuffer, org.xnio.channels.BoundChannel, org.xnio.http.HttpUpgrade, org.xnio.ssl.XnioSsl, io.undertow.UndertowOptions, io.undertow.protocols.http2.Http2Channel, .Http2Setting, io.undertow.util.FlexBase64, .Headers

HTTP2 client provider that uses HTTP upgrade rather than ALPN. This provider will only use h2c, and sends an initial dummy request to do the initial upgrade.

Author: Stuart Douglas

Nested and Inner Type Summary

Modifier and Type	Class and Description
private static class	Http2ClearClientProvider.ClientStatisticsImpl
private static class	Http2ClearClientProvider.FailedNotifier
private static class	Http2ClearClientProvider.Http2ClearOpenListener

Constructor Summary

Access	Constructor and Description
public	Http2ClearClientProvider()

Method Summary

Modifier and Type	Method and Description
public void	connect(final ClientCallback<ClientConnection> listener, final URI uri, final XnioWorker worker, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options) Implements io.undertow.client.ClientProvider.connect.
public void	connect(final ClientCallback<ClientConnection> listener, final URI uri, final XnioIoThread ioThread, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options) Implements io.undertow.client.ClientProvider.connect.
public void	connect(final ClientCallback<ClientConnection> listener, InetSocketAddress bindAddress, final URI uri, final XnioWorker worker, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options) Implements io.undertow.client.ClientProvider.connect.
public void	connect(final ClientCallback<ClientConnection> listener, final InetSocketAddress bindAddress, final URI uri, final XnioIoThread ioThread, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options) Implements io.undertow.client.ClientProvider.connect.
private Map<String, String>	createHeaders(OptionMap options, ByteBufferPool bufferPool, URI uri)
public static String	createSettingsFrame(OptionMap options, ByteBufferPool bufferPool)
public Set<String>	handlesSchemes() Implements io.undertow.client.ClientProvider.handlesSchemes.
private static void	pushOption(ByteBuffer currentBuffer, int id, int value)

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

Constructor Detail

Http2ClearClientProvider	back to summary
public Http2ClearClientProvider()

Method Detail

connect	back to summary
public void connect(final ClientCallback<ClientConnection> listener, final URI uri, final XnioWorker worker, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options) Implements io.undertow.client.ClientProvider.connect. Annotations @Override

connect

back to summary

public void connect(final ClientCallback<ClientConnection> listener, final URI uri, final XnioWorker worker, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

Implements io.undertow.client.ClientProvider.connect.

Annotations

@Override

connect	back to summary
public void connect(final ClientCallback<ClientConnection> listener, final URI uri, final XnioIoThread ioThread, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options) Implements io.undertow.client.ClientProvider.connect. Annotations @Override

connect

back to summary

public void connect(final ClientCallback<ClientConnection> listener, final URI uri, final XnioIoThread ioThread, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

Implements io.undertow.client.ClientProvider.connect.

Annotations

@Override

connect	back to summary
public void connect(final ClientCallback<ClientConnection> listener, InetSocketAddress bindAddress, final URI uri, final XnioWorker worker, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options) Implements io.undertow.client.ClientProvider.connect. Annotations @Override

connect

back to summary

public void connect(final ClientCallback<ClientConnection> listener, InetSocketAddress bindAddress, final URI uri, final XnioWorker worker, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

Implements io.undertow.client.ClientProvider.connect.

Annotations

@Override

connect	back to summary
public void connect(final ClientCallback<ClientConnection> listener, final InetSocketAddress bindAddress, final URI uri, final XnioIoThread ioThread, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options) Implements io.undertow.client.ClientProvider.connect. Annotations @Override

connect

back to summary

public void connect(final ClientCallback<ClientConnection> listener, final InetSocketAddress bindAddress, final URI uri, final XnioIoThread ioThread, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

Implements io.undertow.client.ClientProvider.connect.

Annotations

@Override

createHeaders	back to summary
private Map<String, String> createHeaders(OptionMap options, ByteBufferPool bufferPool, URI uri)

createSettingsFrame	back to summary
public static String createSettingsFrame(OptionMap options, ByteBufferPool bufferPool)

handlesSchemes	back to summary
public Set<String> handlesSchemes() Implements io.undertow.client.ClientProvider.handlesSchemes. Annotations @Override

handlesSchemes

back to summary

public Set<String> handlesSchemes()

Implements io.undertow.client.ClientProvider.handlesSchemes.

Annotations

@Override

pushOption	back to summary
private static void pushOption(ByteBuffer currentBuffer, int id, int value)

io.undertow.client.http2 back to summary

private Class Http2ClearClientProvider.ClientStatisticsImpl

Class Inheritance

extends Object
implements ClientStatistics

java.lang.Object
io.undertow.client.http2.Http2ClearClientProvider.ClientStatisticsImpl

All Implemented Interfaces

io.undertow.client.ClientStatistics

Field Summary

Modifier and Type	Field and Description
private long	read
private long	requestCount
private long	written

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	getRequestCount()
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.
public void	setRead(long read)
public void	setRequestCount(long requestCount)
public void	setWritten(long written)

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

Field Detail

read	back to summary
private long read

requestCount	back to summary
private long requestCount

written	back to summary
private long written

Constructor Detail

ClientStatisticsImpl	back to summary
private ClientStatisticsImpl()

Method Detail

getRead	back to summary
public long getRead() Implements io.undertow.client.ClientStatistics.getRead. Annotations @Override

getRead

back to summary

public long getRead()

Implements io.undertow.client.ClientStatistics.getRead.

Annotations

@Override

getRequestCount	back to summary
public long getRequestCount()

getRequests	back to summary
public long getRequests() Implements io.undertow.client.ClientStatistics.getRequests. Annotations @Override

getRequests

back to summary

public long getRequests()

Implements io.undertow.client.ClientStatistics.getRequests.

Annotations

@Override

getWritten	back to summary
public long getWritten() Implements io.undertow.client.ClientStatistics.getWritten. Annotations @Override

getWritten

back to summary

public long getWritten()

Implements io.undertow.client.ClientStatistics.getWritten.

Annotations

@Override

reset	back to summary
public void reset() Implements io.undertow.client.ClientStatistics.reset. Annotations @Override

reset

back to summary

public void reset()

Implements io.undertow.client.ClientStatistics.reset.

Annotations

@Override

setRead	back to summary
public void setRead(long read)

setRequestCount	back to summary
public void setRequestCount(long requestCount)

setWritten	back to summary
public void setWritten(long written)

io.undertow.client.http2 back to summary

private Class Http2ClearClientProvider.FailedNotifier

Class Inheritance

extends Object
implements IoFuture.Notifier<StreamConnection, Object>

java.lang.Object
io.undertow.client.http2.Http2ClearClientProvider.FailedNotifier

All Implemented Interfaces

org.xnio.IoFuture.Notifier, java.util.EventListener

Field Summary

Modifier and Type	Field and Description
private final ClientCallback<ClientConnection>	listener

Constructor Summary

Access	Constructor and Description
pack-priv	FailedNotifier(ClientCallback<ClientConnection> listener)

Method Summary

Modifier and Type	Method and Description
public void	notify(IoFuture<? extends StreamConnection> the future corresponding to this operation ioFuture, Object the attachment attachment) Implements org.xnio.IoFuture.Notifier.notify. Receive notification of the completion of an outstanding operation.

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

Field Detail

listener	back to summary
private final ClientCallback<ClientConnection> listener

Constructor Detail

FailedNotifier	back to summary
pack-priv FailedNotifier(ClientCallback<ClientConnection> listener)

Method Detail

notify	back to summary
public void notify(IoFuture<? extends StreamConnection> ioFuture, Object attachment) Implements org.xnio.IoFuture.Notifier.notify. Doc from org.xnio.IoFuture.Notifier.notify. Receive notification of the completion of an outstanding operation. Parameters ioFuture:IoFuture<? extends StreamConnection> the future corresponding to this operation attachment:Object the attachment Annotations @Override

notify

back to summary

public void notify(IoFuture<? extends StreamConnection> ioFuture, Object attachment)

Implements org.xnio.IoFuture.Notifier.notify.

Doc from org.xnio.IoFuture.Notifier.notify.

Receive notification of the completion of an outstanding operation.

Parameters

ioFuture:IoFuture<? extends StreamConnection>: the future corresponding to this operation
attachment:Object: the attachment

Annotations

@Override

io.undertow.client.http2 back to summary

private Class Http2ClearClientProvider.Http2ClearOpenListener

Class Inheritance

extends Object
implements ChannelListener<StreamConnection>

java.lang.Object
io.undertow.client.http2.Http2ClearClientProvider.Http2ClearOpenListener

All Implemented Interfaces

org.xnio.ChannelListener, java.util.EventListener

Field Summary

Modifier and Type	Field and Description
private final ByteBufferPool	bufferPool
private final String	defaultHost
private final ClientCallback<ClientConnection>	listener
private final OptionMap	options

Constructor Summary

Access	Constructor and Description
pack-priv	Http2ClearOpenListener(ByteBufferPool bufferPool, OptionMap options, ClientCallback<ClientConnection> listener, String defaultHost)

Method Summary

Modifier and Type	Method and Description
public void	handleEvent(StreamConnection 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

Field Detail

bufferPool	back to summary
private final ByteBufferPool bufferPool

defaultHost	back to summary
private final String defaultHost

listener	back to summary
private final ClientCallback<ClientConnection> listener

options	back to summary
private final OptionMap options

Constructor Detail

Http2ClearOpenListener	back to summary
pack-priv Http2ClearOpenListener(ByteBufferPool bufferPool, OptionMap options, ClientCallback<ClientConnection> listener, String defaultHost)

Method Detail

handleEvent	back to summary
public void handleEvent(StreamConnection channel) Implements org.xnio.ChannelListener.handleEvent. Doc from org.xnio.ChannelListener.handleEvent. Handle the event on this channel. Parameters channel:StreamConnection the channel event Annotations @Override

handleEvent

back to summary

public void handleEvent(StreamConnection channel)

Implements org.xnio.ChannelListener.handleEvent.

Doc from org.xnio.ChannelListener.handleEvent.

Handle the event on this channel.

Parameters

channel:StreamConnection: the channel event

Annotations

@Override