|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mortbay.util.ThreadPool
org.mortbay.util.ThreadedServer
org.mortbay.p2psockets.util.P2PThreadedServer
Threaded socket server modified for JXTA. This class listens at a socket and gives the connections received to a pool of Threads
The regular P2PThreadedServer is abstract; however, we have modified P2PThreadedServer to not be abstract so that an instance of it can be aggregated by P2PSocketListener. -- bkn3@columbia.edu
The properties THREADED_SERVER_MIN_THREADS and THREADED_SERVER_MAX_THREADS can be set to control the number of threads created.
Nested Class Summary |
Nested classes inherited from class org.mortbay.util.ThreadPool |
org.mortbay.util.ThreadPool.PoolThread |
Field Summary |
Fields inherited from class org.mortbay.util.ThreadPool |
__DAEMON, __PRIORITY |
Constructor Summary | |
P2PThreadedServer(java.net.InetAddress address,
int port,
P2PSocketListener socketListener)
Construct for specific address and port. |
|
P2PThreadedServer(org.mortbay.util.InetAddrPort address,
P2PSocketListener socketListener)
Construct for specific address and port. |
|
P2PThreadedServer(int port,
P2PSocketListener socketListener)
Construct for specific port. |
|
P2PThreadedServer(P2PSocketListener socketListener)
|
|
P2PThreadedServer(java.lang.String host,
int port,
P2PSocketListener socketListener)
Construct for specific address and port. |
Method Summary | |
protected java.net.Socket |
acceptSocket(java.net.ServerSocket serverSocket,
int timeout)
Accept socket connection. |
java.lang.String |
getHost()
|
java.net.InetAddress |
getInetAddress()
|
org.mortbay.util.InetAddrPort |
getInetAddrPort()
|
int |
getLingerTimeSecs()
|
int |
getMaxReadTimeMs()
|
int |
getPort()
|
java.net.ServerSocket |
getServerSocket()
|
void |
handle(java.lang.Object job)
Handle Job. |
protected void |
handleConnection(java.io.InputStream in,
java.io.OutputStream out)
Handle new connection. |
protected void |
handleConnection(java.net.Socket connection)
Handle new connection. |
protected java.net.ServerSocket |
newServerSocket(org.mortbay.util.InetAddrPort address,
int acceptQueueSize)
New server socket. |
void |
open()
Open the server socket. |
void |
setHost(java.lang.String host)
|
void |
setInetAddress(java.net.InetAddress addr)
|
void |
setInetAddrPort(org.mortbay.util.InetAddrPort address)
Set the server InetAddress and port. |
void |
setLingerTimeSecs(int ls)
|
void |
setMaxReadTimeMs(int ms)
Deprecated. maxIdleTime is used instead. |
void |
setPort(int port)
|
void |
start()
|
void |
stop()
|
protected void |
stopJob(java.lang.Thread thread,
java.lang.Object job)
Kill a job. |
java.lang.String |
toString()
|
Methods inherited from class org.mortbay.util.ThreadPool |
getIdleThreads, getMaxIdleTimeMs, getMaxThreads, getMinThreads, getName, getPoolName, getThreads, getThreadsPriority, isDaemon, isStarted, join, run, setDaemon, setMaxIdleTimeMs, setMaxStopTimeMs, setMaxThreads, setMinThreads, setName, setPoolName, setThreadsPriority, shrink |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public P2PThreadedServer(P2PSocketListener socketListener)
public P2PThreadedServer(int port, P2PSocketListener socketListener)
public P2PThreadedServer(java.net.InetAddress address, int port, P2PSocketListener socketListener)
public P2PThreadedServer(java.lang.String host, int port, P2PSocketListener socketListener) throws java.net.UnknownHostException
public P2PThreadedServer(org.mortbay.util.InetAddrPort address, P2PSocketListener socketListener)
Method Detail |
public java.net.ServerSocket getServerSocket()
public void setInetAddrPort(org.mortbay.util.InetAddrPort address)
address
- The Address to listen on, or 0.0.0.0:port for
all interfaces.public org.mortbay.util.InetAddrPort getInetAddrPort()
public void setHost(java.lang.String host) throws java.net.UnknownHostException
host
-
java.net.UnknownHostException
public java.lang.String getHost()
public void setInetAddress(java.net.InetAddress addr)
addr
- public java.net.InetAddress getInetAddress()
public void setPort(int port)
port
- public int getPort()
public void setMaxReadTimeMs(int ms)
public int getMaxReadTimeMs()
public void setLingerTimeSecs(int ls)
ls
- seconds to linger or -1 to disable linger.public int getLingerTimeSecs()
protected void handleConnection(java.io.InputStream in, java.io.OutputStream out)
protected void handleConnection(java.net.Socket connection) throws java.io.IOException
java.io.IOException
public void handle(java.lang.Object job)
job
- A Connection.protected java.net.ServerSocket newServerSocket(org.mortbay.util.InetAddrPort address, int acceptQueueSize) throws java.io.IOException
address
- Address and portacceptQueueSize
- Accept queue size
java.io.IOException
protected java.net.Socket acceptSocket(java.net.ServerSocket serverSocket, int timeout)
serverSocket
- timeout
- The time to wait for a connection. Normally
passed the ThreadPool maxIdleTime.
public void open() throws java.io.IOException
java.io.IOException
- if an error occurspublic void start() throws java.lang.Exception
java.lang.Exception
public void stop() throws java.lang.InterruptedException
java.lang.InterruptedException
protected void stopJob(java.lang.Thread thread, java.lang.Object job)
thread
- job
- public java.lang.String toString()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |