org.jboss.remoting3.remote

Class RemoteConnectionProvider

java.lang.Object

org.jboss.remoting3.spi.AbstractHandleableCloseable<ConnectionProvider>

org.jboss.remoting3.remote.RemoteConnectionProvider

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, HandleableCloseable<ConnectionProvider>, ConnectionProvider

Direct Known Subclasses:

HttpUpgradeConnectionProvider

class RemoteConnectionProvider
extends AbstractHandleableCloseable<ConnectionProvider>
implements ConnectionProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	RemoteConnectionProvider.AcceptListener
(package private) class	RemoteConnectionProvider.ProviderInterface

Nested classes/interfaces inherited from interface org.jboss.remoting3.HandleableCloseable

HandleableCloseable.Key

Field Summary

Fields

Modifier and Type	Field and Description
private ConnectionProviderContext	connectionProviderContext
(package private) static org.xnio.Pool<java.nio.ByteBuffer>	GLOBAL_POOL
private java.util.Set<RemoteConnectionHandler>	handlers
(package private) static boolean	LEAK_DEBUGGING
private javax.management.ObjectName	objectName
private java.util.Collection<org.xnio.Cancellable>	pendingInboundConnections
private RemoteConnectionProvider.ProviderInterface	providerInterface
private javax.management.MBeanServer	server
private boolean	sslEnabled
(package private) static boolean	USE_POOLING
private org.xnio.Xnio	xnio
private org.xnio.XnioWorker	xnioWorker

Fields inherited from interface org.jboss.remoting3.spi.ConnectionProvider

NO_PROVIDER_INTERFACES

Constructor Summary

Constructors

Constructor and Description
RemoteConnectionProvider(org.xnio.OptionMap optionMap, ConnectionProviderContext connectionProviderContext)

Method Summary

Modifier and Type	Method and Description
(package private) void	addConnectionHandler(RemoteConnectionHandler connectionHandler)
protected void	closeAction() Called exactly once when the close() method is invoked; the actual close operation should take place here.
org.xnio.Cancellable	connect(java.net.SocketAddress bindAddress, java.net.SocketAddress destination, org.xnio.OptionMap connectOptions, org.xnio.Result<ConnectionHandlerFactory> result, javax.security.auth.callback.CallbackHandler callbackHandler, org.xnio.ssl.XnioSsl xnioSsl) Open an outbound connection, using the (optionally) given socket addresses as source and destination.
protected org.xnio.IoFuture<org.xnio.channels.ConnectedStreamChannel>	createConnection(java.net.SocketAddress bindAddress, java.net.SocketAddress destination, org.xnio.OptionMap connectOptions, org.xnio.ChannelListener<org.xnio.channels.ConnectedStreamChannel> openListener)
protected org.xnio.IoFuture<org.xnio.channels.ConnectedSslStreamChannel>	createSslConnection(java.net.SocketAddress bindAddress, java.net.InetSocketAddress destination, org.xnio.OptionMap connectOptions, org.xnio.ssl.XnioSsl xnioSsl, org.xnio.ChannelListener<org.xnio.channels.ConnectedStreamChannel> openListener)
private void	doDumpConnectionState()
private java.lang.String	doGetConnectionState()
private void	doGetConnectionState(java.lang.StringBuilder b)
ConnectionProviderContext	getConnectionProviderContext()
protected java.util.concurrent.Executor	getExecutor() Get the executor to use for handler invocation.
java.lang.Object	getProviderInterface() Get the user data associated with this connection provider.
protected org.xnio.XnioWorker	getXnioWorker()
(package private) void	removeConnectionHandler(RemoteConnectionHandler connectionHandler)
private static java.io.IOException	sslConfigFailure(java.security.GeneralSecurityException e)
java.lang.String	toString()

Methods inherited from class org.jboss.remoting3.spi.AbstractHandleableCloseable

addCloseHandler, awaitClosed, awaitClosedUninterruptibly, checkOpen, close, closeAsync, closeComplete, closeFailed, finalize, isOpen

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jboss.remoting3.HandleableCloseable

addCloseHandler, awaitClosed, awaitClosedUninterruptibly, close, closeAsync

Field Detail

USE_POOLING

static final boolean USE_POOLING

LEAK_DEBUGGING

static final boolean LEAK_DEBUGGING

GLOBAL_POOL

static final org.xnio.Pool<java.nio.ByteBuffer> GLOBAL_POOL

providerInterface

private final RemoteConnectionProvider.ProviderInterface providerInterface

xnio

private final org.xnio.Xnio xnio

xnioWorker

private final org.xnio.XnioWorker xnioWorker

connectionProviderContext

