org.eclipse.jetty.server.bio
Class SocketConnector

java.lang.Object
  org.eclipse.jetty.util.component.AbstractLifeCycle
      org.eclipse.jetty.http.HttpBuffers
          org.eclipse.jetty.server.AbstractConnector
              org.eclipse.jetty.server.bio.SocketConnector

All Implemented Interfaces:

Connector, Dumpable, LifeCycle

Direct Known Subclasses:

Ajp13SocketConnector, SslSocketConnector

public class SocketConnector
extends AbstractConnector

Socket Connector. This connector implements a traditional blocking IO and threading model. Normal JRE sockets are used and a thread is allocated per connection. Buffers are managed so that large buffers are only allocated to active connections. This Connector should only be used if NIO is not available.

Nested Class Summary

protected class

SocketConnector.ConnectorEndPoint

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

protected Set<EndPoint>	_connections
protected int	_localPort
protected ServerSocket	_serverSocket

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

SocketConnector()
Constructor.

Method Summary

void	accept(int acceptorID)
void	close()
void	customize(EndPoint endpoint, Request request) Customize a request for an endpoint.
protected void	doStart()
protected void	doStop()
Object	getConnection()
int	getLocalPort()
protected Connection	newConnection(EndPoint endpoint) Allows subclass to override Conection if required.
protected ServerSocket	newServerSocket(String host, int port, int backlog)
void	open() Opens the connector

Methods inherited from class org.eclipse.jetty.server.AbstractConnector

checkForwardedHeaders, configure, connectionClosed, connectionOpened, connectionUpgraded, dump, dump, getAcceptorPriorityOffset, getAcceptors, getAcceptQueueSize, getConfidentialPort, getConfidentialScheme, getConnections, getConnectionsDurationMax, getConnectionsDurationMean, getConnectionsDurationStdDev, getConnectionsDurationTotal, getConnectionsOpen, getConnectionsOpenMax, getConnectionsRequestsMax, getConnectionsRequestsMean, getConnectionsRequestsStdDev, getForwardedForHeader, getForwardedHostHeader, getForwardedProtoHeader, getForwardedServerHeader, getHost, getHostHeader, getIntegralPort, getIntegralScheme, getLeftMostValue, getLowResourceMaxIdleTime, getLowResourcesMaxIdleTime, getMaxIdleTime, getName, getPort, getRequests, getResolveNames, getReuseAddress, getServer, getSoLingerTime, getStatsOn, getStatsOnMs, getThreadPool, isConfidential, isForwarded, isIntegral, isLowResources, join, persist, setAcceptorPriorityOffset, setAcceptors, setAcceptQueueSize, setConfidentialPort, setConfidentialScheme, setForwarded, setForwardedForHeader, setForwardedHostHeader, setForwardedProtoHeader, setForwardedServerHeader, setHost, setHostHeader, setIntegralPort, setIntegralScheme, setLowResourceMaxIdleTime, setLowResourcesMaxIdleTime, setMaxIdleTime, 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

Field Detail

_serverSocket

protected ServerSocket _serverSocket

_connections

protected final Set<EndPoint> _connections

_localPort

protected volatile int _localPort

Constructor Detail

SocketConnector

public SocketConnector()

Constructor.

Method Detail

getConnection

public Object getConnection()

Returns:

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

open

public void open()
          throws IOException

Description copied from interface: Connector

Opens the connector

Throws:

IOException

newServerSocket

protected ServerSocket newServerSocket(String host,
                                       int port,
                                       int backlog)
                                throws IOException

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

newConnection

protected Connection newConnection(EndPoint endpoint)

Allows subclass to override Conection if required.

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.

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class AbstractConnector

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class AbstractConnector

Throws:

Exception