Package org.eclipse.jetty.server
Class ServerConnector.ServerConnectorManager
- java.lang.Object
-
- org.eclipse.jetty.util.component.AbstractLifeCycle
-
- org.eclipse.jetty.util.component.ContainerLifeCycle
-
- org.eclipse.jetty.io.SelectorManager
-
- org.eclipse.jetty.server.ServerConnector.ServerConnectorManager
-
- All Implemented Interfaces:
Container
,Destroyable
,Dumpable
,Dumpable.DumpableContainer
,LifeCycle
- Enclosing class:
- ServerConnector
protected class ServerConnector.ServerConnectorManager extends SelectorManager
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.eclipse.jetty.io.SelectorManager
SelectorManager.AcceptListener
-
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.Container
Container.InheritedListener, Container.Listener
-
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable
Dumpable.DumpableContainer
-
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
-
-
Constructor Summary
Constructors Constructor Description ServerConnectorManager(java.util.concurrent.Executor executor, Scheduler scheduler, int selectors)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
accepted(java.nio.channels.SelectableChannel channel)
Callback method when a channel is accepted from theServerSocketChannel
passed toSelectorManager.acceptor(SelectableChannel)
.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(java.nio.channels.SelectableChannel channel, EndPoint endpoint, java.lang.Object attachment)
Factory method to createConnection
.protected ChannelEndPoint
newEndPoint(java.nio.channels.SelectableChannel channel, ManagedSelector selectSet, java.nio.channels.SelectionKey selectionKey)
Factory method to createEndPoint
.java.lang.String
toString()
-
Methods inherited from class org.eclipse.jetty.io.SelectorManager
accept, accept, acceptor, addAcceptListener, addEventListener, connect, connectionClosed, connectionFailed, connectionOpened, doAccept, doFinishConnect, doStart, doStop, execute, getConnectTimeout, getExecutor, getReservedThreads, getScheduler, getSelectorCount, isConnectionPending, newSelector, newSelector, onAccepted, onAcceptFailed, onAccepting, removeAcceptListener, removeEventListener, setConnectTimeout, setReservedThreads
-
Methods inherited from class org.eclipse.jetty.util.component.ContainerLifeCycle
addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dump, dump, dump, dumpBeans, dumpObject, dumpObjects, dumpStdErr, dumpThis, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, updateBean, updateBean, updateBeans
-
Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.eclipse.jetty.util.component.Dumpable.DumpableContainer
isDumpable
-
-
-
-
Constructor Detail
-
ServerConnectorManager
public ServerConnectorManager(java.util.concurrent.Executor executor, Scheduler scheduler, int selectors)
-
-
Method Detail
-
accepted
protected void accepted(java.nio.channels.SelectableChannel channel) throws java.io.IOException
Description copied from class:SelectorManager
Callback method when a channel is accepted from theServerSocketChannel
passed toSelectorManager.acceptor(SelectableChannel)
. The default impl throws anUnsupportedOperationException
, so it must be overridden by subclasses if a server channel is provided.- Overrides:
accepted
in classSelectorManager
- Parameters:
channel
- the- Throws:
java.io.IOException
- if unable to accept channel
-
newEndPoint
protected ChannelEndPoint newEndPoint(java.nio.channels.SelectableChannel channel, ManagedSelector selectSet, java.nio.channels.SelectionKey selectionKey) throws java.io.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(SelectableChannel, Object)
orSelectorManager.accept(SelectableChannel)
.- Specified by:
newEndPoint
in classSelectorManager
- Parameters:
channel
- the channel associated to the endpointselectSet
- the selector the channel is registered toselectionKey
- the selection key- Returns:
- a new endpoint
- Throws:
java.io.IOException
- if the endPoint cannot be created- See Also:
SelectorManager.newConnection(SelectableChannel, EndPoint, Object)
-
newConnection
public Connection newConnection(java.nio.channels.SelectableChannel channel, EndPoint endpoint, java.lang.Object attachment) throws java.io.IOException
Description copied from class:SelectorManager
Factory method to create
Connection
.- Specified by:
newConnection
in classSelectorManager
- Parameters:
channel
- the channel associated to the connectionendpoint
- the endpointattachment
- the attachment- Returns:
- a new connection
- Throws:
java.io.IOException
- if unable to create new connection
-
endPointOpened
protected void endPointOpened(EndPoint endpoint)
Description copied from class:SelectorManager
Callback method invoked when an endpoint is opened.
- Overrides:
endPointOpened
in classSelectorManager
- 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 classSelectorManager
- Parameters:
endpoint
- the endpoint being closed
-
toString
public java.lang.String toString()
- Overrides:
toString
in classAbstractLifeCycle
-
-