Class SelectorImpl

  • All Implemented Interfaces:
    Selector, java.lang.Runnable

    @ManagedObject
    @Description("The Selector, which handles incoming requests to the ORB")
    public class SelectorImpl
    extends java.lang.Thread
    implements Selector
    • Method Detail

      • 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​(java.lang.String msg,
                             java.lang.Object value)
      • closedEventHandler

        @InfoMethod
        private void closedEventHandler()
      • defaultCaseForEventHandler

        @InfoMethod
        private void defaultCaseForEventHandler()
      • 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 java.lang.Runnable
        Overrides:
        run in class java.lang.Thread
      • runSelectionLoopOnce

        void runSelectionLoopOnce()
                           throws java.io.IOException
        Throws:
        java.io.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()
      • 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)