org.shared.net.nio

Class NioManagerDispatchThread

java.lang.Object

java.lang.Thread

org.shared.net.nio.NioManagerThread

org.shared.net.nio.NioManagerDispatchThread

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable, EnumStatus<NioManagerThread.NioManagerThreadStatus>, SourceLocal<NioEvent<?>>

public class NioManagerDispatchThread
extends NioManagerThread

A specialized NioManagerThread that dispatches newly created connections to NioManagerIoThreads.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	NioManagerDispatchThread.AcceptRegistry A bookkeeping class for storing pending accepts on listening sockets.

Nested classes/interfaces inherited from class org.shared.net.nio.NioManagerThread

NioManagerThread.NioManagerThreadStatus, NioManagerThread.Request<I,O>

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class org.shared.net.nio.NioManagerThread

exception, fsm, fsmInternal, log, queue, requests, selector, status

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	NioManagerDispatchThread(String name, int nThreads) Default constructor.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	dispatch(NioConnection conn) Dispatches the given connection to an NioManagerIoThread.
protected void	doAccept(SelectionKey key) Finishes the accept cycle on a ready ServerSocketChannel.
protected void	doConnect(NioConnection conn) Finishes the connect cycle on a ready connection.
protected void	doReadyOps(int readyOps, SelectionKey key) Performs actions stipulated by a ready operations bit vector on the given SelectionKey.
protected void	handleAccept(NioConnection conn, InetSocketAddress address) Handles a connection accept request.
protected void	handleConnect(NioConnection conn, InetSocketAddress address) Handles a connection connect request.
protected void	handleGetBacklogSize(NioManagerThread.Request<?,Integer> request) Handles a request to get the listen backlog size.
protected void	handleGetBoundAddresses(NioManagerThread.Request<?,List<InetSocketAddress>> request) Handles a request to get the list of bound addresses.
protected void	handleGetConnections(NioManagerThread.Request<?,List<Future<List<NioConnection>>>> request) Handles a request to get the list of connections, which consists of pending connections aggregated with the lists reported by helper NioManagerIoThreads.
protected void	handleRegister(NioConnection conn, SocketChannel chan) Handles a connection registration request.
protected void	handleSetBacklogSize(NioManagerThread.Request<Integer,?> request) Handles a request to set the listen backlog size.
protected void	onStart() On thread start.
protected void	onStop() On thread stop.
protected void	purge(NioConnection conn) A sequence of actions to take when deleting a connection, as far as this thread is concerned.
void	start() Starts this thread and its helper NioManagerIoThreads.

Methods inherited from class org.shared.net.nio.NioManagerThread

close, debug, debug, getStatus, handleClose, handleClosingEos, handleClosingUser, handleError, handleInvoke, handleOp, handleShutdown, initFsms, onLocal, request, run, setStatus, toString

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, stop, stop, suspend, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

NioManagerDispatchThread

protected NioManagerDispatchThread(String name,
                        int nThreads)

Default constructor.

Method Detail

onStart

protected void onStart()

Description copied from class: NioManagerThread

On thread start.

Specified by:

onStart in class NioManagerThread

onStop

protected void onStop()

Description copied from class: NioManagerThread

On thread stop.

Specified by:

onStop in class NioManagerThread

doReadyOps

protected void doReadyOps(int readyOps,
              SelectionKey key)

Description copied from class: NioManagerThread

Performs actions stipulated by a ready operations bit vector on the given SelectionKey.

Specified by:

doReadyOps in class NioManagerThread

purge

protected void purge(NioConnection conn)

Description copied from class: NioManagerThread

A sequence of actions to take when deleting a connection, as far as this thread is concerned.

Specified by:

purge in class NioManagerThread

start

public void start()

Starts this thread and its helper NioManagerIoThreads.

Overrides:

start in class Thread

dispatch

protected void dispatch(NioConnection conn)

Dispatches the given connection to an NioManagerIoThread.

doAccept

protected void doAccept(SelectionKey key)

Finishes the accept cycle on a ready ServerSocketChannel.

doConnect

protected void doConnect(NioConnection conn)

Finishes the connect cycle on a ready connection.

handleConnect

protected void handleConnect(NioConnection conn,
                 InetSocketAddress address)

Handles a connection connect request.

handleAccept

protected void handleAccept(NioConnection conn,
                InetSocketAddress address)

Handles a connection accept request.

handleRegister

protected void handleRegister(NioConnection conn,
                  SocketChannel chan)

Handles a connection registration request.

handleGetBoundAddresses

protected void handleGetBoundAddresses(NioManagerThread.Request<?,List<InetSocketAddress>> request)

Handles a request to get the list of bound addresses.

handleGetConnections

protected void handleGetConnections(NioManagerThread.Request<?,List<Future<List<NioConnection>>>> request)

Handles a request to get the list of connections, which consists of pending connections aggregated with the lists reported by helper NioManagerIoThreads.

handleGetBacklogSize

protected void handleGetBacklogSize(NioManagerThread.Request<?,Integer> request)

Handles a request to get the listen backlog size.

handleSetBacklogSize

protected void handleSetBacklogSize(NioManagerThread.Request<Integer,?> request)

Handles a request to set the listen backlog size.