org.apache.tomcat.util.net
public class JIoEndpoint extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
protected class |
JIoEndpoint.Acceptor
Server socket acceptor thread.
|
static interface |
JIoEndpoint.Handler
Bare bones interface used for socket processing.
|
protected class |
JIoEndpoint.SocketProcessor
This class is the equivalent of the Worker, but will simply use in an
external Executor thread pool.
|
protected class |
JIoEndpoint.Worker |
class |
JIoEndpoint.WorkerStack |
Modifier and Type | Field and Description |
---|---|
protected int |
acceptorThreadCount
Acceptor thread count.
|
protected java.net.InetAddress |
address
Address for the server socket.
|
protected int |
backlog
Allows the server developer to specify the backlog that
should be used for server sockets.
|
static java.lang.String |
CERTIFICATE_KEY
The Request attribute key for the client certificate chain.
|
static java.lang.String |
CIPHER_SUITE_KEY
The Request attribute key for the cipher suite.
|
protected int |
curThreads
Current worker threads count.
|
protected int |
curThreadsBusy
Current worker threads busy count.
|
protected boolean |
daemon
The default is true - the created threads will be
in daemon mode.
|
protected java.util.concurrent.Executor |
executor
External Executor based thread pool.
|
protected JIoEndpoint.Handler |
handler
Handling of accepted sockets.
|
protected boolean |
initialized
Track the initialization state of the endpoint.
|
static java.lang.String |
KEY_SIZE_KEY
The Request attribute key for the key size.
|
protected static Log |
log |
protected int |
maxThreads
Maximum amount of worker threads.
|
protected java.lang.String |
name
Name of the thread pool, which will be used for naming child threads.
|
protected boolean |
paused
Will be set to true whenever the endpoint is paused.
|
protected int |
port
Server socket port.
|
protected boolean |
running
Running state of the endpoint.
|
protected int |
sequence
Sequence number used to generate thread names.
|
protected java.net.ServerSocket |
serverSocket
Associated server socket.
|
protected ServerSocketFactory |
serverSocketFactory
Server socket factory.
|
static java.lang.String |
SESSION_ID_KEY
The Request attribute key for the session id.
|
protected StringManager |
sm |
protected int |
soLinger
Socket linger.
|
protected int |
soTimeout
Socket timeout.
|
protected boolean |
tcpNoDelay
Socket TCP no delay.
|
protected int |
threadPriority
Priority of the acceptor and poller threads.
|
protected int |
unlockTimeout
Unlock timeout.
|
protected JIoEndpoint.WorkerStack |
workers
Available workers.
|
Constructor and Description |
---|
JIoEndpoint() |
Modifier and Type | Method and Description |
---|---|
protected JIoEndpoint.Worker |
createWorkerThread()
Create (or allocate) and return an available processor for use in
processing a specific HTTP request, if possible.
|
void |
destroy()
Deallocate APR memory pools, and close server socket.
|
int |
getAcceptorThreadCount() |
java.net.InetAddress |
getAddress() |
int |
getBacklog() |
int |
getCurrentThreadCount()
Return the amount of threads that are managed by the pool.
|
int |
getCurrentThreadsBusy()
Return the amount of threads that are in use
|
boolean |
getDaemon() |
java.util.concurrent.Executor |
getExecutor() |
JIoEndpoint.Handler |
getHandler() |
int |
getMaxThreads() |
java.lang.String |
getName() |
int |
getPort() |
ServerSocketFactory |
getServerSocketFactory() |
int |
getSoLinger() |
int |
getSoTimeout() |
boolean |
getTcpNoDelay() |
int |
getThreadPriority() |
int |
getUnlockTimeout() |
protected JIoEndpoint.Worker |
getWorkerThread()
Return a new worker thread, and block while to worker is available.
|
void |
init() |
boolean |
isPaused() |
boolean |
isRunning() |
protected JIoEndpoint.Worker |
newWorkerThread()
Create and return a new processor suitable for processing HTTP
requests and returning the corresponding responses.
|
void |
pause() |
protected boolean |
processSocket(java.net.Socket socket)
Process given socket.
|
protected void |
recycleWorkerThread(JIoEndpoint.Worker workerThread)
Recycle the specified Processor so that it can be used again.
|
void |
resume() |
void |
setAcceptorThreadCount(int acceptorThreadCount) |
void |
setAddress(java.net.InetAddress address) |
void |
setBacklog(int backlog) |
void |
setDaemon(boolean b) |
void |
setExecutor(java.util.concurrent.Executor executor) |
void |
setHandler(JIoEndpoint.Handler handler) |
void |
setMaxThreads(int maxThreads) |
void |
setName(java.lang.String name) |
void |
setPort(int port) |
void |
setServerSocketFactory(ServerSocketFactory factory) |
protected boolean |
setSocketOptions(java.net.Socket socket)
Set the options for the current socket.
|
void |
setSoLinger(int soLinger) |
void |
setSoTimeout(int soTimeout) |
void |
setTcpNoDelay(boolean tcpNoDelay) |
void |
setThreadPriority(int threadPriority) |
void |
setUnlockTimeout(int unlockTimeout) |
void |
start() |
void |
stop() |
protected void |
unlockAccept()
Unlock the accept by using a local connection.
|
protected static Log log
protected StringManager sm
public static final java.lang.String CIPHER_SUITE_KEY
public static final java.lang.String KEY_SIZE_KEY
public static final java.lang.String CERTIFICATE_KEY
public static final java.lang.String SESSION_ID_KEY
protected JIoEndpoint.WorkerStack workers
protected volatile boolean running
protected volatile boolean paused
protected boolean initialized
protected int curThreadsBusy
protected int curThreads
protected int sequence
protected java.net.ServerSocket serverSocket
protected int acceptorThreadCount
protected java.util.concurrent.Executor executor
protected int maxThreads
protected int threadPriority
protected int port
protected java.net.InetAddress address
protected JIoEndpoint.Handler handler
protected int backlog
protected boolean tcpNoDelay
protected int soLinger
protected int soTimeout
protected boolean daemon
protected java.lang.String name
protected ServerSocketFactory serverSocketFactory
protected int unlockTimeout
public void setAcceptorThreadCount(int acceptorThreadCount)
public int getAcceptorThreadCount()
public void setExecutor(java.util.concurrent.Executor executor)
public java.util.concurrent.Executor getExecutor()
public void setMaxThreads(int maxThreads)
public int getMaxThreads()
public void setThreadPriority(int threadPriority)
public int getThreadPriority()
public int getPort()
public void setPort(int port)
public java.net.InetAddress getAddress()
public void setAddress(java.net.InetAddress address)
public void setHandler(JIoEndpoint.Handler handler)
public JIoEndpoint.Handler getHandler()
public void setBacklog(int backlog)
public int getBacklog()
public boolean getTcpNoDelay()
public void setTcpNoDelay(boolean tcpNoDelay)
public int getSoLinger()
public void setSoLinger(int soLinger)
public int getSoTimeout()
public void setSoTimeout(int soTimeout)
public void setDaemon(boolean b)
public boolean getDaemon()
public void setName(java.lang.String name)
public java.lang.String getName()
public void setServerSocketFactory(ServerSocketFactory factory)
public ServerSocketFactory getServerSocketFactory()
public int getUnlockTimeout()
public void setUnlockTimeout(int unlockTimeout)
public boolean isRunning()
public boolean isPaused()
public int getCurrentThreadCount()
public int getCurrentThreadsBusy()
public void init() throws java.lang.Exception
java.lang.Exception
public void start() throws java.lang.Exception
java.lang.Exception
public void pause()
public void resume()
public void stop()
public void destroy() throws java.lang.Exception
java.lang.Exception
protected void unlockAccept()
protected boolean setSocketOptions(java.net.Socket socket)
protected JIoEndpoint.Worker createWorkerThread()
null
instead.protected JIoEndpoint.Worker newWorkerThread()
protected JIoEndpoint.Worker getWorkerThread()
protected void recycleWorkerThread(JIoEndpoint.Worker workerThread)
workerThread
- The processor to be recycledprotected boolean processSocket(java.net.Socket socket)
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.