Package com.google.code.yanf4j.nio.impl

Class Reactor

java.lang.Object

java.lang.Thread

com.google.code.yanf4j.nio.impl.Reactor

All Implemented Interfaces:

Runnable

public final class Reactor
extends Thread

Reactor pattern

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Reactor.PaddingAtomicBoolean
static class	Reactor.RegisterEvent

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

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final Configuration	configuration
private final NioController	controller
static final int	DEFAULT_WAIT
private final Lock	gate
private final AtomicInteger	jvmBug
static final int	JVMBUG_THRESHHOLD	JVM bug threshold
static final int	JVMBUG_THRESHHOLD1
static final int	JVMBUG_THRESHHOLD2
private boolean	jvmBug0
private boolean	jvmBug1
private long	lastCheckTimestamp
private long	lastJVMBug
private static final org.slf4j.Logger	log
private long	nextTimeout
private final int	reactorIndex
private Queue<Reactor.RegisterEvent>	register
private Selector	selector
private final SelectorManager	selectorManager
private int	selectTries
private final AtomicBoolean	wakenUp

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
Reactor(SelectorManager selectorManager, Configuration configuration, int index)

Method Summary

Modifier and Type	Method	Description
(package private) final void	beforeSelect()
private final boolean	checkExpired(SelectionKey key, Session session)
private long	checkExpiredIdle(SelectionKey key, Session session)
private final void	checkIdle(Session session)
private final long	checkSessionTimeout()	Check session timeout or idle
final void	dispatchEvent(Set<SelectionKey> selectedKeySet)	Dispatch selected event
private final void	dispatchSessionEvent(Session session, EventType event)
(package private) Configuration	getConfiguration()
int	getReactorIndex()
final Selector	getSelector()
private final Session	getSessionFromAttchment(SelectionKey key)
private boolean	isNeedCheckSessionIdleTimeout()
private final boolean	isReactorThread()
private boolean	lookJVMBug(long before, int selected, long wait)	Look jvm bug
final void	postSelect(Set<SelectionKey> selectedKeys, Set<SelectionKey> allKeys)
private final void	processRegister()
final void	registerChannel(SelectableChannel channel, int ops, Object attachment)
private void	registerChannelNow(SelectableChannel channel, int ops, Object attachment)
final void	registerSession(Session session, EventType event)
void	run()
(package private) final void	selectNow()
(package private) final void	unregisterChannel(SelectableChannel channel)
(package private) final void	wakeup()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, toString, yield

Methods inherited from class java.lang.Object

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

Field Details

JVMBUG_THRESHHOLD

public static final int JVMBUG_THRESHHOLD

JVM bug threshold

JVMBUG_THRESHHOLD2

public static final int JVMBUG_THRESHHOLD2

JVMBUG_THRESHHOLD1

public static final int JVMBUG_THRESHHOLD1

DEFAULT_WAIT

public static final int DEFAULT_WAIT

See Also:

• Constant Field Values

log

private static final org.slf4j.Logger log

jvmBug0

private boolean jvmBug0

jvmBug1

private boolean jvmBug1

reactorIndex

private final int reactorIndex

selectorManager

private final SelectorManager selectorManager

jvmBug

private final AtomicInteger jvmBug

lastJVMBug

private long lastJVMBug

selector

private Selector selector

controller

private final NioController controller

configuration

private final Configuration configuration

wakenUp

private final AtomicBoolean wakenUp

register

private Queue<Reactor.RegisterEvent> register

gate

private final Lock gate

selectTries

private int selectTries

nextTimeout

private long nextTimeout

lastCheckTimestamp

private long lastCheckTimestamp

Constructor Details

Reactor

Reactor(SelectorManager selectorManager,
 Configuration configuration,
 int index)
 throws IOException

Throws:

IOException

Method Details

getSelector

public final Selector getSelector()

getReactorIndex

public int getReactorIndex()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

lookJVMBug

private boolean lookJVMBug(long before,
 int selected,
 long wait)
                    throws IOException

Look jvm bug

Parameters:

before -

selected -

wait -

Returns:

Throws:

IOException

dispatchEvent

public final void dispatchEvent(Set<SelectionKey> selectedKeySet)

Dispatch selected event

Parameters:

selectedKeySet -

unregisterChannel

final void unregisterChannel(SelectableChannel channel)
                      throws IOException

Throws:

IOException

checkSessionTimeout

private final long checkSessionTimeout()

Check session timeout or idle

Returns:

isNeedCheckSessionIdleTimeout

private boolean isNeedCheckSessionIdleTimeout()

getSessionFromAttchment

private final Session getSessionFromAttchment(SelectionKey key)

registerSession

public final void registerSession(Session session,
 EventType event)

isReactorThread

private final boolean isReactorThread()

beforeSelect

final void beforeSelect()

processRegister

private final void processRegister()

getConfiguration

Configuration getConfiguration()

dispatchSessionEvent

private final void dispatchSessionEvent(Session session,
 EventType event)

postSelect

public final void postSelect(Set<SelectionKey> selectedKeys,
 Set<SelectionKey> allKeys)

checkExpiredIdle

private long checkExpiredIdle(SelectionKey key,
 Session session)

checkIdle

private final void checkIdle(Session session)

checkExpired

private final boolean checkExpired(SelectionKey key,
 Session session)

registerChannel

public final void registerChannel(SelectableChannel channel,
 int ops,
 Object attachment)

registerChannelNow

private void registerChannelNow(SelectableChannel channel,
 int ops,
 Object attachment)

wakeup

final void wakeup()

selectNow

final void selectNow()
              throws IOException

Throws:

IOException