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.
-
-
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
-
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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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
-
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
- terminatora
- active remote tasks countpc
- tagged socket channeldl
- distributed hash tableL
- ordered pair list
-
-