org.jlab.coda.cMsg.cMsgDomain.server

Class cMsgMonitorClient

java.lang.Object

java.lang.Thread

org.jlab.coda.cMsg.cMsgDomain.server.cMsgMonitorClient

All Implemented Interfaces:

java.lang.Runnable

class cMsgMonitorClient
extends java.lang.Thread

This class implements an object to monitor the health of all cMsg clients connected to this server and to provide these clients with evidence of this server's health. It does this by doing 2 things: 1) it periodically sends monitoring data about the whole cmsg system to all the clients, and 2) it reads monitoring data from each client. If there is an error in reading, the client is assumed dead. All resources associated with that client are recovered for reuse.

Author:

Carl Timmer

Nested Class Summary

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

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

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
cMsgMonitorClient(cMsgNameServer server, int debug) Constructor.

Method Summary

Modifier and Type	Method and Description
(package private) void	addClient(cMsgClientData info, cMsgDomainServer ds) Method to add another client for monitoring.
(package private) void	addClient(cMsgClientData info, cMsgDomainServerSelect dss) Method to add another client for monitoring.
static java.nio.ByteBuffer	copyBuffer(java.nio.ByteBuffer original) Copy a buffer.
(package private) void	removeClient(cMsgClientData info) Method to remove a client from being monitored.
(package private) void	shutdown() Shuts down all client monitoring threads.
void	updateMonitorXML() This method updates the XML string representing the state of this server and the XML string representing the state of the complete cMsg system - cMsg subdomain.

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

Constructor Detail

cMsgMonitorClient

public cMsgMonitorClient(cMsgNameServer server,
                         int debug)
                  throws java.io.IOException

Constructor. Creates a socket channel with the client.

Parameters:

server - domain server which created this monitor

debug - level of debug output

Throws:

java.io.IOException - if selector cannot be opened

Method Detail

copyBuffer

public static java.nio.ByteBuffer copyBuffer(java.nio.ByteBuffer original)

Copy a buffer.

Parameters:

original - buffer to copy or source

Returns:

copied buffer or destination

shutdown

void shutdown()

Shuts down all client monitoring threads.

addClient

void addClient(cMsgClientData info,
               cMsgDomainServerSelect dss)

Method to add another client for monitoring.

Parameters:

info - information on client

dss - cMsgDomainServerSelect object

addClient

void addClient(cMsgClientData info,
               cMsgDomainServer ds)

Method to add another client for monitoring.

Parameters:

info - information on client

ds - cMsgDomainServer object

removeClient

void removeClient(cMsgClientData info)

Method to remove a client from being monitored.

Parameters:

info - information on client

updateMonitorXML

public void updateMonitorXML()

This method updates the XML string representing the state of this server and the XML string representing the state of the complete cMsg system - cMsg subdomain.