Package edu.jas.gb
Class HybridReducerServerEC<C extends RingElem<C>>
- java.lang.Object
-
- edu.jas.gb.HybridReducerServerEC<C>
-
- Type Parameters:
C
- coefficient type
- All Implemented Interfaces:
java.lang.Runnable
class HybridReducerServerEC<C extends RingElem<C>> extends java.lang.Object implements java.lang.Runnable
Distributed server reducing worker proxy threads.
-
-
Field Summary
Fields Modifier and Type Field Description java.lang.Integer
ackTag
Message tag for acknowledgments.private ChannelFactory
cf
private static boolean
debug
private Terminator
finner
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
private int
threadsPerNode
-
Constructor Summary
Constructors Constructor Description HybridReducerServerEC(int tpn, Terminator fin, ChannelFactory cf, 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.
-
-
-
Field Detail
-
logger
private static final org.apache.logging.log4j.Logger logger
-
debug
private static final boolean debug
-
finner
private final Terminator finner
-
cf
private final ChannelFactory cf
-
pairChannel
private TaggedSocketChannel pairChannel
-
theList
private final DistHashTable<java.lang.Integer,GenPolynomial<C extends RingElem<C>>> theList
-
threadsPerNode
private final int threadsPerNode
-
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
-
HybridReducerServerEC
HybridReducerServerEC(int tpn, Terminator fin, ChannelFactory cf, DistHashTable<java.lang.Integer,GenPolynomial<C>> dl, PairList<C> L)
Constructor.- Parameters:
tpn
- number of threads per nodefin
- terminatorcf
- channel factorydl
- distributed hash tableL
- ordered pair list
-
-