NioEndpoint (Apache Tomcat 7.0.67 API Documentation)

java.lang.Object
- org.apache.tomcat.util.net.AbstractEndpoint<NioChannel>
- - org.apache.tomcat.util.net.NioEndpoint

```
public class NioEndpoint
extends AbstractEndpoint<NioChannel>
```
NIO tailored thread pool, providing the following services:
- Socket acceptor thread
- Socket poller thread
- Worker threads pool
When switching to Java 5, there's an opportunity to use the virtual machine's thread pool.
Author:

Mladen Turk, Remy Maucherat, Filip Hanik

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`protected class`	`NioEndpoint.Acceptor` The background thread that listens for incoming TCP/IP connections and hands them off to an appropriate processor.
`static interface`	`NioEndpoint.Handler` Bare bones interface used for socket processing.
`static class`	`NioEndpoint.KeyAttachment`
`static class`	`NioEndpoint.NioBufferHandler`
`class`	`NioEndpoint.Poller` Poller class.
`static class`	`NioEndpoint.PollerEvent` PollerEvent, cacheable object for poller events to avoid GC
`static class`	`NioEndpoint.SendfileData` SendfileData class.
`protected class`	`NioEndpoint.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.BindState

Field Summary

Fields
Modifier and Type	Field and Description
`protected java.util.concurrent.ConcurrentLinkedQueue<NioEndpoint.PollerEvent>`	`eventCache` Cache for poller events
`protected NioEndpoint.Handler`	`handler` Handling of accepted sockets.
`protected java.util.concurrent.ConcurrentLinkedQueue<NioEndpoint.KeyAttachment>`	`keyCache` Cache for key attachment objects
`protected java.util.concurrent.ConcurrentLinkedQueue<NioChannel>`	`nioChannels` Bytebuffer cache, each channel holds a set of buffers (two, except for SSL holds four)
`protected int`	`oomParachute` The size of the OOM parachute.
`protected byte[]`	`oomParachuteData` The oom parachute, when an OOM error happens, will release the data, giving the JVM instantly a chunk of data to be able to recover with.
`protected static java.lang.String`	`oomParachuteMsg` Make sure this string has already been allocated
`static int`	`OP_CALLBACK`
`static int`	`OP_REGISTER`
`protected java.util.concurrent.atomic.AtomicInteger`	`pollerRotater`
`protected NioEndpoint.Poller[]`	`pollers` The socket poller.
`protected int`	`pollerThreadCount` Poller thread count.
`protected int`	`pollerThreadPriority` Priority of the poller threads.
`protected java.util.concurrent.ConcurrentLinkedQueue<NioEndpoint.SocketProcessor>`	`processorCache` Cache for SocketProcessor objects
`protected NioSelectorPool`	`selectorPool`
`protected long`	`selectorTimeout`
`protected java.nio.channels.ServerSocketChannel`	`serverSock` Server socket "pointer".
`protected javax.net.ssl.SSLContext`	`sslContext`
`protected java.util.concurrent.CountDownLatch`	`stopLatch`
`protected boolean`	`useComet` Allow comet request handling.
`protected boolean`	`useSendfile` use send file

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

Constructor Summary

Constructors
Constructor and Description

NioEndpoint()

Constructors
Constructor and Description
`NioEndpoint()`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`bind()` Initialize the endpoint.
`protected void`	`checkParachute()`
`protected AbstractEndpoint.Acceptor`	`createAcceptor()` Hook to allow Endpoints to provide a specific Acceptor implementation.
`protected javax.net.ssl.SSLEngine`	`createSSLEngine()`
`boolean`	`dispatchForEvent(NioChannel socket, SocketStatus status, boolean dispatch)`
`boolean`	`getDeferAccept()` Is deferAccept supported?
`NioEndpoint.Handler`	`getHandler()`
`int`	`getKeepAliveCount()` Number of keepalive sockets.
`int`	`getLocalPort()` Port in use.
`protected Log`	`getLog()`
`int`	`getOomParachute()`
`byte[]`	`getOomParachuteData()`
`NioEndpoint.Poller`	`getPoller0()` Return an available poller in true round robin fashion
`int`	`getPollerThreadCount()`
`int`	`getPollerThreadPriority()`
`int`	`getReadBufSize()`
`NioSelectorPool`	`getSelectorPool()`
`long`	`getSelectorTimeout()`
`javax.net.ssl.SSLContext`	`getSSLContext()`
`boolean`	`getUseComet()`
`boolean`	`getUseCometTimeout()`
`boolean`	`getUsePolling()`
`boolean`	`getUseSendfile()`
`int`	`getWriteBufSize()`
`protected boolean`	`isWorkerAvailable()` Returns true if a worker thread is available for processing.
`boolean`	`processSocket(NioChannel socket, SocketStatus status, boolean dispatch)`
`void`	`processSocketAsync(SocketWrapper<NioChannel> socketWrapper, SocketStatus socketStatus)`
`protected boolean`	`reclaimParachute(boolean force)`
`protected void`	`releaseCaches()`
`void`	`removeWaitingRequest(SocketWrapper<NioChannel> socketWrapper)`
`void`	`setHandler(NioEndpoint.Handler handler)`
`void`	`setOomParachute(int oomParachute)`
`void`	`setOomParachuteData(byte[] oomParachuteData)`
`void`	`setPollerThreadCount(int pollerThreadCount)`
`void`	`setPollerThreadPriority(int pollerThreadPriority)`
`boolean`	`setProperty(java.lang.String name, java.lang.String value)` Generic properties, introspected
`void`	`setSelectorPool(NioSelectorPool selectorPool)`
`void`	`setSelectorTimeout(long timeout)`
`protected boolean`	`setSocketOptions(java.nio.channels.SocketChannel socket)` Process the specified connection.
`void`	`setSocketProperties(SocketProperties socketProperties)`
`void`	`setSSLContext(javax.net.ssl.SSLContext c)`
`void`	`setUseComet(boolean useComet)`
`void`	`setUseSendfile(boolean useSendfile)`
`void`	`startInternal()` Start the NIO endpoint, creating acceptor, poller threads.
`void`	`stopInternal()` Stop the endpoint.
`void`	`unbind()` Deallocate NIO memory pools, and close server socket.
`javax.net.ssl.KeyManager[]`	`wrap(javax.net.ssl.KeyManager[] managers)`

Methods inherited from class org.apache.tomcat.util.net.AbstractEndpoint
configureUseServerCipherSuitesOrder, countDownConnection, countUpOrAwaitConnection, createExecutor, destroy, getAcceptorThreadCount, getAcceptorThreadPriority, getAddress, getAlgorithm, getAllowUnsafeLegacyRenegotiation, 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, getUseServerCipherSuitesOrder, handleExceptionWithDelay, init, initializeConnectionLatch, isPaused, isRunning, isSSLEnabled, pause, releaseConnectionLatch, resume, setAcceptorThreadCount, setAcceptorThreadPriority, setAddress, setAlgorithm, setAllowUnsafeLegacyRenegotiation, setAttribute, setBacklog, setBindOnInit, setCiphers, setClientAuth, setCrlFile, setDaemon, setExecutor, setExecutorTerminationTimeoutMillis, setKeepAliveTimeout, setKeyAlias, setKeyPass, setKeystoreFile, setKeystorePass, setKeystoreProvider, setKeystoreType, setMaxConnections, setMaxHeaderCount, setMaxKeepAliveRequests, setMaxThreads, setMinSpareThreads, setName, setPort, setSessionCacheSize, setSessionTimeout, setSoLinger, setSoTimeout, setSSLEnabled, setSslEnabledProtocols, setSslProtocol, setTcpNoDelay, setThreadPriority, setTrustManagerClassName, setTrustMaxCertLength, setTruststoreAlgorithm, setTruststoreFile, setTruststorePass, setTruststoreProvider, setTruststoreType, setUseServerCipherSuitesOrder, 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

OP_REGISTER
```
public static final int OP_REGISTER
```
See Also:
Constant Field Values

OP_CALLBACK
```
public static final int OP_CALLBACK
```
See Also:
Constant Field Values

selectorPool
```
protected NioSelectorPool selectorPool
```

serverSock

protected java.nio.channels.ServerSocketChannel serverSock

Server socket "pointer".

useSendfile
```
protected boolean useSendfile
```
use send file

oomParachute
```
protected int oomParachute
```
The size of the OOM parachute.

oomParachuteData
```
protected byte[] oomParachuteData
```
The oom parachute, when an OOM error happens, will release the data, giving the JVM instantly a chunk of data to be able to recover with.

oomParachuteMsg
```
protected static final java.lang.String oomParachuteMsg
```
Make sure this string has already been allocated

See Also:
Constant Field Values

stopLatch

protected volatile java.util.concurrent.CountDownLatch stopLatch

processorCache

protected java.util.concurrent.ConcurrentLinkedQueue<NioEndpoint.SocketProcessor> processorCache

Cache for SocketProcessor objects

keyCache

protected java.util.concurrent.ConcurrentLinkedQueue<NioEndpoint.KeyAttachment> keyCache

Cache for key attachment objects

eventCache

protected java.util.concurrent.ConcurrentLinkedQueue<NioEndpoint.PollerEvent> eventCache

Cache for poller events

nioChannels
```
protected java.util.concurrent.ConcurrentLinkedQueue<NioChannel> nioChannels
```
Bytebuffer cache, each channel holds a set of buffers (two, except for SSL holds four)

pollerThreadPriority
```
protected int pollerThreadPriority
```
Priority of the poller threads.

handler
```
protected NioEndpoint.Handler handler
```
Handling of accepted sockets.

useComet
```
protected boolean useComet
```
Allow comet request handling.

pollerThreadCount
```
protected int pollerThreadCount
```
Poller thread count.

selectorTimeout
```
protected long selectorTimeout
```

pollers
```
protected NioEndpoint.Poller[] pollers
```
The socket poller.

pollerRotater

protected java.util.concurrent.atomic.AtomicInteger pollerRotater

sslContext

protected javax.net.ssl.SSLContext sslContext

Constructor Detail
- NioEndpoint
```
public NioEndpoint()
```

Method Detail

setProperty
```
public boolean setProperty(java.lang.String name,
                  java.lang.String value)
