org.jlab.coda.emu.support.transport

Class DataTransportImplEmu

java.lang.Object

org.jlab.coda.emu.support.codaComponent.CODAStateMachineAdapter

org.jlab.coda.emu.support.transport.DataTransportAdapter

org.jlab.coda.emu.support.transport.DataTransportImplEmu

All Implemented Interfaces:

CODAStateMachine, StatedObject, DataTransport

public class DataTransportImplEmu
extends DataTransportAdapter

This class specifies a single cMsg server. Connects to and disconnects from the server.

Author:

timmer (4/18/2014)

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.util.HashMap<java.lang.Integer,DataChannelImplEmu>	inputChannelTable

Fields inherited from class org.jlab.coda.emu.support.transport.DataTransportAdapter

attr, connected, emu, errorMsg, isServer, name, transportClass, transportState

Constructor Summary

Constructors

Constructor and Description
DataTransportImplEmu(java.lang.String pname, java.util.Map<java.lang.String,java.lang.String> attrib, Emu emu) Constructor called during "download".

Method Summary

Modifier and Type	Method and Description
DataChannel	createChannel(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> attributeMap, boolean isInput, Emu emu, EmuModule module, int outputIndex) This method creates a DataChannel object.
void	reset() This method implements the RESET transition of the CODA run control state machine.

Methods inherited from class org.jlab.coda.emu.support.transport.DataTransportAdapter

getAttr, getError, getIntAttr, getTransportClass, isConnected, isServer, name, setAttr, setConnected, setName, state

Methods inherited from class org.jlab.coda.emu.support.codaComponent.CODAStateMachineAdapter

download, end, getEndCallback, getPrestartCallback, go, pause, prestart, registerEndCallback, registerPrestartCallback

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jlab.coda.emu.support.codaComponent.CODAStateMachine

download, end, getEndCallback, getPrestartCallback, go, pause, prestart, registerEndCallback, registerPrestartCallback

Field Detail

inputChannelTable

final java.util.HashMap<java.lang.Integer,DataChannelImplEmu> inputChannelTable

Constructor Detail

DataTransportImplEmu

public DataTransportImplEmu(java.lang.String pname,
                            java.util.Map<java.lang.String,java.lang.String> attrib,
                            Emu emu)
                     throws DataNotFoundException,
                            org.jlab.coda.cMsg.cMsgException

Constructor called during "download".

Parameters:

pname - name of transport

attrib - transport's attribute map from config file

emu - emu object this transport belongs to

Throws:

DataNotFoundException - when udl not given or cannot connect to cmsg server

org.jlab.coda.cMsg.cMsgException - cannot startup emu domain server

Method Detail

createChannel

public DataChannel createChannel(java.lang.String name,
                                 java.util.Map<java.lang.String,java.lang.String> attributeMap,
                                 boolean isInput,
                                 Emu emu,
                                 EmuModule module,
                                 int outputIndex)
                          throws DataTransportException

This method creates a DataChannel object.

Parameters:

name - name of DataChannel

attributeMap - hashmap of attributes taken from XML config file

isInput - true if this channel puts data into the Emu, else false

emu - Emu owning this channel

module - module creating this channel

outputIndex - order in which module's events will be sent to this output channel (0 for first output channel, 1 for next, etc.).

Returns:

DataChannel object

Throws:

DataTransportException - if transport problem

reset

public void reset()

This method implements the RESET transition of the CODA run control state machine.. Disconnect from cMsg server.

Specified by:

reset in interface CODAStateMachine

Overrides:

reset in class DataTransportAdapter