org.eclipse.jetty.server.nio

Class BlockingChannelConnector

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.AggregateLifeCycle

org.eclipse.jetty.server.AbstractConnector

org.eclipse.jetty.server.nio.AbstractNIOConnector

org.eclipse.jetty.server.nio.BlockingChannelConnector

All Implemented Interfaces:

HttpBuffers, Connector, NIOConnector, Destroyable, Dumpable, LifeCycle

public class BlockingChannelConnector
extends AbstractNIOConnector

Blocking NIO connector. This connector uses efficient NIO buffers with a traditional blocking thread model. Direct NIO buffers are used and a thread is allocated per connections. This connector is best used when there are a few very active connections.

Apache XBean:

element="blockingNioConnector" description="Creates a blocking NIO based socket connector"

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.AbstractConnector

_buffers, _lowResourceMaxIdleTime, _maxIdleTime, _soLingerTime

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

_listeners, FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Constructor Summary

Constructors

Constructor and Description
BlockingChannelConnector() Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	accept(int acceptorID)
void	close()
void	customize(EndPoint endpoint, Request request) Customize a request for an endpoint.
protected void	doStart()
Object	getConnection()
int	getLocalPort()
void	open() Opens the connector

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, doStop, 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, getLowResourcesMaxIdleTime, getMaxBuffers, getMaxIdleTime, getName, getPort, getRequestBuffers, getRequestBufferSize, getRequestBufferType, getRequestHeaderSize, getRequestHeaderType, getRequests, getResolveNames, getResponseBuffers, getResponseBufferSize, getResponseBufferType, getResponseHeaderSize, getResponseHeaderType, getReuseAddress, getServer, getSoLingerTime, getStatsOn, getStatsOnMs, getThreadPool, isConfidential, isForwarded, isIntegral, isLowResources, join, persist, setAcceptorPriorityOffset, setAcceptors, setAcceptQueueSize, setConfidentialPort, setConfidentialScheme, setForwarded, setForwardedCipherSuiteHeader, setForwardedForHeader, setForwardedHostHeader, setForwardedProtoHeader, setForwardedServerHeader, setForwardedSslSessionIdHeader, setHost, setHostHeader, setIntegralPort, setIntegralScheme, setLowResourceMaxIdleTime, setLowResourcesMaxIdleTime, setMaxBuffers, setMaxIdleTime, setName, setPort, setRequestBuffers, setRequestBufferSize, setRequestHeaderSize, setResolveNames, setResponseBuffers, setResponseBufferSize, setResponseHeaderSize, setReuseAddress, setServer, setSoLingerTime, setStatsOn, setThreadPool, statsReset, stopAccept, toString

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

addBean, addBean, contains, destroy, dump, dump, dump, dump, dump, dumpObject, dumpStdErr, dumpThis, getBean, getBeans, getBeans, isManaged, manage, removeBean, removeBeans, unmanage

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.util.component.LifeCycle

addLifeCycleListener, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dump, dump

Constructor Detail

BlockingChannelConnector

public BlockingChannelConnector()

Constructor.

Method Detail

getConnection

public Object getConnection()

Returns:

the underlying socket, channel, buffer etc. for the connector.

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class AbstractConnector

Throws:

Exception

See Also:

AbstractConnector.doStart()

open

public void open()
          throws IOException

Description copied from interface: Connector

Opens the connector

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

accept

public void accept(int acceptorID)
            throws IOException,
                   InterruptedException

Specified by:

accept in class AbstractConnector

Throws:

IOException

InterruptedException

customize

public void customize(EndPoint endpoint,
             Request request)
               throws IOException

Description copied from interface: Connector

Customize a request for an endpoint. Called on every request to allow customization of the request for the particular endpoint (eg security properties from a SSL connection).

Specified by:

customize in interface Connector

Overrides:

customize in class AbstractConnector

Throws:

IOException

getLocalPort

public int getLocalPort()

Returns:

The actual port the connector is listening on or -1 if it has not been opened, or -2 if it has been closed.