Class HybridReducerServerEC<C extends RingElem<C>>

java.lang.Object

edu.jas.gb.HybridReducerServerEC<C>

Type Parameters:

C - coefficient type

All Implemented Interfaces:

Runnable

class HybridReducerServerEC<C extends RingElem<C>>
extends Object
implements Runnable

Distributed server reducing worker proxy threads.

Field Summary

Fields

Modifier and Type	Field	Description
final Integer	ackTag	Message tag for acknowledgments.
private final ChannelFactory	cf
private static final boolean	debug
private final Terminator	finner
private static final org.apache.logging.log4j.Logger	logger
private TaggedSocketChannel	pairChannel
private final PairList<C>	pairlist
final Integer	pairTag	Message tag for pairs.
final Integer	resultTag	Message tag for results.
private final DistHashTable<Integer, GenPolynomial<C>>	theList
private final int	threadsPerNode

Constructor Summary

Constructors

Constructor	Description
HybridReducerServerEC(int tpn, Terminator fin, ChannelFactory cf, DistHashTable<Integer, GenPolynomial<C>> dl, PairList<C> L)	Constructor.

Method Summary

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

Methods inherited from class Object

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

Field Details

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<Integer, GenPolynomial<C extends RingElem<C>>> theList

pairlist

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

threadsPerNode

private final int threadsPerNode

pairTag

public final Integer pairTag

Message tag for pairs.

resultTag

public final Integer resultTag

Message tag for results.

ackTag

public final Integer ackTag

Message tag for acknowledgments.

Constructor Details

HybridReducerServerEC

HybridReducerServerEC(int tpn,
 Terminator fin,
 ChannelFactory cf,
 DistHashTable<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 Details

run

public void run()

Work loop.

Specified by:

run in interface Runnable

See Also:

• Runnable.run()