Package com.sun.corba.ee.impl.transport

Class SelectorImpl

java.lang.Object

java.lang.Thread

com.sun.corba.ee.impl.transport.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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	SelectorImpl.SelectionKeyAndOp
(package private) static interface	SelectorImpl.Timer

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

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

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
SelectorImpl(ORB orb)
SelectorImpl(ORB orb, SelectorImpl.Timer timer)

Method Summary

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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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 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()

registerInterestOps

public void registerInterestOps(EventHandler eventHandler)

Specified by:

registerInterestOps in interface Selector

registerForEvent

public void registerForEvent(EventHandler eventHandler)

Specified by:

registerForEvent in interface Selector

unregisterForEvent

public void unregisterForEvent(EventHandler eventHandler)

Specified by:

unregisterForEvent in interface Selector

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()

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)