Field Detail

• global

  protected final RequestGroupInfo global

• registerCount

  protected final java.util.concurrent.atomic.AtomicLong registerCount

• connections

  protected final java.util.Map<S,Processor<S>> connections

• recycledProcessors

  protected final 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 java.lang.Object getGlobal()

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

  Specified by:

  getGlobal in interface AbstractEndpoint.Handler

• 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)

• 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

  protected abstract Processor<S> createUpgradeProcessor(SocketWrapper<S> socket,
                                    java.nio.ByteBuffer leftoverInput,
                                    UpgradeToken upgradeToken)
                                                  throws java.io.IOException

  Throws:

  java.io.IOException

• register

  protected void register(AbstractProcessor<S> processor)

• unregister

  protected void unregister(Processor<S> processor)