at.chrl.nutils.network

Class Dispatcher

java.lang.Object

java.lang.Thread

at.chrl.nutils.network.Dispatcher

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

AcceptDispatcherImpl, AcceptReadWriteDispatcherImpl

public abstract class Dispatcher
extends Thread

Dispatcher that dispatch SelectionKeys set selected by Selector.

Author:

-Nemesiss-

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
Dispatcher(String name, Executor dcPool) Constructor.

Method Summary

Modifier and Type	Method and Description
protected void	closeConnectionImpl(AConnection con) Connection will be closed [onlyClose()] and onDisconnect() method will be executed on another thread [DisconnectionThreadPool] after getDisconnectionDelay() time in ms.
SelectionKey	register(SelectableChannel ch, int ops, Acceptor att) Register new Acceptor this Dispatcher and return SelectionKey (result of registration).
void	register(SelectableChannel ch, int ops, AConnection att) Register new client connected to this Dispatcher and set SelectionKey (result of registration) as this key of given AConnection.
void	run() Dispatching Selected keys and processing pending close.
Selector	selector()

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

Constructor Detail

Dispatcher

public Dispatcher(String name,
                  Executor dcPool)
           throws IOException

Constructor.

Parameters:

name -

dcPool -

Throws:

IOException

Method Detail

selector

public final Selector selector()

Returns:

Selector of this Dispatcher

run

public void run()

Dispatching Selected keys and processing pending close.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

See Also:

Thread.run()

register

public final void register(SelectableChannel ch,
                           int ops,
                           AConnection att)
                    throws IOException

Register new client connected to this Dispatcher and set SelectionKey (result of registration) as this key of given AConnection.

Parameters:

ch -

ops -

att -

Throws:

IOException

register

public final SelectionKey register(SelectableChannel ch,
                                   int ops,
                                   Acceptor att)
                            throws IOException

Register new Acceptor this Dispatcher and return SelectionKey (result of registration).

Parameters:

ch -

ops -

att -

Returns:

SelectionKey representing this registration.

Throws:

IOException

closeConnectionImpl

protected final void closeConnectionImpl(AConnection con)

Connection will be closed [onlyClose()] and onDisconnect() method will be executed on another thread [DisconnectionThreadPool] after getDisconnectionDelay() time in ms. This method may only be called by current Dispatcher Thread.

Parameters:

con -