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 Classes Modifier and Type Class Description private static class
SelectorImpl.SelectionKeyAndOp
(package private) static interface
SelectorImpl.Timer
-
Field Summary
Fields Modifier and Type Field Description private boolean
closed
private java.util.List<EventHandler>
deferredRegistrations
private java.util.List<SelectorImpl.SelectionKeyAndOp>
interestOpsList
private java.util.Map<EventHandler,java.lang.Long>
lastActivityTimers
private java.util.Map<EventHandler,ListenerThread>
listenerThreads
private ORB
orb
private java.util.Map<EventHandler,ReaderThread>
readerThreads
private java.nio.channels.Selector
selector
private boolean
selectorStarted
private static SelectorImpl.Timer
SYSTEM_TIMER
private long
timeout
private SelectorImpl.Timer
timer
private static ORBUtilSystemException
wrapper
-
Constructor Summary
Constructors Constructor Description SelectorImpl(ORB orb)
SelectorImpl(ORB orb, SelectorImpl.Timer timer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
beginSelect()
private void
cannotFindListenerThread()
private void
cannotFindReaderThread()
void
close()
private void
closedEventHandler()
private void
createListenerThread(EventHandler eventHandler)
private void
createReaderThread(EventHandler eventHandler)
private void
defaultCaseForEventHandler()
private void
destroyListenerThread(EventHandler eventHandler)
private void
destroyReaderThread(EventHandler eventHandler)
private void
display(java.lang.String msg, java.lang.Object value)
private void
enableInterestOps()
private void
endSelect()
long
getTimeout()
private void
handleDeferredRegistrations()
private void
ignoringCancelledKeyException()
private boolean
isClosed()
private void
keyAndOpInfo(SelectorImpl.SelectionKeyAndOp val)
void
registerForEvent(EventHandler eventHandler)
private void
registeringEventHandler(EventHandler eh)
void
registerInterestOps(EventHandler eventHandler)
void
run()
(package private) void
runSelectionLoopOnce()
private void
selectorClosed()
private void
selectorStarted()
private void
selectResult(boolean hasNext, int count)
private void
setClosed(boolean closed)
void
setTimeout(long timeout)
private void
skippingEventForCancelledKey()
private void
startSelector()
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 Detail
-
wrapper
private static final ORBUtilSystemException wrapper
-
orb
private ORB orb
-
timer
private SelectorImpl.Timer timer
-
selector
private java.nio.channels.Selector selector
-
timeout
private long timeout
-
deferredRegistrations
private final java.util.List<EventHandler> deferredRegistrations
-
interestOpsList
private final java.util.List<SelectorImpl.SelectionKeyAndOp> interestOpsList
-
listenerThreads
private final java.util.Map<EventHandler,ListenerThread> listenerThreads
-
readerThreads
private final java.util.Map<EventHandler,ReaderThread> readerThreads
-
selectorStarted
private boolean selectorStarted
-
closed
private volatile boolean closed
-
lastActivityTimers
private java.util.Map<EventHandler,java.lang.Long> lastActivityTimers
-
SYSTEM_TIMER
private static final SelectorImpl.Timer SYSTEM_TIMER
-
-
Constructor Detail
-
SelectorImpl
public SelectorImpl(ORB orb)
-
SelectorImpl
SelectorImpl(ORB orb, SelectorImpl.Timer timer)
-
-
Method Detail
-
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
@InfoMethod private void display(java.lang.String msg, java.lang.Object value)
-
closedEventHandler
@InfoMethod private void closedEventHandler()
-
defaultCaseForEventHandler
@InfoMethod private void defaultCaseForEventHandler()
-
registerInterestOps
public void registerInterestOps(EventHandler eventHandler)
- Specified by:
registerInterestOps
in interfaceSelector
-
registerForEvent
public void registerForEvent(EventHandler eventHandler)
- Specified by:
registerForEvent
in interfaceSelector
-
unregisterForEvent
public void unregisterForEvent(EventHandler eventHandler)
- Specified by:
unregisterForEvent
in interfaceSelector
-
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 interfacejava.lang.Runnable
- Overrides:
run
in classjava.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()
-
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)
-
-