com.threerings.nio.conman

Class ConnectionManager

java.lang.Object

java.lang.Thread

com.samskivert.util.LoopingThread

com.threerings.nio.conman.ConnectionManager

All Implemented Interfaces:

Lifecycle.BaseComponent, Lifecycle.ShutdownComponent, Runnable

Direct Known Subclasses:

PolicyServer, PresentsConnectionManager

public abstract class ConnectionManager
extends LoopingThread
implements Lifecycle.ShutdownComponent

Manages socket connections. It creates connection objects for each socket connection, but those connection objects interact closely with the connection manager because network I/O is done via a poll()-like mechanism rather than via threads.

ConnectionManager doesn't directly accept TCP connections; it expects ServerSocketChannelAcceptor or an external entity to do so and call its handleAcceptedSocket(java.nio.channels.SocketChannel) method

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
ConnectionManager(Lifecycle cycle, long idleTime) Creates a connection manager instance.

Method Summary

Modifier and Type	Method and Description
void	closeConnection(Connection conn) Queues a connection up to be closed on the conmgr thread.
ConMgrStats	getStats() Returns our current runtime statistics.
SelectionKey	register(SelectableChannel chan, int ops, NetEventHandler netEventHandler) Registers ops on chan on this manager's selector and hooks netEventHandler up to receive events whenever the selection occurs.
void	setShutdownAction(Runnable onExit) Instructs us to execute the specified runnable when the connection manager thread exits.
void	transferAcceptedSocket(SocketChannel channel) Introduces a new active socket into Presents from off the ConnectionManager thread.

Methods inherited from class com.samskivert.util.LoopingThread

isRunning, run, shutdown

Methods inherited from class java.lang.Thread

activeCount, checkAccess, 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, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.samskivert.util.Lifecycle.ShutdownComponent

shutdown

Constructor Detail

ConnectionManager

public ConnectionManager(Lifecycle cycle,
                         long idleTime)
                  throws IOException

Creates a connection manager instance.

Throws:

IOException

Method Detail

setShutdownAction

public void setShutdownAction(Runnable onExit)

Instructs us to execute the specified runnable when the connection manager thread exits. Note: this will be executed on the connection manager thread, so don't do anything dangerous. Only one action may be specified and it may be cleared by calling this method with null.

getStats

public ConMgrStats getStats()

Returns our current runtime statistics. Note: don't call this method too frequently as it is synchronized and will contend with the network I/O thread.

register

public SelectionKey register(SelectableChannel chan,
                             int ops,
                             NetEventHandler netEventHandler)
                      throws IOException

Registers ops on chan on this manager's selector and hooks netEventHandler up to receive events whenever the selection occurs.

Throws:

IOException

transferAcceptedSocket

public void transferAcceptedSocket(SocketChannel channel)

Introduces a new active socket into Presents from off the ConnectionManager thread. If Presents is embedded in another framework that handles socket acceptance, this will be called by its socket acceptor to get the socket into Presents to start authorization.

closeConnection

public void closeConnection(Connection conn)

Queues a connection up to be closed on the conmgr thread.