Top Description Inners Fields Constructors Methods
org.apache.tomcat.util.net

public Class Nio2Endpoint

extends AbstractJsseEndpoint<Nio2Channel, AsynchronousSocketChannel>
Class Inheritance
Imports
java.io.EOFException, .File, .IOException, java.net.InetSocketAddress, .SocketAddress, .SocketTimeoutException, java.nio.ByteBuffer, java.nio.channels.AsynchronousChannelGroup, .AsynchronousCloseException, .AsynchronousServerSocketChannel, .AsynchronousSocketChannel, .CompletionHandler, .FileChannel, .NetworkChannel, java.nio.file.StandardOpenOption, java.util.concurrent.ExecutionException, .ExecutorService, .Future, .Semaphore, .TimeUnit, .TimeoutException, javax.net.ssl.SSLEngine, org.apache.juli.logging.Log, .LogFactory, org.apache.tomcat.util.ExceptionUtils, org.apache.tomcat.util.collections.SynchronizedStack, org.apache.tomcat.util.compat.JrePlatform, org.apache.tomcat.util.net.AbstractEndpoint.Handler.SocketState, .Acceptor.AcceptorState, org.apache.tomcat.util.net.jsse.JSSESupport
NIO2 endpoint.

Nested and Inner Type Summary

Modifier and TypeClass and Description
protected class
Nio2Endpoint.Nio2Acceptor

public static class
Nio2Endpoint.Nio2SocketWrapper

public static class
Nio2Endpoint.SendfileData

SendfileData class.

protected class
Nio2Endpoint.SocketProcessor

This class is the equivalent of the Worker, but will simply use in an external Executor thread pool.

Field Summary

Modifier and TypeField and Description
private volatile boolean
allClosed

private static ThreadLocal<Boolean>
inlineCompletion

Allows detecting if a completion handler completes inline.

private static final Log
log

private static final Log
logCertificate

private static final Log
logHandshake

private SynchronizedStack<Nio2Channel>
nioChannels

Bytebuffer cache, each channel holds a set of buffers (two, except for SSL holds four)

private long
previousAcceptedSocketNanoTime

private SocketAddress
previousAcceptedSocketRemoteAddress

private volatile AsynchronousServerSocketChannel
serverSock

Server socket "pointer".

private AsynchronousChannelGroup
threadGroup

Thread group associated with the server socket.

Constructor Summary

AccessConstructor and Description
public
Nio2Endpoint()

Method Summary

Modifier and TypeMethod and Description
public void
bind()

Implements abstract org.apache.tomcat.util.net.AbstractEndpoint.bind.

Initialize the endpoint.

protected SocketProcessorBase<Nio2Channel>
createSocketProcessor(SocketWrapperBase<Nio2Channel> socketWrapper, SocketEvent event)

Implements abstract org.apache.tomcat.util.net.AbstractEndpoint.createSocketProcessor.

protected void
destroySocket(AsynchronousSocketChannel
The newly accepted socket
socket)

Implements abstract org.apache.tomcat.util.net.AbstractEndpoint.destroySocket.

Close the socket.

protected void
doCloseServerSocket()

Implements abstract org.apache.tomcat.util.net.AbstractEndpoint.doCloseServerSocket.

Actually close the server socket but don't perform any other clean-up.

public static void
endInline()

public int

Returns:

Always returns -1.
getKeepAliveCount()

Number of keep-alive sockets.

protected Log
getLog()

Implements abstract org.apache.tomcat.util.net.AbstractEndpoint.getLog.

protected Log
getLogCertificate()

Overrides org.apache.tomcat.util.net.AbstractEndpoint.getLogCertificate.

protected SynchronizedStack<Nio2Channel>
getNioChannels()

protected NetworkChannel
getServerSocket()

Implements abstract org.apache.tomcat.util.net.AbstractJsseEndpoint.getServerSocket.

public static boolean
isInline()

public void
resume()

Overrides org.apache.tomcat.util.net.AbstractEndpoint.resume.

Resume the endpoint, which will make it start accepting new connections again.

protected AsynchronousSocketChannel
serverSocketAccept()

Implements abstract org.apache.tomcat.util.net.AbstractEndpoint.serverSocketAccept.

protected boolean

Returns:

true if the socket was correctly configured and processing may continue, false if the socket needs to be close immediately
setSocketOptions(AsynchronousSocketChannel
The socket channel
socket)

Implements abstract org.apache.tomcat.util.net.AbstractEndpoint.setSocketOptions.

Process the specified connection.

public void
shutdownExecutor()

Overrides org.apache.tomcat.util.net.AbstractEndpoint.shutdownExecutor.

protected void
startAcceptorThread()

Overrides org.apache.tomcat.util.net.AbstractEndpoint.startAcceptorThread.

public static void
startInline()

public void
startInternal()

Implements abstract org.apache.tomcat.util.net.AbstractEndpoint.startInternal.

Start the NIO2 endpoint, creating acceptor.

public void
stopInternal()

Implements abstract org.apache.tomcat.util.net.AbstractEndpoint.stopInternal.

Stop the endpoint.

public void
unbind()

Overrides org.apache.tomcat.util.net.AbstractJsseEndpoint.unbind.

Deallocate NIO memory pools, and close server socket.

Inherited from org.apache.tomcat.util.net.AbstractJsseEndpoint:
createSSLContextcreateSSLEnginegetLocalAddressgetSniParseLimitgetSslImplementationgetSslImplementationNameinitialiseSslsetSniParseLimitsetSslImplementationName