org.eclipse.jetty.server

Class ServerConnector.ServerConnectorManager

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.io.SelectorManager

org.eclipse.jetty.server.ServerConnector.ServerConnectorManager

All Implemented Interfaces:

Dumpable, LifeCycle

Enclosing class:

ServerConnector

protected class ServerConnector.ServerConnectorManager
extends SelectorManager

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

LifeCycle.Listener

Field Summary

Fields inherited from class org.eclipse.jetty.io.SelectorManager

DEFAULT_CONNECT_TIMEOUT, LOG

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Constructor Summary

Constructors

Constructor and Description
ServerConnectorManager(Executor executor, Scheduler scheduler, int selectors)

Method Summary

Modifier and Type	Method and Description
protected void	accepted(SocketChannel channel) Callback method when a channel is accepted from the ServerSocketChannel passed to SelectorManager.acceptor(ServerSocketChannel).
protected void	endPointClosed(EndPoint endpoint) Callback method invoked when an endpoint is closed.
protected void	endPointOpened(EndPoint endpoint) Callback method invoked when an endpoint is opened.
Connection	newConnection(SocketChannel channel, EndPoint endpoint, Object attachment) Factory method to create Connection.
protected SelectChannelEndPoint	newEndPoint(SocketChannel channel, ManagedSelector selectSet, SelectionKey selectionKey) Factory method to create EndPoint.

Methods inherited from class org.eclipse.jetty.io.SelectorManager

accept, accept, acceptor, connect, connectionClosed, connectionFailed, connectionOpened, doStart, doStop, dump, dump, execute, finishConnect, getConnectTimeout, getExecutor, getScheduler, getSelectorCount, getSelectorPriorityDelta, newSelector, setConnectTimeout, setSelectorPriorityDelta

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, setStopTimeout, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerConnectorManager

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

Method Detail

accepted

protected void accepted(SocketChannel channel)
                 throws IOException

Description copied from class: SelectorManager

Callback method when a channel is accepted from the ServerSocketChannel passed to SelectorManager.acceptor(ServerSocketChannel). The default impl throws an UnsupportedOperationException, so it must be overridden by subclasses if a server channel is provided.

Overrides:

accepted in class SelectorManager

Parameters:

channel - the

Throws:

IOException - if unable to accept channel

newEndPoint

protected SelectChannelEndPoint newEndPoint(SocketChannel channel,
                                            ManagedSelector selectSet,
                                            SelectionKey selectionKey)
                                     throws IOException

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(SocketChannel, Object) or SelectorManager.accept(SocketChannel).

Specified by:

newEndPoint in class SelectorManager

Parameters:

channel - the channel associated to the endpoint

selectSet - the selector the channel is registered to

selectionKey - the selection key

Returns:

a new endpoint

Throws:

IOException - if the endPoint cannot be created

See Also:

SelectorManager.newConnection(SocketChannel, EndPoint, Object)

newConnection

public Connection newConnection(SocketChannel 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

See Also:

SelectorManager.newEndPoint(SocketChannel, ManagedSelector, SelectionKey)

endPointOpened

protected void endPointOpened(EndPoint endpoint)

Description copied from class: SelectorManager

Callback method invoked when an endpoint is opened.

Overrides:

endPointOpened in class SelectorManager

Parameters:

endpoint - the endpoint being opened

endPointClosed

protected void endPointClosed(EndPoint endpoint)

Description copied from class: SelectorManager

Callback method invoked when an endpoint is closed.

Overrides:

endPointClosed in class SelectorManager

Parameters:

endpoint - the endpoint being closed