org.eclipse.jetty.server.nio
Class NetworkTrafficSelectChannelConnector

java.lang.Object
  extended by org.eclipse.jetty.util.component.AbstractLifeCycle
      extended by org.eclipse.jetty.http.HttpBuffers
          extended by org.eclipse.jetty.server.AbstractConnector
              extended by org.eclipse.jetty.server.nio.AbstractNIOConnector
                  extended by org.eclipse.jetty.server.nio.SelectChannelConnector
                      extended by org.eclipse.jetty.server.nio.NetworkTrafficSelectChannelConnector
All Implemented Interfaces:
Connector, NIOConnector, Dumpable, LifeCycle

public class NetworkTrafficSelectChannelConnector
extends SelectChannelConnector

A specialized version of SelectChannelConnector that supports NetworkTrafficListeners.

NetworkTrafficListeners can be added and removed dynamically before and after this connector has been started without causing ConcurrentModificationExceptions.


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.server.nio.SelectChannelConnector
_acceptChannel
 
Fields inherited from class org.eclipse.jetty.server.AbstractConnector
_lowResourceMaxIdleTime, _maxIdleTime, _soLingerTime
 
Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
_listeners, FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING
 
Constructor Summary
NetworkTrafficSelectChannelConnector()
           
 
Method Summary
 void addNetworkTrafficListener(NetworkTrafficListener listener)
           
protected  void endPointClosed(SelectChannelEndPoint endpoint)
           
protected  SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectorManager.SelectSet selectSet, SelectionKey key)
           
 void removeNetworkTrafficListener(NetworkTrafficListener listener)
           
 
Methods inherited from class org.eclipse.jetty.server.nio.SelectChannelConnector
accept, close, customize, doStart, doStop, dump, getConnection, getLocalPort, getLowResourcesConnections, getLowResourcesMaxIdleTime, newConnection, open, persist, setLowResourcesConnections, setLowResourcesMaxIdleTime, setMaxIdleTime
 
Methods inherited from class org.eclipse.jetty.server.nio.AbstractNIOConnector
getUseDirectBuffers, setUseDirectBuffers
 
Methods inherited from class org.eclipse.jetty.server.AbstractConnector
checkForwardedHeaders, configure, connectionClosed, connectionOpened, connectionUpgraded, dump, getAcceptorPriorityOffset, getAcceptors, getAcceptQueueSize, getConfidentialPort, getConfidentialScheme, getConnections, getConnectionsDurationMax, getConnectionsDurationMean, getConnectionsDurationStdDev, getConnectionsDurationTotal, getConnectionsOpen, getConnectionsOpenMax, getConnectionsRequestsMax, getConnectionsRequestsMean, getConnectionsRequestsStdDev, getForwardedCipherSuiteHeader, getForwardedForHeader, getForwardedHostHeader, getForwardedProtoHeader, getForwardedServerHeader, getForwardedSslSessionIdHeader, getHost, getHostHeader, getIntegralPort, getIntegralScheme, getLeftMostFieldValue, getLowResourceMaxIdleTime, getMaxIdleTime, getName, getPort, getRequests, getResolveNames, getReuseAddress, getServer, getSoLingerTime, getStatsOn, getStatsOnMs, getThreadPool, isConfidential, isForwarded, isIntegral, isLowResources, join, setAcceptorPriorityOffset, setAcceptors, setAcceptQueueSize, setConfidentialPort, setConfidentialScheme, setForwarded, setForwardedCipherSuiteHeader, setForwardedForHeader, setForwardedHostHeader, setForwardedProtoHeader, setForwardedServerHeader, setForwardedSslSessionIdHeader, setHost, setHostHeader, setIntegralPort, setIntegralScheme, setLowResourceMaxIdleTime, setName, setPort, setResolveNames, setReuseAddress, setServer, setSoLingerTime, setStatsOn, setThreadPool, statsReset, stopAccept, toString
 
Methods inherited from class org.eclipse.jetty.http.HttpBuffers
getMaxBuffers, getRequestBuffers, getRequestBufferSize, getRequestBufferType, getRequestHeaderSize, getRequestHeaderType, getResponseBuffers, getResponseBufferSize, getResponseBufferType, getResponseHeaderSize, getResponseHeaderType, setMaxBuffers, setRequestBuffers, setRequestBufferSize, setRequestBufferType, setRequestHeaderSize, setRequestHeaderType, setResponseBuffers, setResponseBufferSize, setResponseBufferType, setResponseHeaderSize, setResponseHeaderType
 
Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
addLifeCycleListener, getState, getState, 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.server.Connector
getRequestBuffers, getRequestBufferSize, getRequestHeaderSize, getResponseBuffers, getResponseBufferSize, getResponseHeaderSize, setRequestBufferSize, setRequestHeaderSize, setResponseBufferSize, setResponseHeaderSize
 
Methods inherited from interface org.eclipse.jetty.util.component.LifeCycle
addLifeCycleListener, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop
 

Constructor Detail

NetworkTrafficSelectChannelConnector

public NetworkTrafficSelectChannelConnector()
Method Detail

addNetworkTrafficListener

public void addNetworkTrafficListener(NetworkTrafficListener listener)
Parameters:
listener - the listener to add

removeNetworkTrafficListener

public void removeNetworkTrafficListener(NetworkTrafficListener listener)
Parameters:
listener - the listener to remove

newEndPoint

protected SelectChannelEndPoint newEndPoint(SocketChannel channel,
                                            SelectorManager.SelectSet selectSet,
                                            SelectionKey key)
                                     throws IOException
Overrides:
newEndPoint in class SelectChannelConnector
Throws:
IOException

endPointClosed

protected void endPointClosed(SelectChannelEndPoint endpoint)
Overrides:
endPointClosed in class SelectChannelConnector


Copyright © 1995-2011 Mort Bay Consulting. All Rights Reserved.