Top Description Inners Fields Constructors Methods
io.undertow.client.http2

public Class Http2PriorKnowledgeClientProvider

extends Object
implements ClientProvider
Class Inheritance
All Implemented Interfaces
io.undertow.client.ClientProvider
Imports
io.undertow.UndertowOptions, io.undertow.client.ClientCallback, .ClientConnection, .ClientProvider, .ClientStatistics, io.undertow.conduits.ByteActivityCallback, .BytesReceivedStreamSourceConduit, .BytesSentStreamSinkConduit, io.undertow.protocols.http2.Http2Channel, org.xnio.ChannelListener, .IoFuture, .OptionMap, .StreamConnection, .XnioIoThread, .XnioWorker, io.undertow.connector.ByteBufferPool, org.xnio.conduits.ConduitStreamSinkChannel, org.xnio.ssl.XnioSsl, java.io.IOException, java.net.InetSocketAddress, .URI, java.nio.ByteBuffer, java.util.Arrays, .HashSet, .Set
HTTP2 client provider that connects to endpoints that are known to support HTTP2
Author
Stuart Douglas

Nested and Inner Type Summary

Modifier and TypeClass and Description
private static class
Http2PriorKnowledgeClientProvider.ClientStatisticsImpl

Field Summary

Modifier and TypeField and Description
private static final byte[]
PRI_REQUEST

Constructor Summary

AccessConstructor and Description
public
Http2PriorKnowledgeClientProvider()

Method Summary

Modifier and TypeMethod 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 IoFuture.Notifier<StreamConnection, Object>
createNotifier(final ClientCallback<ClientConnection> listener)

private ChannelListener<StreamConnection>
createOpenListener(final ClientCallback<ClientConnection> listener, final ByteBufferPool bufferPool, final OptionMap options, final String defaultHost)

private void
handleConnected(final StreamConnection connection, final ClientCallback<ClientConnection> listener, final ByteBufferPool bufferPool, final OptionMap options, final String defaultHost)

public Set<String>
handlesSchemes()

Implements io.undertow.client.ClientProvider.handlesSchemes.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

PRI_REQUESTback to summary
private static final byte[] PRI_REQUEST

Constructor Detail

Http2PriorKnowledgeClientProviderback to summary
public Http2PriorKnowledgeClientProvider()

Method Detail

connectback 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
connectback 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
connectback 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
connectback 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
createNotifierback to summary
private IoFuture.Notifier<StreamConnection, Object> createNotifier(final ClientCallback<ClientConnection> listener)
createOpenListenerback to summary
private ChannelListener<StreamConnection> createOpenListener(final ClientCallback<ClientConnection> listener, final ByteBufferPool bufferPool, final OptionMap options, final String defaultHost)
handleConnectedback to summary
private void handleConnected(final StreamConnection connection, final ClientCallback<ClientConnection> listener, final ByteBufferPool bufferPool, final OptionMap options, final String defaultHost)
handlesSchemesback to summary
public Set<String> handlesSchemes()

Implements io.undertow.client.ClientProvider.handlesSchemes.

Annotations
@Override
io.undertow.client.http2 back to summary

private Class Http2PriorKnowledgeClientProvider.ClientStatisticsImpl

extends Object
implements ClientStatistics
Class Inheritance
  • java.lang.Object
  • io.undertow.client.http2.Http2PriorKnowledgeClientProvider.ClientStatisticsImpl
All Implemented Interfaces
io.undertow.client.ClientStatistics

Field Summary

Modifier and TypeField and Description
private long
read

private long
requestCount

private long
written

Constructor Summary

AccessConstructor and Description
private
ClientStatisticsImpl()

Method Summary

Modifier and TypeMethod 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.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

readback to summary
private long read
requestCountback to summary
private long requestCount
writtenback to summary
private long written

Constructor Detail

ClientStatisticsImplback to summary
private ClientStatisticsImpl()

Method Detail

getReadback to summary
public long getRead()

Implements io.undertow.client.ClientStatistics.getRead.

Annotations
@Override
getRequestsback to summary
public long getRequests()

Implements io.undertow.client.ClientStatistics.getRequests.

Annotations
@Override
getWrittenback to summary
public long getWritten()

Implements io.undertow.client.ClientStatistics.getWritten.

Annotations
@Override
resetback to summary
public void reset()

Implements io.undertow.client.ClientStatistics.reset.

Annotations
@Override