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, 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, 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, isRequestHeader, isResponseHeader, join, newBuffer, newRequestBuffer, newRequestHeader, newResponseBuffer, newResponseHeader, 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 |
getHeaderBufferSize, getRequestBuffers, getRequestBufferSize, getRequestHeaderSize, getResponseBuffers, getResponseBufferSize, getResponseHeaderSize, setHeaderBufferSize, setRequestBufferSize, setRequestHeaderSize, setResponseBufferSize, setResponseHeaderSize |
Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle |
addLifeCycleListener, 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 |
_serverSocket
protected java.net.ServerSocket _serverSocket
_connections
protected final java.util.Set<EndPoint> _connections
_localPort
protected volatile int _localPort
SocketConnector
public SocketConnector()
- Constructor.
getConnection
public java.lang.Object getConnection()
- Returns:
- the underlying socket, channel, buffer etc. for the connector.
open
public void open()
throws java.io.IOException
- Description copied from interface:
Connector
- Opens the connector
- Throws:
java.io.IOException
newServerSocket
protected java.net.ServerSocket newServerSocket(java.lang.String host,
int port,
int backlog)
throws java.io.IOException
- Throws:
java.io.IOException
close
public void close()
throws java.io.IOException
- Throws:
java.io.IOException
accept
public void accept(int acceptorID)
throws java.io.IOException,
java.lang.InterruptedException
- Specified by:
accept
in class AbstractConnector
- Throws:
java.io.IOException
java.lang.InterruptedException
newConnection
protected Connection newConnection(EndPoint endpoint)
- Allows subclass to override Conection if required.
customize
public void customize(EndPoint endpoint,
Request request)
throws java.io.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:
java.io.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 java.lang.Exception
- Overrides:
doStart
in class AbstractConnector
- Throws:
java.lang.Exception
doStop
protected void doStop()
throws java.lang.Exception
- Overrides:
doStop
in class AbstractConnector
- Throws:
java.lang.Exception
Copyright © 1995-2010 Mort Bay Consulting. All Rights Reserved.