Package edu.jas.gb

Class HybridReducerReceiverEC<C extends RingElem<C>>

java.lang.Object

java.lang.Thread

edu.jas.gb.HybridReducerReceiverEC<C>

Type Parameters:

C - coefficient type

All Implemented Interfaces:

java.lang.Runnable

class HybridReducerReceiverEC<C extends RingElem<C>>
extends java.lang.Thread

Distributed server receiving worker thread.

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	Description
java.lang.Integer	ackTag	Message tag for acknowledgments.
private java.util.concurrent.atomic.AtomicInteger	active
private static boolean	debug
private Terminator	finner
private boolean	goon
private static org.apache.logging.log4j.Logger	logger
private TaggedSocketChannel	pairChannel
private PairList<C>	pairlist
java.lang.Integer	pairTag	Message tag for pairs.
java.lang.Integer	resultTag	Message tag for results.
private DistHashTable<java.lang.Integer,GenPolynomial<C>>	theList

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
HybridReducerReceiverEC(Terminator fin, java.util.concurrent.atomic.AtomicInteger a, TaggedSocketChannel pc, DistHashTable<java.lang.Integer,GenPolynomial<C>> dl, PairList<C> L)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	run()	Work loop.
void	terminate()	Terminate.

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

logger

private static final org.apache.logging.log4j.Logger logger

debug

private static final boolean debug

theList

private final DistHashTable<java.lang.Integer,GenPolynomial<C extends RingElem<C>>> theList

pairlist

private final PairList<C extends RingElem<C>> pairlist

pairChannel

private final TaggedSocketChannel pairChannel

finner

private final Terminator finner

active

private final java.util.concurrent.atomic.AtomicInteger active

goon

private volatile boolean goon

pairTag

public final java.lang.Integer pairTag

Message tag for pairs.

resultTag

public final java.lang.Integer resultTag

Message tag for results.

ackTag

public final java.lang.Integer ackTag

Message tag for acknowledgments.

Constructor Detail

HybridReducerReceiverEC

HybridReducerReceiverEC(Terminator fin,
                        java.util.concurrent.atomic.AtomicInteger a,
                        TaggedSocketChannel pc,
                        DistHashTable<java.lang.Integer,GenPolynomial<C>> dl,
                        PairList<C> L)

Constructor.

Parameters:

fin - terminator

a - active remote tasks count

pc - tagged socket channel

dl - distributed hash table

L - ordered pair list

Method Detail

run

public void run()

Work loop.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

See Also:

Thread.run()

terminate

public void terminate()

Terminate.