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

Class AllGatherStreamingFinalReceiver

java.lang.Object

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

edu.iu.dsc.tws.comms.dfw.io.gather.GatherStreamingPartialReceiver

edu.iu.dsc.tws.comms.dfw.io.allgather.AllGatherStreamingFinalReceiver

All Implemented Interfaces:

MessageReceiver

public class AllGatherStreamingFinalReceiver
extends GatherStreamingPartialReceiver

Field Summary

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
AllGatherStreamingFinalReceiver(TreeBroadcast broadcast)

Method Summary

Modifier and Type	Method and Description
protected boolean	handleMessage(int task, java.lang.Object message, int flags, int dest)
void	init(Config cfg, DataFlowOperation op, java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> expectedIds) Initialize the message receiver with tasks from which messages are expected For each sub edge in graph, for each path, gives the expected task ids
protected boolean	sendSyncForward(int target) Handle the sync

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

aggregate, 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

AllGatherStreamingFinalReceiver

public AllGatherStreamingFinalReceiver(TreeBroadcast broadcast)

Method Detail

init

public void init(Config cfg,
                 DataFlowOperation op,
                 java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> expectedIds)

Description copied from interface: MessageReceiver

Initialize the message receiver with tasks from which messages are expected For each sub edge in graph, for each path, gives the expected task ids

target -> source tasks

Specified by:

init in interface MessageReceiver

Overrides:

init in class GatherStreamingPartialReceiver

expectedIds - expected task ids

handleMessage

protected boolean handleMessage(int task,
                                java.lang.Object message,
                                int flags,
                                int dest)

Overrides:

handleMessage in class GatherStreamingPartialReceiver

sendSyncForward

protected boolean sendSyncForward(int target)

Description copied from class: SourceReceiver

Handle the sync

Overrides:

sendSyncForward in class GatherStreamingPartialReceiver

Parameters:

target - target

Returns:

the needFurtherProgress