org.jlab.coda.cMsg.cMsgDomain.subdomains

Class Et

java.lang.Object

org.jlab.coda.cMsg.common.cMsgSubdomainAdapter

org.jlab.coda.cMsg.cMsgDomain.subdomains.Et

All Implemented Interfaces:

cMsgSubdomainInterface

public class Et
extends cMsgSubdomainAdapter

cMsg subdomain handler for opening and putting events into an ET system. WARNING: This class may need some thread-safety measures added (Timmer).

Version:

1.0

Author:

Carl Timmer

Constructor Summary

Constructors

Constructor and Description
Et()

Method Summary

Modifier and Type	Method and Description
void	handleClientShutdown() Dump leftover events, then close the ET system.
void	handleSendRequest(cMsgMessageFull msg) If there are no events to work with, get chunk number of empty events from the ET system.
int	handleSyncSendRequest(cMsgMessageFull msg) If there are no events to work with, get chunk number of empty events from the ET system.
boolean	hasSend() Method to tell if the "send" cMsg API function is implemented by this interface implementation in the "handleSendRequest" method.
boolean	hasSyncSend() Method to tell if the "syncSend" cMsg API function is implemented by this interface implementation in the "handleSyncSendRequest" method.
void	registerClient(cMsgClientInfo info) Open ET system and attach to GrandCentral station.
void	setUDLRemainder(java.lang.String udlRemainder) Parse arg to get ET system file, method to open ET system, chunk size.

Methods inherited from class org.jlab.coda.cMsg.common.cMsgSubdomainAdapter

handleSendAndGetRequest, handleShutdownClientsRequest, handleSubscribeAndGetRequest, handleSubscribeRequest, handleUnSendAndGetRequest, handleUnsubscribeAndGetRequest, handleUnsubscribeRequest, hasSendAndGet, hasShutdown, hasSubscribe, hasSubscribeAndGet, hasUnsubscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

Et

public Et()

Method Detail

hasSend

public boolean hasSend()

Method to tell if the "send" cMsg API function is implemented by this interface implementation in the "handleSendRequest" method.

Specified by:

hasSend in interface cMsgSubdomainInterface

Overrides:

hasSend in class cMsgSubdomainAdapter

Returns:

true

hasSyncSend

public boolean hasSyncSend()

Method to tell if the "syncSend" cMsg API function is implemented by this interface implementation in the "handleSyncSendRequest" method.

Specified by:

hasSyncSend in interface cMsgSubdomainInterface

Overrides:

hasSyncSend in class cMsgSubdomainAdapter

Returns:

true

setUDLRemainder

public void setUDLRemainder(java.lang.String udlRemainder)
                     throws cMsgException

Parse arg to get ET system file, method to open ET system, chunk size.

Specified by:

setUDLRemainder in interface cMsgSubdomainInterface

Overrides:

setUDLRemainder in class cMsgSubdomainAdapter

Parameters:

udlRemainder - last part of the UDL appropriate to the subdomain handler

Throws:

cMsgException - if invalid arg

registerClient

public void registerClient(cMsgClientInfo info)
                    throws cMsgException

Open ET system and attach to GrandCentral station.

Specified by:

registerClient in interface cMsgSubdomainInterface

Overrides:

registerClient in class cMsgSubdomainAdapter

Parameters:

info - information about client

Throws:

cMsgException - upon IO error, bad arg, too many valid responses

handleSendRequest

public void handleSendRequest(cMsgMessageFull msg)
                       throws cMsgException

If there are no events to work with, get chunk number of empty events from the ET system. Take the binary array of the message argument, copy it into a single event, and put that event back into the ET system.

Specified by:

handleSendRequest in interface cMsgSubdomainInterface

Overrides:

handleSendRequest in class cMsgSubdomainAdapter

Parameters:

msg - message from sender

Throws:

cMsgException - if errors talking to ET system

handleSyncSendRequest

public int handleSyncSendRequest(cMsgMessageFull msg)
                          throws cMsgException

If there are no events to work with, get chunk number of empty events from the ET system. Take the binary array of the message argument, copy it into a single event, and put that event back into the ET system.

Specified by:

handleSyncSendRequest in interface cMsgSubdomainInterface

Overrides:

handleSyncSendRequest in class cMsgSubdomainAdapter

Parameters:

msg - message from sender

Returns:

0

Throws:

cMsgException - if errors talking to ET system

handleClientShutdown

public void handleClientShutdown()
                          throws cMsgException

Dump leftover events, then close the ET system.

Specified by:

handleClientShutdown in interface cMsgSubdomainInterface

Overrides:

handleClientShutdown in class cMsgSubdomainAdapter

Throws:

cMsgException - never