Package com.sun.corba.ee.impl.transport
Class SelectorImpl
java.lang.Object
java.lang.Thread
com.sun.corba.ee.impl.transport.SelectorImpl
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate static class(package private) static interfaceNested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate booleanprivate final List<EventHandler> private final List<SelectorImpl.SelectionKeyAndOp> private Map<EventHandler, Long> private final Map<EventHandler, ListenerThread> private ORBprivate final Map<EventHandler, ReaderThread> private Selectorprivate booleanprivate static final SelectorImpl.Timerprivate longprivate SelectorImpl.Timerprivate static final ORBUtilSystemExceptionFields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate voidprivate voidprivate voidvoidclose()private voidprivate voidcreateListenerThread(EventHandler eventHandler) private voidcreateReaderThread(EventHandler eventHandler) private voidprivate voiddestroyListenerThread(EventHandler eventHandler) private voiddestroyReaderThread(EventHandler eventHandler) private voidprivate voidprivate voidlongprivate voidprivate voidprivate booleanisClosed()private voidvoidregisterForEvent(EventHandler eventHandler) private voidvoidregisterInterestOps(EventHandler eventHandler) voidrun()(package private) voidprivate voidprivate voidprivate voidselectResult(boolean hasNext, int count) private voidsetClosed(boolean closed) voidsetTimeout(long timeout) private voidprivate voidvoidunregisterForEvent(EventHandler eventHandler) Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
-
Field Details
-
wrapper
-
orb
-
timer
-
selector
-
timeout
private long timeout -
deferredRegistrations
-
interestOpsList
-
listenerThreads
-
readerThreads
-
selectorStarted
private boolean selectorStarted -
closed
private volatile boolean closed -
lastActivityTimers
-
SYSTEM_TIMER
-
-
Constructor Details
-
SelectorImpl
-
SelectorImpl
SelectorImpl(ORB orb, SelectorImpl.Timer timer)
-
-
Method Details
-
setTimeout
public void setTimeout(long timeout) - Specified by:
setTimeoutin interfaceSelector
-
getTimeout
@ManagedAttribute @Description("The selector timeout") public long getTimeout()- Specified by:
getTimeoutin interfaceSelector
-
display
-
closedEventHandler
@InfoMethod private void closedEventHandler() -
defaultCaseForEventHandler
@InfoMethod private void defaultCaseForEventHandler() -
registerInterestOps
- Specified by:
registerInterestOpsin interfaceSelector
-
registerForEvent
- Specified by:
registerForEventin interfaceSelector
-
unregisterForEvent
- Specified by:
unregisterForEventin interfaceSelector
-
close
public void close() -
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() -
runSelectionLoopOnce
- Throws:
IOException
-
isClosed
private boolean isClosed() -
setClosed
private void setClosed(boolean closed) -
selectorStarted
@InfoMethod private void selectorStarted() -
startSelector
private void startSelector() -
registeringEventHandler
-
handleDeferredRegistrations
private void handleDeferredRegistrations() -
ignoringCancelledKeyException
@InfoMethod private void ignoringCancelledKeyException() -
keyAndOpInfo
-
enableInterestOps
private void enableInterestOps() -
createListenerThread
-
cannotFindListenerThread
@InfoMethod private void cannotFindListenerThread() -
destroyListenerThread
-
createReaderThread
-
cannotFindReaderThread
@InfoMethod private void cannotFindReaderThread() -
destroyReaderThread
-