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 interface
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private final List
<EventHandler> private final List
<SelectorImpl.SelectionKeyAndOp> private Map
<EventHandler, Long> private final Map
<EventHandler, ListenerThread> private ORB
private final Map
<EventHandler, ReaderThread> private Selector
private boolean
private static final SelectorImpl.Timer
private long
private SelectorImpl.Timer
private static final ORBUtilSystemException
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
private void
private void
void
close()
private void
private void
createListenerThread
(EventHandler eventHandler) private void
createReaderThread
(EventHandler eventHandler) private void
private void
destroyListenerThread
(EventHandler eventHandler) private void
destroyReaderThread
(EventHandler eventHandler) private void
private void
private void
long
private void
private void
private boolean
isClosed()
private void
void
registerForEvent
(EventHandler eventHandler) private void
void
registerInterestOps
(EventHandler eventHandler) void
run()
(package private) void
private void
private void
private void
selectResult
(boolean hasNext, int count) private void
setClosed
(boolean closed) void
setTimeout
(long timeout) private void
private void
void
unregisterForEvent
(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:
setTimeout
in interfaceSelector
-
getTimeout
@ManagedAttribute @Description("The selector timeout") public long getTimeout()- Specified by:
getTimeout
in interfaceSelector
-
display
-
closedEventHandler
@InfoMethod private void closedEventHandler() -
defaultCaseForEventHandler
@InfoMethod private void defaultCaseForEventHandler() -
registerInterestOps
- Specified by:
registerInterestOps
in interfaceSelector
-
registerForEvent
- Specified by:
registerForEvent
in interfaceSelector
-
unregisterForEvent
- Specified by:
unregisterForEvent
in 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
-