Class SelectorManager

java.lang.Object
com.google.code.yanf4j.nio.impl.SelectorManager

public class SelectorManager extends Object
Selector manager
  • Field Details

    • reactorSet

      private final Reactor[] reactorSet
    • sets

      private final AtomicInteger sets
    • controller

      private final NioController controller
    • dividend

      private final int dividend
    • reactorReadyCount

      private int reactorReadyCount
      Reactor count which are ready
    • started

      private volatile boolean started
    • REACTOR_ATTRIBUTE

      public static final String REACTOR_ATTRIBUTE
    • log

      private static final org.slf4j.Logger log
  • Constructor Details

  • Method Details

    • getSelectorCount

      public int getSelectorCount()
    • start

      public void start()
    • getReactorFromSession

      Reactor getReactorFromSession(Session session)
    • getReactorByIndex

      public Reactor getReactorByIndex(int index)
      Find reactor by index
      Parameters:
      index -
      Returns:
    • stop

      public void stop()
    • registerChannel

      public final Reactor registerChannel(SelectableChannel channel, int ops, Object attachment)
      Register channel
      Parameters:
      channel -
      ops -
      attachment -
      Returns:
    • awaitReady

      void awaitReady()
    • nextReactor

      public final Reactor nextReactor()
      Get next reactor
      Returns:
    • registerSession

      public final void registerSession(Session session, EventType event)
      Register session
      Parameters:
      session -
      event -
    • getController

      public NioController getController()
    • notifyReady

      void notifyReady()
      Notify all reactor have been ready
    • isStarted

      public final boolean isStarted()