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.
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, getForwardedCipherSuiteHeader, getForwardedForHeader, getForwardedHostHeader, getForwardedProtoHeader, getForwardedServerHeader, getForwardedSslSessionIdHeader, getHost, getHostHeader, getIntegralPort, getIntegralScheme, getLeftMostFieldValue, 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, setForwardedCipherSuiteHeader, setForwardedForHeader, setForwardedHostHeader, setForwardedProtoHeader, setForwardedServerHeader, setForwardedSslSessionIdHeader, 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 |
_serverSocket
protected ServerSocket _serverSocket
_connections
protected final Set<EndPoint> _connections
_localPort
protected volatile int _localPort
SocketConnector
public SocketConnector()
- Constructor.
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
Copyright © 1995-2011 Mort Bay Consulting. All Rights Reserved.