org.jlab.coda.cMsg.cMsgDomain.server

Class cMsgDomainServer

java.lang.Object

java.lang.Thread

org.jlab.coda.cMsg.cMsgDomain.server.cMsgDomainServer

All Implemented Interfaces:

java.lang.Runnable

class cMsgDomainServer
extends java.lang.Thread

Domain Server which services a number of clients through select and nonblocking sockets.

Nested Class Summary

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.util.concurrent.atomic.AtomicBoolean	calledShutdown Keep track of whether the shutdown method of this object has already been called.
(package private) static java.lang.String	domainType Type of domain this is.
(package private) cMsgClientData	info Object containing information about the client this object is connected to.
(package private) boolean	killSpawnedThreads Kill all spawned threads if true.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
cMsgDomainServer(cMsgNameServer nameServer, cMsgClientData info, boolean noUdp, int debug) Constructor.

Method Summary

Modifier and Type	Method and Description
void	finalize() Method to be run when this server's client is dead or disconnected and the server threads will be killed.
cMsgSubdomainInterface	getSubdomainHandler() Getter for the subdomain handler object.
int	getUdpPort() Getter for the UDP port being used.
void	killSpawnedThreads() Kill spawned threads.
(package private) void	shutdown() Method to gracefully shutdown this object's threads and clean things up.
(package private) void	startThreads() Start reading and writing over the sockets.

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, run, 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

Field Detail

domainType

static java.lang.String domainType

Type of domain this is.

info

cMsgClientData info

Object containing information about the client this object is connected to. Certain members of info can only be filled in by this thread, such as the listening port.

calledShutdown

java.util.concurrent.atomic.AtomicBoolean calledShutdown

Keep track of whether the shutdown method of this object has already been called.

killSpawnedThreads

volatile boolean killSpawnedThreads

Kill all spawned threads if true.

Constructor Detail

cMsgDomainServer

public cMsgDomainServer(cMsgNameServer nameServer,
                        cMsgClientData info,
                        boolean noUdp,
                        int debug)
                 throws cMsgException

Constructor.

Parameters:

nameServer - nameServer object which created (is creating) this object

info - object containing client data

noUdp - if true, do not create and listen on a udp socket.

debug - level of debug output.

Throws:

cMsgException - if UDP listening socket could not be opened

Method Detail

killSpawnedThreads

public void killSpawnedThreads()

Kill spawned threads.

getUdpPort

public int getUdpPort()

Getter for the UDP port being used.

Returns:

UDP port being used; if none used, return -1

getSubdomainHandler

public cMsgSubdomainInterface getSubdomainHandler()

Getter for the subdomain handler object.

Returns:

subdomain handler object

startThreads

void startThreads()
           throws java.io.IOException

Start reading and writing over the sockets. Start threads to process client requests.

Throws:

java.io.IOException - if streams to and from client cannot be opened

finalize

public void finalize()

Method to be run when this server's client is dead or disconnected and the server threads will be killed.

Finalize methods are run after an object has become unreachable and before the garbage collector is run.

Overrides:

finalize in class java.lang.Object

shutdown

void shutdown()

Method to gracefully shutdown this object's threads and clean things up.