public class SocketConnector extends AbstractConnector
Modifier and Type | Class and Description |
---|---|
protected class |
SocketConnector.Connection |
AbstractBuffers.ThreadBuffers
Modifier and Type | Field and Description |
---|---|
protected Set |
_connections |
protected ServerSocket |
_serverSocket |
_lowResourceMaxIdleTime, _maxIdleTime, _soLingerTime
Constructor and Description |
---|
SocketConnector()
Constructor.
|
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() |
protected void |
doStop() |
Object |
getConnection() |
int |
getLocalPort() |
protected Buffer |
newBuffer(int size) |
protected HttpConnection |
newHttpConnection(EndPoint endpoint)
Allows subclass to override Conection if required.
|
protected ServerSocket |
newServerSocket(String host,
int port,
int backlog) |
void |
open()
Opens the connector
|
checkForwardedHeaders, configure, connectionClosed, connectionOpened, getAcceptorPriorityOffset, getAcceptors, getAcceptQueueSize, getConfidentialPort, getConfidentialScheme, getConnections, getConnectionsDurationAve, getConnectionsDurationMax, getConnectionsDurationMin, getConnectionsDurationTotal, getConnectionsOpen, getConnectionsOpenMax, getConnectionsOpenMin, getConnectionsRequestsAve, getConnectionsRequestsMax, getConnectionsRequestsMin, getForwardedForHeader, getForwardedHostHeader, getForwardedServerHeader, getHost, getHostHeader, getIntegralPort, getIntegralScheme, getLeftMostValue, getLowResourceMaxIdleTime, getMaxIdleTime, getName, getPort, getRequests, getResolveNames, getReuseAddress, getServer, getSoLingerTime, getStatsOn, getStatsOnMs, getThreadPool, isConfidential, isForwarded, isIntegral, join, newContinuation, persist, setAcceptorPriorityOffset, setAcceptors, setAcceptQueueSize, setConfidentialPort, setConfidentialScheme, setForwarded, setForwardedForHeader, setForwardedHostHeader, setForwardedServerHeader, setHost, setHostHeader, setIntegralPort, setIntegralScheme, setLowResourceMaxIdleTime, setMaxIdleTime, setName, setPort, setResolveNames, setReuseAddress, setServer, setSoLingerTime, setStatsOn, setThreadPool, statsReset, stopAccept, toString
getBuffer, getHeaderBufferSize, getRequestBufferSize, getResponseBufferSize, returnBuffer, setHeaderBufferSize, setRequestBufferSize, setResponseBufferSize
addLifeCycleListener, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getHeaderBufferSize, getRequestBufferSize, getResponseBufferSize, setHeaderBufferSize, setRequestBufferSize, setResponseBufferSize
addLifeCycleListener, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop
getBuffer, returnBuffer
protected ServerSocket _serverSocket
protected Set _connections
public Object getConnection()
public void open() throws IOException
Connector
IOException
protected ServerSocket newServerSocket(String host, int port, int backlog) throws IOException
IOException
public void close() throws IOException
IOException
public void accept(int acceptorID) throws IOException, InterruptedException
accept
in class AbstractConnector
IOException
InterruptedException
protected HttpConnection newHttpConnection(EndPoint endpoint)
protected Buffer newBuffer(int size)
newBuffer
in class AbstractBuffers
public void customize(EndPoint endpoint, Request request) throws IOException
Connector
customize
in interface Connector
customize
in class AbstractConnector
IOException
public int getLocalPort()
protected void doStart() throws Exception
doStart
in class AbstractConnector
Exception
protected void doStop() throws Exception
doStop
in class AbstractConnector
Exception
Copyright © 2009 Mortbay Consulting Pty. Ltd. All Rights Reserved.