org.jlab.coda.emu.test

Class InputDataChannelImplEmu

java.lang.Object

org.jlab.coda.emu.test.InputDataChannelImplEmu

class InputDataChannelImplEmu
extends java.lang.Object

This class is a simplified version of DataChannelImplEmu class.

Field Summary

Fields

Modifier and Type	Field and Description
protected ByteBufferSupply[]	bbSupply Ring buffers holding ByteBuffers when using EvioCompactEvent reader for incoming events.
(package private) org.jlab.coda.emu.test.InputDataChannelImplEmu.StatisticsThread	statThread

Constructor Summary

Constructors

Constructor and Description
InputDataChannelImplEmu() Constructor to create a new DataChannelImplEt instance.

Method Summary

Modifier and Type	Method and Description
(package private) void	attachToInput(java.nio.channels.SocketChannel channel, int sourceId, int maxBufferSize, int socketCount, int socketPosition) Once a client connects to the Emu domain server in the Emu transport object, that socket is passed to this method and a thread is spawned to handle all communications over it.

Methods inherited from class java.lang.Object

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

Field Detail

bbSupply

protected ByteBufferSupply[] bbSupply

Ring buffers holding ByteBuffers when using EvioCompactEvent reader for incoming events.

statThread

org.jlab.coda.emu.test.InputDataChannelImplEmu.StatisticsThread statThread

Constructor Detail

InputDataChannelImplEmu

InputDataChannelImplEmu()

Constructor to create a new DataChannelImplEt instance. Used only by DataTransportImplEt.createChannel(String, java.util.Map, boolean, org.jlab.coda.emu.Emu, org.jlab.coda.emu.EmuModule, int) which is only used during PRESTART in Emu.

Method Detail

attachToInput

void attachToInput(java.nio.channels.SocketChannel channel,
                   int sourceId,
                   int maxBufferSize,
                   int socketCount,
                   int socketPosition)
            throws java.io.IOException

Once a client connects to the Emu domain server in the Emu transport object, that socket is passed to this method and a thread is spawned to handle all communications over it. Only used for input channel.

Parameters:

channel - data input socket/channel

sourceId - CODA id # of data source

maxBufferSize - biggest chunk of data expected to be sent by data producer

socketCount - total # of sockets data producer will be making

socketPosition - position with respect to other data producers: 1, 2 ...

Throws:

java.io.IOException - if exception dealing with socket or input stream