edu.iu.dsc.tws.comms.dfw.io.allreduce

Class AllReduceStreamingFinalReceiver

java.lang.Object

edu.iu.dsc.tws.comms.dfw.io.SourceReceiver

edu.iu.dsc.tws.comms.dfw.io.reduce.ReduceStreamingReceiver

edu.iu.dsc.tws.comms.dfw.io.allreduce.AllReduceStreamingFinalReceiver

All Implemented Interfaces:

MessageReceiver

public class AllReduceStreamingFinalReceiver
extends ReduceStreamingReceiver

Field Summary

Fields inherited from class edu.iu.dsc.tws.comms.dfw.io.reduce.ReduceStreamingReceiver

reduceFunction

Fields inherited from class edu.iu.dsc.tws.comms.dfw.io.SourceReceiver

barriers, destination, isSyncSent, messages, operation, sendPendingMax, sourcesOfTarget, syncReceived, syncState, targetStates, workerId

Constructor Summary

Constructors

Constructor and Description
AllReduceStreamingFinalReceiver(ReduceFunction reduceFunction, TreeBroadcast bcast)

Method Summary

Modifier and Type	Method and Description
boolean	handleMessage(int source, java.lang.Object message, int flags, int dest)
protected boolean	sendSyncForward(int target) Handle the sync

Methods inherited from class edu.iu.dsc.tws.comms.dfw.io.reduce.ReduceStreamingReceiver

aggregate, init, isAllEmpty, isFilledToSend, onSyncEvent, sendToTarget

Methods inherited from class edu.iu.dsc.tws.comms.dfw.io.SourceReceiver

allQueuesEmpty, allSyncsPresent, clean, isComplete, onFinish, onMessage, progress

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.iu.dsc.tws.api.comms.messaging.MessageReceiver

close, onMessage

Constructor Detail

AllReduceStreamingFinalReceiver

public AllReduceStreamingFinalReceiver(ReduceFunction reduceFunction,
                                       TreeBroadcast bcast)

Method Detail

handleMessage

public boolean handleMessage(int source,
                             java.lang.Object message,
                             int flags,
                             int dest)

Specified by:

handleMessage in class ReduceStreamingReceiver

sendSyncForward

protected boolean sendSyncForward(int target)

Description copied from class: SourceReceiver

Handle the sync

Overrides:

sendSyncForward in class ReduceStreamingReceiver

Parameters:

target - target

Returns:

the needFurtherProgress