```
Generic properties, introspected

Overrides:

setProperty in class AbstractEndpoint<NioChannel>

setPollerThreadPriority

public void setPollerThreadPriority(int pollerThreadPriority)

getPollerThreadPriority
```
public int getPollerThreadPriority()
```

setHandler

public void setHandler(NioEndpoint.Handler handler)

getHandler

public NioEndpoint.Handler getHandler()

setUseComet

public void setUseComet(boolean useComet)

getUseComet
```
public boolean getUseComet()
```
Specified by:

getUseComet in class AbstractEndpoint<NioChannel>

getUseCometTimeout
```
public boolean getUseCometTimeout()
```
Specified by:

getUseCometTimeout in class AbstractEndpoint<NioChannel>

getUsePolling
```
public boolean getUsePolling()
```
Specified by:

getUsePolling in class AbstractEndpoint<NioChannel>

setPollerThreadCount

public void setPollerThreadCount(int pollerThreadCount)

getPollerThreadCount
```
public int getPollerThreadCount()
```

setSelectorTimeout

public void setSelectorTimeout(long timeout)

getSelectorTimeout
```
public long getSelectorTimeout()
```

getPoller0
```
public NioEndpoint.Poller getPoller0()
```
Return an available poller in true round robin fashion

setSelectorPool

public void setSelectorPool(NioSelectorPool selectorPool)

setSocketProperties

public void setSocketProperties(SocketProperties socketProperties)

setUseSendfile

public void setUseSendfile(boolean useSendfile)

getDeferAccept
```
public boolean getDeferAccept()
```
Is deferAccept supported?

Specified by:

getDeferAccept in class AbstractEndpoint<NioChannel>

setOomParachute

public void setOomParachute(int oomParachute)

setOomParachuteData

public void setOomParachuteData(byte[] oomParachuteData)

getSSLContext

public javax.net.ssl.SSLContext getSSLContext()

setSSLContext

public void setSSLContext(javax.net.ssl.SSLContext c)

getLocalPort
```
public int getLocalPort()
```
Port in use.

Specified by:

getLocalPort in class AbstractEndpoint<NioChannel>

checkParachute
```
protected void checkParachute()
```

reclaimParachute

protected boolean reclaimParachute(boolean force)

releaseCaches
```
protected void releaseCaches()
```

getKeepAliveCount
```
public int getKeepAliveCount()
```
Number of keepalive sockets.

bind
```
public void bind()
          throws java.lang.Exception
