JIoEndpoint (Apache Tomcat 8.0.15 API Documentation)

java.lang.Object
- org.apache.tomcat.util.net.AbstractEndpoint<Socket>
- - org.apache.tomcat.util.net.JIoEndpoint

```
public class JIoEndpoint
extends AbstractEndpoint<Socket>
```
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, Jason Hunter, James Todd, Costin Manolache, Gal Shachor, Yoav Shapira, Remy Maucherat

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`protected class`	`JIoEndpoint.Acceptor` The background thread that listens for incoming TCP/IP connections and hands them off to an appropriate processor.
`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.

Nested classes/interfaces inherited from class org.apache.tomcat.util.net.AbstractEndpoint
AbstractEndpoint.AsyncTimeout, AbstractEndpoint.BindState

Field Summary

Fields
Modifier and Type	Field and Description
`protected JIoEndpoint.Handler`	`handler` Handling of accepted sockets.
`protected ServerSocket`	`serverSocket` Associated server socket.
`protected ServerSocketFactory`	`serverSocketFactory` Server socket factory.

Fields inherited from class org.apache.tomcat.util.net.AbstractEndpoint
acceptors, acceptorThreadCount, acceptorThreadPriority, attributes, DEFAULT_CIPHERS, internalExecutor, paused, running, sm, socketProperties, threadPriority, waitingRequests

Constructor Summary

Constructors
Constructor and Description

JIoEndpoint()

Constructors
Constructor and Description
`JIoEndpoint()`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`bind()`
`protected AbstractEndpoint.Acceptor`	`createAcceptor()` Hook to allow Endpoints to provide a specific Acceptor implementation.
`String[]`	`getCiphersUsed()`
`boolean`	`getDeferAccept()`
`JIoEndpoint.Handler`	`getHandler()`
`int`	`getLocalPort()` Port in use.
`protected Log`	`getLog()`
`ServerSocketFactory`	`getServerSocketFactory()`
`boolean`	`getUseComet()`
`boolean`	`getUseCometTimeout()`
`boolean`	`getUsePolling()`
`boolean`	`getUseSendfile()`
`protected boolean`	`processSocket(Socket socket)` Process a new connection from a new client.
`void`	`processSocket(SocketWrapper<Socket> socket, SocketStatus status, boolean dispatch)` Process the given SocketWrapper with the given status.
`void`	`setHandler(JIoEndpoint.Handler handler)`
`void`	`setServerSocketFactory(ServerSocketFactory factory)`
`protected boolean`	`setSocketOptions(Socket socket)` Configure the socket.
`void`	`startInternal()`
`void`	`stopInternal()`
`void`	`unbind()` Deallocate APR memory pools, and close server socket.

Methods inherited from class org.apache.tomcat.util.net.AbstractEndpoint
countDownConnection, countUpOrAwaitConnection, createExecutor, destroy, executeNonBlockingDispatches, getAcceptorThreadCount, getAcceptorThreadPriority, getAddress, getAlgorithm, getAllowUnsafeLegacyRenegotiation, getAsyncTimeout, getAttribute, getBacklog, getBindOnInit, getCiphers, getClientAuth, getConnectionCount, getCrlFile, getCurrentThreadCount, getCurrentThreadsBusy, getDaemon, getExecutor, getExecutorTerminationTimeoutMillis, getKeepAliveTimeout, getKeyAlias, getKeyPass, getKeystoreFile, getKeystorePass, getKeystoreProvider, getKeystoreType, getMaxConnections, getMaxHeaderCount, getMaxKeepAliveRequests, getMaxThreads, getMaxThreadsExecutor, getMinSpareThreads, getName, getPort, getProperty, getSessionCacheSize, getSessionTimeout, getSocketProperties, getSoLinger, getSoTimeout, getSslEnabledProtocolsArray, getSslProtocol, getTcpNoDelay, getThreadPriority, getTrustManagerClassName, getTrustMaxCertLength, getTruststoreAlgorithm, getTruststoreFile, getTruststorePass, getTruststoreProvider, getTruststoreType, handleExceptionWithDelay, init, initializeConnectionLatch, isPaused, isRunning, isSSLEnabled, pause, releaseConnectionLatch, resume, setAcceptorThreadCount, setAcceptorThreadPriority, setAddress, setAlgorithm, setAllowUnsafeLegacyRenegotiation, setAsyncTimeout, setAttribute, setBacklog, setBindOnInit, setCiphers, setClientAuth, setCrlFile, setDaemon, setExecutor, setExecutorTerminationTimeoutMillis, setKeepAliveTimeout, setKeyAlias, setKeyPass, setKeystoreFile, setKeystorePass, setKeystoreProvider, setKeystoreType, setMaxConnections, setMaxHeaderCount, setMaxKeepAliveRequests, setMaxThreads, setMinSpareThreads, setName, setPort, setProperty, setSessionCacheSize, setSessionTimeout, setSoLinger, setSoTimeout, setSSLEnabled, setSslEnabledProtocols, setSslProtocol, setTcpNoDelay, setThreadPriority, setTrustManagerClassName, setTrustMaxCertLength, setTruststoreAlgorithm, setTruststoreFile, setTruststorePass, setTruststoreProvider, setTruststoreType, shutdownExecutor, start, startAcceptorThreads, stop, unlockAccept

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - serverSocket
```
protected ServerSocket serverSocket
```
    Associated server socket.
  - handler
```
protected JIoEndpoint.Handler handler
```
    Handling of accepted sockets.
  - serverSocketFactory
```
protected ServerSocketFactory serverSocketFactory
```
    Server socket factory.
- Constructor Detail
  - JIoEndpoint
```
public JIoEndpoint()
```
- Method Detail
  - setHandler
```
public void setHandler(JIoEndpoint.Handler handler)
```
  - getHandler
```
public JIoEndpoint.Handler getHandler()
```
  - setServerSocketFactory
```
public void setServerSocketFactory(ServerSocketFactory factory)
```
  - getServerSocketFactory
```
public ServerSocketFactory getServerSocketFactory()
```
  - getLocalPort
```
public int getLocalPort()
```
    Port in use.
    
    Specified by:
    
    getLocalPort in class AbstractEndpoint<Socket>
  - getCiphersUsed
```
public String[] getCiphersUsed()
```
    Specified by:
    
    getCiphersUsed in class AbstractEndpoint<Socket>
    
    Returns:
    The ciphers in use by this Endpoint
  - getUseSendfile
```
public boolean getUseSendfile()
```
    Specified by:
    
    getUseSendfile in class AbstractEndpoint<Socket>
  - getUseComet
```
public boolean getUseComet()
```
    Specified by:
    
    getUseComet in class AbstractEndpoint<Socket>
  - getUseCometTimeout
```
public boolean getUseCometTimeout()
```
    Specified by:
    
    getUseCometTimeout in class AbstractEndpoint<Socket>
  - getDeferAccept
```
public boolean getDeferAccept()
```
    Specified by:
    
    getDeferAccept in class AbstractEndpoint<Socket>
  - getUsePolling
```
public boolean getUsePolling()
```
    Specified by:
    
    getUsePolling in class AbstractEndpoint<Socket>
  - bind
```
public void bind()
          throws Exception
