org.jlab.coda.cMsg.cMsgDomain.server

Class cMsgServerSendAndGetter

java.lang.Object

org.jlab.coda.cMsg.cMsgDomain.server.cMsgServerSendAndGetter

All Implemented Interfaces:

java.lang.Runnable

class cMsgServerSendAndGetter
extends java.lang.Object
implements java.lang.Runnable

This class handles a server client's sendAndGet request and propagates it to all the connected servers. It takes care of all the details of getting a response and forwarding that to the client as well as cancelling the request to servers after the first response is received.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) cMsgNotifier	notifier Wait on this object which tells us when a response message has been sent to a sendAndGet so we can notify bridges to cancel their sendAndGets.
(package private) java.util.concurrent.ConcurrentHashMap<java.lang.Integer,cMsgServerSendAndGetter>	sendAndGetters A map of all cMsgServerSendAndGetter objects (threads) for this client.

Constructor Summary

Constructors

Constructor and Description
cMsgServerSendAndGetter(cMsgNameServer nameServer, cMsgNotifier notifier, java.util.concurrent.ConcurrentHashMap<java.lang.Integer,cMsgServerSendAndGetter> sendAndGetters) Constructor.

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

notifier

cMsgNotifier notifier

Wait on this object which tells us when a response message has been sent to a sendAndGet so we can notify bridges to cancel their sendAndGets.

sendAndGetters

java.util.concurrent.ConcurrentHashMap<java.lang.Integer,cMsgServerSendAndGetter> sendAndGetters

A map of all cMsgServerSendAndGetter objects (threads) for this client.

Constructor Detail

cMsgServerSendAndGetter

public cMsgServerSendAndGetter(cMsgNameServer nameServer,
                               cMsgNotifier notifier,
                               java.util.concurrent.ConcurrentHashMap<java.lang.Integer,cMsgServerSendAndGetter> sendAndGetters)

Constructor.

Parameters:

nameServer - server

notifier - notifier

sendAndGetters - map of all cMsgServerSendAndGetter objects (threads) for this client

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable