Field Detail

• global

  protected RequestGroupInfo global

• registerCount

  protected AtomicLong registerCount

• connections

  protected final Map<S,Processor<S>> connections

• recycledProcessors

  protected AbstractProtocol.RecycledProcessors<P extends Processor<S>,S> recycledProcessors

Constructor Detail

• AbstractProtocol.AbstractConnectionHandler

  protected AbstractProtocol.AbstractConnectionHandler()

Method Detail

• getLog

  protected abstract Log getLog()

• getProtocol

  protected abstract AbstractProtocol<S> getProtocol()

• getGlobal

  public Object getGlobal()

  Description copied from interface: AbstractEndpoint.Handler
  Obtain the GlobalRequestProcessor associated with the handler.

  Specified by:

  getGlobal in interface AbstractEndpoint.Handler

  Returns:

  the GlobalRequestProcessor

• recycle

  public void recycle()

  Description copied from interface: AbstractEndpoint.Handler
  Recycle resources associated with the handler.

  Specified by:

  recycle in interface AbstractEndpoint.Handler

• process

  public AbstractEndpoint.Handler.SocketState process(SocketWrapper<S> wrapper,
                                             SocketStatus status)

• isAvailable

  public boolean isAvailable(SocketWrapper<S> wrapper)

• createProcessor

  protected abstract P createProcessor()

• initSsl

  protected abstract void initSsl(SocketWrapper<S> socket,
             Processor<S> processor)

• longPoll

  protected abstract void longPoll(SocketWrapper<S> socket,
              Processor<S> processor)

• release

  protected abstract void release(SocketWrapper<S> socket,
             Processor<S> processor,
             boolean socketClosing,
             boolean addToPoller)

• createUpgradeProcessor

  @Deprecated
  protected abstract Processor<S> createUpgradeProcessor(SocketWrapper<S> socket,
                                               UpgradeInbound inbound)
                                                  throws IOException

  Deprecated. Will be removed in Tomcat 8.0.x.
  Create an instance of an HTTP upgrade processor.

  Parameters:

  socket - The socket associated with the connection to upgrade

  inbound - Listener to which data available events should be passed

  Returns:

  A Processor instance for the upgraded connection

  Throws:

  IOException - if an I/O error occurred during the creation of the Processor

• createUpgradeProcessor

  protected abstract Processor<S> createUpgradeProcessor(SocketWrapper<S> socket,
                                    HttpUpgradeHandler httpUpgradeProcessor)
                                                  throws IOException

  Throws:

  IOException

• register

  protected void register(AbstractProcessor<S> processor)

• unregister

  protected void unregister(Processor<S> processor)