Class ClientConnector.ClientSelectorManager

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.io.SelectorManager

org.eclipse.jetty.io.ClientConnector.ClientSelectorManager

All Implemented Interfaces:

Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle

Enclosing class:

ClientConnector

protected class ClientConnector.ClientSelectorManager
extends SelectorManager

Nested Class Summary

Nested classes/interfaces inherited from class SelectorManager

SelectorManager.AcceptListener, SelectorManager.SelectorManagerListener

Nested classes/interfaces inherited from class AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener, AbstractLifeCycle.StopException

Nested classes/interfaces inherited from interface Container

Container.InheritedListener, Container.Listener

Nested classes/interfaces inherited from interface Dumpable

Dumpable.DumpableContainer

Nested classes/interfaces inherited from interface LifeCycle

LifeCycle.Listener

Field Summary

Fields inherited from class SelectorManager

DEFAULT_CONNECT_TIMEOUT

Fields inherited from class AbstractLifeCycle

FAILED, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface Dumpable

KEY

Constructor Summary

Constructors

Constructor	Description
ClientSelectorManager(Executor executor, Scheduler scheduler, int selectors)

Method Summary

Modifier and Type	Method	Description
protected void	connectionFailed(SelectableChannel channel, Throwable failure, Object attachment)	Callback method invoked when a non-blocking connect failed.
void	connectionOpened(Connection connection, Object context)	Callback method invoked when a connection is opened.
void	connectionSucceeded(SelectableChannel channel)	Callback method invoked when a non-blocking connect was succeeded.
Connection	newConnection(SelectableChannel channel, EndPoint endPoint, Object attachment)	Factory method to create Connection.
protected EndPoint	newEndPoint(SelectableChannel channel, ManagedSelector selector, SelectionKey selectionKey)	Factory method to create EndPoint.

Methods inherited from class SelectorManager

accept, accept, accepted, acceptor, addEventListener, chooseSelector, connect, connectionClosed, doAccept, doFinishConnect, doStart, doStop, endPointClosed, endPointOpened, execute, getConnectTimeout, getExecutor, getScheduler, getSelectorCount, getTotalKeys, isConnectionPending, newSelector, newSelector, onAccepted, onAcceptFailed, onAccepting, removeEventListener, setConnectTimeout, toString

Methods inherited from class ContainerLifeCycle

addBean, addBean, addManaged, contains, destroy, dump, dump, dump, dumpObjects, dumpStdErr, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, installBean, installBean, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, setBeans, start, stop, unmanage, updateBean, updateBean, updateBeans, updateBeans

Methods inherited from class AbstractLifeCycle

getEventListeners, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, setEventListeners, start, stop

Methods inherited from class Object

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

Methods inherited from interface Container

getCachedBeans, getEventListeners

Methods inherited from interface Dumpable

dump, dump, dumpSelf

Methods inherited from interface Dumpable.DumpableContainer

isDumpable

Constructor Details

ClientSelectorManager

public ClientSelectorManager(Executor executor,
 Scheduler scheduler,
 int selectors)

Method Details

newEndPoint

protected EndPoint newEndPoint(SelectableChannel channel,
 ManagedSelector selector,
 SelectionKey selectionKey)

Description copied from class: SelectorManager

Factory method to create EndPoint.

This method is invoked as a result of the registration of a channel via SelectorManager.connect(SelectableChannel, Object) or SelectorManager.accept(SelectableChannel).

Specified by:

newEndPoint in class SelectorManager

Parameters:

channel - the channel associated to the endpoint

selector - the selector the channel is registered to

selectionKey - the selection key

Returns:

a new endpoint

See Also:

• SelectorManager.newConnection(SelectableChannel, EndPoint, Object)

newConnection

public Connection newConnection(SelectableChannel channel,
 EndPoint endPoint,
 Object attachment)
                         throws IOException

Description copied from class: SelectorManager

Factory method to create Connection.

Specified by:

newConnection in class SelectorManager

Parameters:

channel - the channel associated to the connection

endPoint - the endpoint

attachment - the attachment

Returns:

a new connection

Throws:

IOException - if unable to create new connection

connectionOpened

public void connectionOpened(Connection connection,
 Object context)

Description copied from class: SelectorManager

Callback method invoked when a connection is opened.

Overrides:

connectionOpened in class SelectorManager

Parameters:

connection - the connection just opened

context - the attachment associated with the creation of the connection

See Also:

• SelectorManager.newConnection(SelectableChannel, EndPoint, Object)

connectionSucceeded

public void connectionSucceeded(SelectableChannel channel)

Description copied from class: SelectorManager

Callback method invoked when a non-blocking connect was succeeded.

Overrides:

connectionSucceeded in class SelectorManager

Parameters:

channel - the channel that attempted the connect

connectionFailed

protected void connectionFailed(SelectableChannel channel,
 Throwable failure,
 Object attachment)

Description copied from class: SelectorManager

Callback method invoked when a non-blocking connect failed.

Overrides:

connectionFailed in class SelectorManager

Parameters:

channel - the channel that attempted the connect

failure - the exception that caused the connect to fail

attachment - the attachment object associated at registration