org.apache.tomcat.util.net

Class PoolTcpEndpoint

public class PoolTcpEndpoint extends Object implements Runnable

Handle incoming TCP connections. This class implement a simple server model: one listener thread accepts on a socket and creates a new worker thread for each incoming connection. More advanced Endpoints will reuse the threads, use queues, etc.

Author: James Duncan Davidson [duncan@eng.sun.com] Jason Hunter [jch@eng.sun.com] James Todd [gonzo@eng.sun.com] Costin@eng.sun.com Gal Shachor [shachor@il.ibm.com] Yoav Shapira

Field Summary
protected int	linger
protected int	socketTimeout
protected boolean	tcpNoDelay

Constructor Summary
	PoolTcpEndpoint()
	PoolTcpEndpoint(ThreadPool tp)

Method Summary
protected void	closeServerSocket()
InetAddress	getAddress()
int	getBacklog()
TcpConnectionHandler	getConnectionHandler()
int	getCurrentThreadCount()
int	getCurrentThreadsBusy()
int	getMaxSpareThreads()
int	getMaxThreads()
int	getMinSpareThreads()
int	getPort()
int	getServerSoTimeout()
int	getSoLinger()
int	getSoTimeout()
String	getStrategy()
boolean	getTcpNoDelay()
int	getThreadPriority()
void	initEndpoint()
boolean	isPaused()
boolean	isRunning()
void	pauseEndpoint()
void	resumeEndpoint()
void	run() The background thread that listens for incoming TCP/IP connections and hands them off to an appropriate processor.
void	setAddress(InetAddress inet)
void	setBacklog(int backlog) Allows the server developer to specify the backlog that should be used for server sockets.
void	setConnectionHandler(TcpConnectionHandler handler)
void	setMaxSpareThreads(int maxThreads)
void	setMaxThreads(int maxThreads)
void	setMinSpareThreads(int minThreads)
void	setPort(int port)
void	setServerSocket(ServerSocket ss)
void	setServerSocketFactory(ServerSocketFactory factory)
void	setServerSoTimeout(int i)
void	setServerTimeout(int timeout) Sets the timeout in ms of the server sockets created by this server.
void	setSoLinger(int i)
void	setSoTimeout(int i)
void	setStrategy(String strategy)
void	setTcpNoDelay(boolean b)
void	setThreadPriority(int threadPriority)
void	startEndpoint()
void	stopEndpoint()
protected void	unlockAccept()

Field Detail

linger

protected int linger

socketTimeout

protected int socketTimeout

tcpNoDelay

protected boolean tcpNoDelay

Constructor Detail

PoolTcpEndpoint

public PoolTcpEndpoint()

PoolTcpEndpoint

public PoolTcpEndpoint(ThreadPool tp)

Method Detail

closeServerSocket

protected void closeServerSocket()

getAddress

public InetAddress getAddress()

getBacklog

public int getBacklog()

getConnectionHandler

public TcpConnectionHandler getConnectionHandler()

getCurrentThreadCount

public int getCurrentThreadCount()

getCurrentThreadsBusy

public int getCurrentThreadsBusy()

getMaxSpareThreads

public int getMaxSpareThreads()

getMaxThreads

public int getMaxThreads()

getMinSpareThreads

public int getMinSpareThreads()

getPort

public int getPort()

getServerSoTimeout

public int getServerSoTimeout()

getSoLinger

public int getSoLinger()

getSoTimeout

public int getSoTimeout()

getStrategy

public String getStrategy()

getTcpNoDelay

public boolean getTcpNoDelay()

getThreadPriority

public int getThreadPriority()

initEndpoint

public void initEndpoint()

isPaused

public boolean isPaused()

isRunning

public boolean isRunning()

pauseEndpoint

public void pauseEndpoint()

resumeEndpoint

public void resumeEndpoint()

run

public void run()

The background thread that listens for incoming TCP/IP connections and hands them off to an appropriate processor.

setAddress

public void setAddress(InetAddress inet)

setBacklog

public void setBacklog(int backlog)

Allows the server developer to specify the backlog that should be used for server sockets. By default, this value is 100.

setConnectionHandler

public void setConnectionHandler(TcpConnectionHandler handler)

setMaxSpareThreads

public void setMaxSpareThreads(int maxThreads)

setMaxThreads

public void setMaxThreads(int maxThreads)

setMinSpareThreads

public void setMinSpareThreads(int minThreads)

setPort

public void setPort(int port)

setServerSocket

public void setServerSocket(ServerSocket ss)

setServerSocketFactory

public void setServerSocketFactory(ServerSocketFactory factory)

setServerSoTimeout

public void setServerSoTimeout(int i)

setServerTimeout

public void setServerTimeout(int timeout)

Sets the timeout in ms of the server sockets created by this server. This method allows the developer to make servers more or less responsive to having their server sockets shut down.

By default this value is 1000ms.