Class NioEndpoint

java/org/apache/tomcat/util/net/NioEndpoint.java:71–2092

NIO endpoint.

 * NIO endpoint.
 */
public class NioEndpoint extends AbstractNetworkChannelEndpoint<NioChannel,SocketChannel> {

    /**
     * Default constructor.
     */
    public NioEndpoint() {
    }


    // -------------------------------------------------------------- Constants


    private static final Log log = LogFactory.getLog(NioEndpoint.class);
    private static final Log logCertificate = LogFactory.getLog(NioEndpoint.class.getName() + ".certificate");
    private static final Log logHandshake = LogFactory.getLog(NioEndpoint.class.getName() + ".handshake");


    /**
     * Custom operation for registering interest in a socket.
     */
    public static final int OP_REGISTER = 0x100; // register interest op

    // ----------------------------------------------------------------- Fields

    /**
     * Server socket "pointer".
     */
    private volatile ServerSocketChannel serverSock = null;

    /**
     * Stop latch used to wait for poller stop
     */
    private volatile CountDownLatch stopLatch = null;

    /**
     * Cache for poller events
     */
    private SynchronizedStack<PollerEvent> eventCache;

    /**
     * Bytebuffer cache, each channel holds a set of buffers (two, except for SSL holds four)
     */
    private SynchronizedStack<NioChannel> nioChannels;

    /**
     * Address of the previously accepted socket for duplicate detection.
     */
    private SocketAddress previousAcceptedSocketRemoteAddress = null;

    /**
     * Nano time when the previous socket was accepted for duplicate detection.
     */
    private long previousAcceptedSocketNanoTime = 0;


    // ------------------------------------------------------------- Properties

    /**