```
    Specified by:
    
    bind in class AbstractEndpoint<Socket>
    
    Throws:
    
    Exception
  - startInternal
```
public void startInternal()
                   throws Exception
```
    Specified by:
    
    startInternal in class AbstractEndpoint<Socket>
    
    Throws:
    
    Exception
  - stopInternal
```
public void stopInternal()
```
    Specified by:
    
    stopInternal in class AbstractEndpoint<Socket>
  - unbind
```
public void unbind()
            throws Exception
```
    Deallocate APR memory pools, and close server socket.
    
    Specified by:
    
    unbind in class AbstractEndpoint<Socket>
    
    Throws:
    
    Exception
  - createAcceptor
```
protected AbstractEndpoint.Acceptor createAcceptor()
```
    Description copied from class: AbstractEndpoint
    
    Hook to allow Endpoints to provide a specific Acceptor implementation.
    
    Specified by:
    
    createAcceptor in class AbstractEndpoint<Socket>
  - setSocketOptions
```
protected boolean setSocketOptions(Socket socket)
```
    Configure the socket.
  - processSocket
```
protected boolean processSocket(Socket socket)
```
    Process a new connection from a new client. Wraps the socket so keep-alive and other attributes can be tracked and then passes the socket to the executor for processing.
    
    Parameters:
    socket - The socket associated with the client.
    
    Returns:
    true if the socket is passed to the executor, false if something went wrong or if the endpoint is shutting down. Returning false is an indication to close the socket immediately.
  - processSocket
```
public void processSocket(SocketWrapper<Socket> socket,
                 SocketStatus status,
                 boolean dispatch)
```
    Description copied from class: AbstractEndpoint
    
    Process the given SocketWrapper with the given status. Used to trigger processing as if the Poller (for those endpoints that have one) selected the socket.
    
    Specified by:
    
    processSocket in class AbstractEndpoint<Socket>
    
    Parameters:
    socket - The socket wrapper to process
    status - The input status to the processing
    dispatch - Should the processing be performed on a new container thread
  - getLog
```
protected Log getLog()
```
    Specified by:
    
    getLog in class AbstractEndpoint<Socket>

Class JIoEndpoint

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.tomcat.util.net.AbstractEndpoint

Field Summary

Fields inherited from class org.apache.tomcat.util.net.AbstractEndpoint

Constructor Summary

Method Summary

Methods inherited from class org.apache.tomcat.util.net.AbstractEndpoint

Methods inherited from class java.lang.Object

Field Detail

serverSocket

handler

serverSocketFactory

Constructor Detail

JIoEndpoint

Method Detail

setHandler

getHandler

setServerSocketFactory

getServerSocketFactory

getLocalPort

getCiphersUsed

getUseSendfile

getUseComet

getUseCometTimeout

getDeferAccept

getUsePolling

bind

startInternal

stopInternal

unbind

createAcceptor

setSocketOptions

processSocket

processSocket

getLog