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

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

Methods inherited from class java.lang.Object

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

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

pairlist

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

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 node

fin - terminator

cf - channel factory

dl - distributed hash table

L - ordered pair list

Method Detail

run

public void run()

Work loop.

Specified by:

run in interface java.lang.Runnable

See Also:

Runnable.run()