public class SocketConnector extends AbstractConnector
Modifier and Type | Class and Description |
---|---|
protected class |
SocketConnector.Connection |
AbstractBuffers.ThreadBuffers
Modifier and Type | Field and Description |
---|---|
protected java.util.Set |
_connections |
protected java.net.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() |
java.lang.Object |
getConnection() |
int |
getLocalPort() |
protected Buffer |
newBuffer(int size) |
protected HttpConnection |
newHttpConnection(EndPoint endpoint)
Allows subclass to override Conection if required.
|
protected java.net.ServerSocket |
newServerSocket(java.lang.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 java.net.ServerSocket _serverSocket
protected java.util.Set _connections
public java.lang.Object getConnection()
public void open() throws java.io.IOException
Connector
java.io.IOException
protected java.net.ServerSocket newServerSocket(java.lang.String host, int port, int backlog) throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
java.io.IOException
public void accept(int acceptorID) throws java.io.IOException, java.lang.InterruptedException
accept
in class AbstractConnector
java.io.IOException
java.lang.InterruptedException
protected HttpConnection newHttpConnection(EndPoint endpoint)
protected Buffer newBuffer(int size)
newBuffer
in class AbstractBuffers
public void customize(EndPoint endpoint, Request request) throws java.io.IOException
Connector
customize
in interface Connector
customize
in class AbstractConnector
java.io.IOException
public int getLocalPort()
protected void doStart() throws java.lang.Exception
doStart
in class AbstractConnector
java.lang.Exception
protected void doStop() throws java.lang.Exception
doStop
in class AbstractConnector
java.lang.Exception
Copyright © 2009 Mortbay Consulting Pty. Ltd. All Rights Reserved.