org.jlab.coda.emu.test

Class VardanERSAP.CrateAggregatingConsumer

java.lang.Object

java.lang.Thread

org.jlab.coda.emu.test.VardanERSAP.CrateAggregatingConsumer

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

VardanERSAP

class VardanERSAP.CrateAggregatingConsumer
extends java.lang.Thread

Thread to consume from two streams in one crate and send (be a producer for) an output ring.

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) long	getOutSequence Current spot in output ring from which an item was claimed.
(package private) java.nio.ByteBuffer[]	inputItems Array to store items obtained from both the crate (input) rings.
(package private) java.nio.ByteBuffer[]	outputItems Array to store items obtained from both the output ring.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
CrateAggregatingConsumer()

Method Summary

Modifier and Type	Method and Description
void	get() Get the next available item from each crate ring buffer.
void	put() This "consumer" is also a producer for the output ring.
void	run()

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

inputItems

java.nio.ByteBuffer[] inputItems

Array to store items obtained from both the crate (input) rings.

outputItems

java.nio.ByteBuffer[] outputItems

Array to store items obtained from both the output ring.

getOutSequence

long getOutSequence

Current spot in output ring from which an item was claimed.

Constructor Detail

CrateAggregatingConsumer

CrateAggregatingConsumer()

Method Detail

get

public void get()
         throws java.lang.InterruptedException

Get the next available item from each crate ring buffer. Do NOT call this multiple times in a row! Be sure to call "put" before calling this again.

Throws:

java.lang.InterruptedException - if thread interrupted.

put

public void put()

This "consumer" is also a producer for the output ring. So get items from the output ring and fill them with items claimed from the input rings.

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread