40 import com.sun.corba.se.pept.transport.Acceptor;
  41 import com.sun.corba.se.pept.transport.Connection;
  42 import com.sun.corba.se.pept.transport.EventHandler;
  43 import com.sun.corba.se.pept.transport.ListenerThread;
  44 import com.sun.corba.se.pept.transport.ReaderThread;
  45 
  46 import com.sun.corba.se.spi.logging.CORBALogDomains;
  47 import com.sun.corba.se.spi.orb.ORB;
  48 import com.sun.corba.se.spi.orbutil.threadpool.Work;
  49 import com.sun.corba.se.spi.orbutil.threadpool.NoSuchThreadPoolException;
  50 import com.sun.corba.se.spi.orbutil.threadpool.NoSuchWorkQueueException;
  51 
  52 import com.sun.corba.se.impl.logging.ORBUtilSystemException;
  53 import com.sun.corba.se.impl.orbutil.ORBUtility;
  54 
  55 /**
  56  * @author Harold Carr
  57  */
  58 class SelectorImpl
  59     extends
  60         ManagedLocalsThread
  61     implements
  62         com.sun.corba.se.pept.transport.Selector
  63 {
  64     private ORB orb;
  65     private Selector selector;
  66     private long timeout;
  67     private List deferredRegistrations;
  68     private List interestOpsList;
  69     private HashMap listenerThreads;
  70     private Map readerThreads;
  71     private boolean selectorStarted;
  72     private volatile boolean closed;
  73     private ORBUtilSystemException wrapper;
  74 
  75 
  76     public SelectorImpl(ORB orb)
  77     {
  78         this.orb = orb;
  79         selector = null;
  80         selectorStarted = false;

  40 import com.sun.corba.se.pept.transport.Acceptor;
  41 import com.sun.corba.se.pept.transport.Connection;
  42 import com.sun.corba.se.pept.transport.EventHandler;
  43 import com.sun.corba.se.pept.transport.ListenerThread;
  44 import com.sun.corba.se.pept.transport.ReaderThread;
  45 
  46 import com.sun.corba.se.spi.logging.CORBALogDomains;
  47 import com.sun.corba.se.spi.orb.ORB;
  48 import com.sun.corba.se.spi.orbutil.threadpool.Work;
  49 import com.sun.corba.se.spi.orbutil.threadpool.NoSuchThreadPoolException;
  50 import com.sun.corba.se.spi.orbutil.threadpool.NoSuchWorkQueueException;
  51 
  52 import com.sun.corba.se.impl.logging.ORBUtilSystemException;
  53 import com.sun.corba.se.impl.orbutil.ORBUtility;
  54 
  55 /**
  56  * @author Harold Carr
  57  */
  58 class SelectorImpl
  59     extends
  60         sun.misc.ManagedLocalsThread
  61     implements
  62         com.sun.corba.se.pept.transport.Selector
  63 {
  64     private ORB orb;
  65     private Selector selector;
  66     private long timeout;
  67     private List deferredRegistrations;
  68     private List interestOpsList;
  69     private HashMap listenerThreads;
  70     private Map readerThreads;
  71     private boolean selectorStarted;
  72     private volatile boolean closed;
  73     private ORBUtilSystemException wrapper;
  74 
  75 
  76     public SelectorImpl(ORB orb)
  77     {
  78         this.orb = orb;
  79         selector = null;
  80         selectorStarted = false;