Class SelectorImpl

java.lang.Object
java.lang.Thread
com.sun.corba.ee.impl.transport.SelectorImpl
All Implemented Interfaces:
Selector, Runnable

@ManagedObject @Description("The Selector, which handles incoming requests to the ORB") public class SelectorImpl extends Thread implements Selector
  • Field Details

  • Constructor Details

  • Method Details

    • setTimeout

      public void setTimeout(long timeout)
      Specified by:
      setTimeout in interface Selector
    • getTimeout

      @ManagedAttribute @Description("The selector timeout") public long getTimeout()
      Specified by:
      getTimeout in interface Selector
    • display

      @InfoMethod private void display(String msg, Object value)
    • closedEventHandler

      @InfoMethod private void closedEventHandler()
    • defaultCaseForEventHandler

      @InfoMethod private void defaultCaseForEventHandler()
    • registerInterestOps

      public void registerInterestOps(EventHandler eventHandler)
      Specified by:
      registerInterestOps in interface Selector
    • registerForEvent

      public void registerForEvent(EventHandler eventHandler)
      Specified by:
      registerForEvent in interface Selector
    • unregisterForEvent

      public void unregisterForEvent(EventHandler eventHandler)
      Specified by:
      unregisterForEvent in interface Selector
    • close

      public void close()
      Specified by:
      close in interface Selector
    • beginSelect

      @InfoMethod private void beginSelect()
    • endSelect

      @InfoMethod private void endSelect()
    • selectorClosed

      @InfoMethod private void selectorClosed()
    • selectResult

      @InfoMethod private void selectResult(boolean hasNext, int count)
    • skippingEventForCancelledKey

      @InfoMethod private void skippingEventForCancelledKey()
    • run

      public void run()
      Specified by:
      run in interface Runnable
      Overrides:
      run in class Thread
    • runSelectionLoopOnce

      void runSelectionLoopOnce() throws IOException
      Throws:
      IOException
    • isClosed

      private boolean isClosed()
    • setClosed

      private void setClosed(boolean closed)
    • selectorStarted

      @InfoMethod private void selectorStarted()
    • startSelector

      private void startSelector()
    • registeringEventHandler

      @InfoMethod private void registeringEventHandler(EventHandler eh)
    • handleDeferredRegistrations

      private void handleDeferredRegistrations()
    • ignoringCancelledKeyException

      @InfoMethod private void ignoringCancelledKeyException()
    • keyAndOpInfo

      @InfoMethod private void keyAndOpInfo(SelectorImpl.SelectionKeyAndOp val)
    • enableInterestOps

      private void enableInterestOps()
    • createListenerThread

      private void createListenerThread(EventHandler eventHandler)
    • cannotFindListenerThread

      @InfoMethod private void cannotFindListenerThread()
    • destroyListenerThread

      private void destroyListenerThread(EventHandler eventHandler)
    • createReaderThread

      private void createReaderThread(EventHandler eventHandler)
    • cannotFindReaderThread

      @InfoMethod private void cannotFindReaderThread()
    • destroyReaderThread

      private void destroyReaderThread(EventHandler eventHandler)