Class HybridReducerClientEC<C extends RingElem<C>>

java.lang.Object

edu.jas.gb.HybridReducerClientEC<C>

All Implemented Interfaces:

Runnable

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

Distributed clients reducing worker threads.

Field Summary

Fields

Modifier and Type	Field	Description
final Integer	ackTag	Message tag for acknowledgments.
private static final boolean	debug
private static final org.apache.logging.log4j.Logger	logger
private final TaggedSocketChannel	pairChannel
final Integer	pairTag	Message tag for pairs.
private final ReductionPar<C>	red
final Integer	resultTag	Message tag for results.
private final DistHashTable<Integer, GenPolynomial<C>>	theList

Constructor Summary

Constructors

Constructor	Description
HybridReducerClientEC(TaggedSocketChannel tc, DistHashTable<Integer, GenPolynomial<C>> dl)	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

pairChannel

private final TaggedSocketChannel pairChannel

theList

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

red

private final ReductionPar<C extends RingElem<C>> red

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

HybridReducerClientEC

HybridReducerClientEC(TaggedSocketChannel tc,
 DistHashTable<Integer, GenPolynomial<C>> dl)

Constructor.

Parameters:

tc - tagged socket channel

dl - distributed hash table

Method Details

run

public void run()

Work loop.

Specified by:

run in interface Runnable

See Also:

• Runnable.run()