org.jlab.coda.cMsg.cMsgDomain.client

Class cMsgClientListeningThread

java.lang.Object

java.lang.Thread

org.jlab.coda.cMsg.cMsgDomain.client.cMsgClientListeningThread

All Implemented Interfaces:

java.lang.Runnable

class cMsgClientListeningThread
extends java.lang.Thread

This class implements a cMsg client's thread which listens for communications from the domain server. The server sends it keep alives, messages to which the client has subscribed, and other directives.

Note that the class org.jlab.cMsg.RCDomain.rcListeningThread is largely the same as this one. If there are any changes made here the identical changes should be made there as well.

Version:

1.0

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

Modifier and Type	Field and Description
(package private) byte[]	bytes Allocate byte array once (used for reading in data) for efficiency's sake.
(package private) java.io.DataInputStream	in Socket input stream associated with channel.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
cMsgClientListeningThread(cMsgServerClient myClient, java.net.Socket sock) Constructor for server clients.
cMsgClientListeningThread(cMsg myClient, java.net.Socket sock) Constructor for regular clients.

Method Summary

Modifier and Type	Method and Description
void	changeSockets(java.net.Socket sock) If reconnecting to another server as part of a failover, we must change to another channel.
void	killThread() Kills 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

Field Detail

in

java.io.DataInputStream in

Socket input stream associated with channel.

bytes

byte[] bytes

Allocate byte array once (used for reading in data) for efficiency's sake.

Constructor Detail

cMsgClientListeningThread

public cMsgClientListeningThread(cMsg myClient,
                                 java.net.Socket sock)
                          throws java.io.IOException

Constructor for regular clients.

Parameters:

myClient - cMsg client that created this object

sock - main communication socket with server

Throws:

java.io.IOException - if an I/O error occurs when creating the input stream, the socket is closed, the socket is not connected, or the socket input has been shutdown.

cMsgClientListeningThread

public cMsgClientListeningThread(cMsgServerClient myClient,
                                 java.net.Socket sock)
                          throws java.io.IOException

Constructor for server clients.

Parameters:

myClient - cMsg server client that created this object

sock - main communication socket with server

Throws:

java.io.IOException - if an I/O error occurs when creating the input stream, the socket is closed, the socket is not connected, or the socket input has been shutdown.

Method Detail

killThread

public void killThread()

Kills this thread.

changeSockets

public void changeSockets(java.net.Socket sock)
                   throws java.io.IOException

If reconnecting to another server as part of a failover, we must change to another channel. TODO: How do we call this while waiting on read???

Parameters:

sock - main communication socket with 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