org.jlab.coda.cMsg.cMsgDomain.client

Class cMsg.KeepAlive

java.lang.Object

java.lang.Thread

org.jlab.coda.cMsg.cMsgDomain.client.cMsg.KeepAlive

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

cMsg

class cMsg.KeepAlive
extends java.lang.Thread

Class that checks the health of the domain server by reading monitoring information. If there is an IOException, server is assumed dead and a disconnect is done.

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
KeepAlive(java.net.Socket socket) Constructor.

Method Summary

Modifier and Type	Method and Description
void	changeChannels(java.net.Socket socket) If reconnecting to another server as part of a failover, we must change to another channel for keepAlives.
void	killThread() Kill this thread.
void	run() This method is executed as a thread.

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

KeepAlive

public KeepAlive(java.net.Socket socket)
          throws java.io.IOException

Constructor.

Parameters:

socket - communication socket with domain server

Throws:

java.io.IOException - if channel is closed

Method Detail

killThread

public void killThread()

Kill this thread.

changeChannels

public void changeChannels(java.net.Socket socket)
                    throws java.io.IOException

If reconnecting to another server as part of a failover, we must change to another channel for keepAlives.

Parameters:

socket - communication socket with domain server

Throws:

java.io.IOException - if channel is closed

run

public void run()

This method is executed as a thread.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread