Module com.aoindustries.aoserv.master

Package com.aoindustries.aoserv.master

Class SocketServerThread

java.lang.Object

java.lang.Thread

com.aoindustries.aoserv.master.SocketServerThread

All Implemented Interfaces:

RequestSource, Runnable

public final class SocketServerThread
extends Thread
implements RequestSource

The AOServServerThread handles a connection once it is accepted.

Author:

AO Industries, Inc.

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	Description
SocketServerThread(TcpServer server, Socket socket)	Creates a new, running AOServServerThread.

Method Summary

Modifier and Type	Method	Description
void	cachesInvalidated(IntList tableList)	Invalidates the listed tables.
Identifier	getConnectorId()
User.Name	getCurrentAdministrator()
int	getDaemonServer()	Gets the id of the server that this connection is created from.
InvalidateCacheEntry	getNextInvalidatedTables()
AoservProtocol.Version	getProtocolVersion()	Gets the protocol version number supported by the client.
String	getSecurityMessageHeader()	Logs a security message to System.err.
boolean	isClosed()
boolean	isSecure()	Determines if the communication with the client is currently secure.
void	run()

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, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Details

SocketServerThread

public SocketServerThread(TcpServer server,
 Socket socket)
                   throws IOException,
SQLException

Creates a new, running AOServServerThread.

Throws:

IOException

SQLException

Method Details

cachesInvalidated

public void cachesInvalidated(IntList tableList)
                       throws IOException

Invalidates the listed tables. Also, if this connector represents a daemon, this invalidate is registered with ServerHandler for invalidation synchronization.

IDEA: Could reduce signals under high load by combining entries that are not synchronous. Could even combine synchronous ones as long as all sync entries were acknowledged in the proper order.

Specified by:

cachesInvalidated in interface RequestSource

Throws:

IOException

getDaemonServer

public int getDaemonServer()

Description copied from interface: RequestSource

Gets the id of the server that this connection is created from. This is only used by connections initiated by daemons.

Specified by:

getDaemonServer in interface RequestSource

Returns:

the id of the server or -1 for none

getNextInvalidatedTables

public InvalidateCacheEntry getNextInvalidatedTables()

Specified by:

getNextInvalidatedTables in interface RequestSource

getConnectorId

public Identifier getConnectorId()

Specified by:

getConnectorId in interface RequestSource

getProtocolVersion

public AoservProtocol.Version getProtocolVersion()

Description copied from interface: RequestSource

Gets the protocol version number supported by the client.

Specified by:

getProtocolVersion in interface RequestSource

getSecurityMessageHeader

public String getSecurityMessageHeader()

Logs a security message to System.err. Also sends email messages to aoserv.server.

Specified by:

getSecurityMessageHeader in interface RequestSource

getCurrentAdministrator

public User.Name getCurrentAdministrator()

Specified by:

getCurrentAdministrator in interface RequestSource

isSecure

public boolean isSecure()
                 throws UnknownHostException

Description copied from interface: RequestSource

Determines if the communication with the client is currently secure.

Specified by:

isSecure in interface RequestSource

Throws:

UnknownHostException

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

isClosed

public boolean isClosed()

Specified by:

isClosed in interface RequestSource