private final ConnectionProviderContext connectionProviderContext

sslEnabled

private final boolean sslEnabled

pendingInboundConnections

private final java.util.Collection<org.xnio.Cancellable> pendingInboundConnections

handlers

private final java.util.Set<RemoteConnectionHandler> handlers

server

private final javax.management.MBeanServer server

objectName

private final javax.management.ObjectName objectName

Constructor Detail

RemoteConnectionProvider

RemoteConnectionProvider(org.xnio.OptionMap optionMap,
                         ConnectionProviderContext connectionProviderContext)
                  throws java.io.IOException

Throws:

java.io.IOException

Method Detail

doDumpConnectionState

private void doDumpConnectionState()

doGetConnectionState

private void doGetConnectionState(java.lang.StringBuilder b)

doGetConnectionState

private java.lang.String doGetConnectionState()

connect

public org.xnio.Cancellable connect(java.net.SocketAddress bindAddress,
                                    java.net.SocketAddress destination,
                                    org.xnio.OptionMap connectOptions,
                                    org.xnio.Result<ConnectionHandlerFactory> result,
                                    javax.security.auth.callback.CallbackHandler callbackHandler,
                                    org.xnio.ssl.XnioSsl xnioSsl)
                             throws java.lang.IllegalArgumentException

Description copied from interface: ConnectionProvider

Open an outbound connection, using the (optionally) given socket addresses as source and destination. This method is expected to be non-blocking, with the result stored in the result variable possibly asynchronously.

Specified by:

connect in interface ConnectionProvider

Parameters:

bindAddress - the local address to bind to for this outbound connection, or null to choose one automatically

destination - the destination socket address, or null if none is given

connectOptions - the options to use for this connection

result - the result which should receive the connection

callbackHandler - the callback handler to use for authentication

xnioSsl - the XNIO SSL context to use

Returns:

a handle which may be used to cancel the connect attempt

Throws:

java.lang.IllegalArgumentException - if any of the given arguments are not valid for this protocol

createConnection

protected org.xnio.IoFuture<org.xnio.channels.ConnectedStreamChannel> createConnection(java.net.SocketAddress bindAddress,
                                                                                       java.net.SocketAddress destination,
                                                                                       org.xnio.OptionMap connectOptions,
                                                                                       org.xnio.ChannelListener<org.xnio.channels.ConnectedStreamChannel> openListener)

createSslConnection

protected org.xnio.IoFuture<org.xnio.channels.ConnectedSslStreamChannel> createSslConnection(java.net.SocketAddress bindAddress,
                                                                                             java.net.InetSocketAddress destination,
                                                                                             org.xnio.OptionMap connectOptions,
                                                                                             org.xnio.ssl.XnioSsl xnioSsl,
                                                                                             org.xnio.ChannelListener<org.xnio.channels.ConnectedStreamChannel> openListener)

getProviderInterface

public java.lang.Object getProviderInterface()

Description copied from interface: ConnectionProvider

Get the user data associated with this connection provider. This object should implement all of the provider interfaces which are supported by this provider. Must not return null.

Specified by:

getProviderInterface in interface ConnectionProvider

Returns:

the user data (not null)

See Also:

NetworkServerProvider

closeAction

protected void closeAction()

Description copied from class: AbstractHandleableCloseable

Called exactly once when the close() method is invoked; the actual close operation should take place here. This method must call AbstractHandleableCloseable.closeComplete(), directly or indirectly, for the close operation to finish (it may happen in another thread but it must happen). This method should not expect the AbstractHandleableCloseable.closeComplete() call to be made from another thread from the same thread pool that may cause AbstractHandleableCloseable.close(). As close will block, this can result in situations where all threads in the pool are blocked on AbstractHandleableCloseable.close() method calls, which means the AbstractHandleableCloseable.closeComplete() will never be run.

Overrides:

closeAction in class AbstractHandleableCloseable<ConnectionProvider>

addConnectionHandler

void addConnectionHandler(RemoteConnectionHandler connectionHandler)

removeConnectionHandler

void removeConnectionHandler(RemoteConnectionHandler connectionHandler)

getExecutor

protected java.util.concurrent.Executor getExecutor()

Description copied from class: AbstractHandleableCloseable

Get the executor to use for handler invocation.

Overrides:

getExecutor in class AbstractHandleableCloseable<ConnectionProvider>

Returns:

the executor

sslConfigFailure

private static java.io.IOException sslConfigFailure(java.security.GeneralSecurityException e)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getXnioWorker

protected org.xnio.XnioWorker getXnioWorker()

getConnectionProviderContext

public ConnectionProviderContext getConnectionProviderContext()