```
Initialize the endpoint.

Specified by:

bind in class AbstractEndpoint<NioChannel>

Throws:

java.lang.Exception

wrap

public javax.net.ssl.KeyManager[] wrap(javax.net.ssl.KeyManager[] managers)

startInternal
```
public void startInternal()
                   throws java.lang.Exception
```
Start the NIO endpoint, creating acceptor, poller threads.

Specified by:

startInternal in class AbstractEndpoint<NioChannel>

Throws:

java.lang.Exception

stopInternal
```
public void stopInternal()
```
Stop the endpoint. This will cause all processing threads to stop.

Specified by:

stopInternal in class AbstractEndpoint<NioChannel>

unbind
```
public void unbind()
            throws java.lang.Exception
```
Deallocate NIO memory pools, and close server socket.

Specified by:

unbind in class AbstractEndpoint<NioChannel>

Throws:

java.lang.Exception

getWriteBufSize
```
public int getWriteBufSize()
```

getReadBufSize
```
public int getReadBufSize()
```

getSelectorPool

public NioSelectorPool getSelectorPool()

getUseSendfile
```
public boolean getUseSendfile()
```
Specified by:

getUseSendfile in class AbstractEndpoint<NioChannel>

getOomParachute
```
public int getOomParachute()
```

getOomParachuteData
```
public byte[] getOomParachuteData()
```

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<NioChannel>

setSocketOptions

protected boolean setSocketOptions(java.nio.channels.SocketChannel socket)

Process the specified connection.

createSSLEngine

protected javax.net.ssl.SSLEngine createSSLEngine()

isWorkerAvailable
```
protected boolean isWorkerAvailable()
```
Returns true if a worker thread is available for processing.

Returns:
boolean

processSocketAsync

public void processSocketAsync(SocketWrapper<NioChannel> socketWrapper,
                      SocketStatus socketStatus)

Specified by:: processSocketAsync in class AbstractEndpoint<NioChannel>

dispatchForEvent

public boolean dispatchForEvent(NioChannel socket,
                       SocketStatus status,
                       boolean dispatch)

processSocket

public boolean processSocket(NioChannel socket,
                    SocketStatus status,
                    boolean dispatch)

removeWaitingRequest
```
public void removeWaitingRequest(SocketWrapper<NioChannel> socketWrapper)
```
Specified by:

removeWaitingRequest in class AbstractEndpoint<NioChannel>

getLog
```
protected Log getLog()
```
Specified by:

getLog in class AbstractEndpoint<NioChannel>

Class NioEndpoint

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

OP_REGISTER

OP_CALLBACK

selectorPool

serverSock

useSendfile

oomParachute

oomParachuteData

oomParachuteMsg

stopLatch

processorCache

keyCache

eventCache

nioChannels

pollerThreadPriority

handler

useComet

pollerThreadCount

selectorTimeout

pollers

pollerRotater

sslContext

Constructor Detail

NioEndpoint

Method Detail

setProperty

setPollerThreadPriority

getPollerThreadPriority

setHandler

getHandler

setUseComet

getUseComet

getUseCometTimeout

getUsePolling

setPollerThreadCount

getPollerThreadCount

setSelectorTimeout

getSelectorTimeout

getPoller0

setSelectorPool

setSocketProperties

setUseSendfile

getDeferAccept

setOomParachute

setOomParachuteData

getSSLContext

setSSLContext

getLocalPort

checkParachute

reclaimParachute

releaseCaches

getKeepAliveCount

bind

wrap

startInternal

stopInternal

unbind

getWriteBufSize

getReadBufSize

getSelectorPool

getUseSendfile

getOomParachute

getOomParachuteData

createAcceptor

setSocketOptions

createSSLEngine

isWorkerAvailable

processSocketAsync

dispatchForEvent

processSocket

removeWaitingRequest