com.threerings.presents.server.net

Class PresentsConnectionManager

java.lang.Object

java.lang.Thread

com.samskivert.util.LoopingThread

com.threerings.nio.conman.ConnectionManager

com.threerings.presents.server.net.PresentsConnectionManager

All Implemented Interfaces:

Lifecycle.BaseComponent, Lifecycle.ShutdownComponent, ReportManager.Reporter, Runnable

public class PresentsConnectionManager
extends ConnectionManager
implements ReportManager.Reporter

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
PresentsConnectionManager(Lifecycle cycle, ReportManager repmgr)

Method Summary

Modifier and Type	Method and Description
void	addChainedAuthenticator(ChainedAuthenticator author) Adds an authenticator to the authentication chain.
void	appendReport(StringBuilder report, long now, long sinceLast, boolean reset) Requests that this reporter append its report to the supplied string buffer.
PrivateKey	getPrivateKey() Returns the private key used in secure authentication.
PresentsConMgrStats	getStats() Returns our current runtime statistics.
boolean	isRunning()
void	openOutgoingConnection(Connection conn, String hostname, int port) Opens an outgoing connection to the supplied address.
boolean	setPrivateKey(PrivateKey key) Sets the private key if the ciphers are supported.
boolean	setPrivateKey(String key) Sets the private key if the ciphers are supported.

Methods inherited from class com.threerings.nio.conman.ConnectionManager

closeConnection, register, setShutdownAction, transferAcceptedSocket

Methods inherited from class com.samskivert.util.LoopingThread

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

PresentsConnectionManager

@Inject
public PresentsConnectionManager(Lifecycle cycle,
                                         ReportManager repmgr)
                                  throws IOException

Throws:

IOException

Method Detail

getStats

public PresentsConMgrStats getStats()

Description copied from class: ConnectionManager

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.

Overrides:

getStats in class ConnectionManager

appendReport

public void appendReport(StringBuilder report,
                         long now,
                         long sinceLast,
                         boolean reset)

Description copied from interface: ReportManager.Reporter

Requests that this reporter append its report to the supplied string buffer.

Specified by:

appendReport in interface ReportManager.Reporter

Parameters:

report - the string buffer to which the report text should be appended.

now - the time at which the report generation began, in epoch millis.

sinceLast - number of milliseconds since the last time we generated a report.

reset - if true, all accumulating stats should be reset, if false they should be allowed to continue to accumulate.

addChainedAuthenticator

public void addChainedAuthenticator(ChainedAuthenticator author)

Adds an authenticator to the authentication chain. This authenticator will be offered a chance to authenticate incoming connections before falling back to the main authenticator.

setPrivateKey

public boolean setPrivateKey(PrivateKey key)

Sets the private key if the ciphers are supported.

Returns:

true if the key is set

setPrivateKey

public boolean setPrivateKey(String key)

Sets the private key if the ciphers are supported.

Returns:

true if the key is set

getPrivateKey

public PrivateKey getPrivateKey()

Returns the private key used in secure authentication.

openOutgoingConnection

public void openOutgoingConnection(Connection conn,
                                   String hostname,
                                   int port)
                            throws IOException

Opens an outgoing connection to the supplied address. The connection will be opened in a non-blocking manner and added to the connection manager's select set. Messages posted to the connection prior to it being actually connected to its destination will remain in the queue. If the connection fails those messages will be dropped.

Parameters:

conn - the connection to be initialized and opened. Callers may want to provide a Connection derived class so that they may intercept calldown methods.

hostname - the hostname of the server to which to connect.

port - the port on which to connect to the server.

Throws:

IOException - thrown if an error occurs creating our socket. Everything else happens asynchronously. If the connection attempt fails, the Connection will be notified via Connection.networkFailure(java.io.IOException).

isRunning

public boolean isRunning()

Overrides:

isRunning in class LoopingThread