org.jlab.coda.cMsg.RCServerDomain

Class rcListeningThread

java.lang.Object

java.lang.Thread

org.jlab.coda.cMsg.RCServerDomain.rcListeningThread

All Implemented Interfaces:

java.lang.Runnable

class rcListeningThread
extends java.lang.Thread

This class implements a thread to listen to runcontrol clients in the runcontrol server domain over TCP.

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.CountDownLatch	startLatch Let connect() know that the client has established a connection to this server.
(package private) int	tcpPort Tcp listening port.
(package private) int	udpPort Udp listening port.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
rcListeningThread(RCServer server) Constructor for regular clients.

Method Summary

Modifier and Type	Method and Description
int	getTcpPort() Get the TCP listening port of this server.
int	getUdpPort() Get the UDP listening port of this server.
(package private) 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

tcpPort

int tcpPort

Tcp listening port.

udpPort

int udpPort

Udp listening port.

startLatch

final java.util.concurrent.CountDownLatch startLatch

Let connect() know that the client has established a connection to this server.

Constructor Detail

rcListeningThread

public rcListeningThread(RCServer server)
                  throws cMsgException

Constructor for regular clients.

Parameters:

server - RC server that created this object

Throws:

cMsgException - if TCP socket cannot be created or cannot bind to a port, or if UDP socket cannot be created.

Method Detail

killThread

void killThread()

Kills this thread.

getTcpPort

public int getTcpPort()

Get the TCP listening port of this server.

Returns:

TCP listening port of this server

getUdpPort

public int getUdpPort()

Get the UDP listening port of this server.

Returns:

UDP listening port of this server

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