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

Class AllGatherBatchFinalReceiver

java.lang.Object

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

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

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

All Implemented Interfaces:

MessageReceiver

public class AllGatherBatchFinalReceiver
extends BaseGatherBatchReceiver

Field Summary

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

gatheredValuesMap

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
AllGatherBatchFinalReceiver(TreeBroadcast bCast)

Method Summary

Modifier and Type	Method and Description
protected boolean	handleMessage(int task, java.lang.Object message, int flags, int dest)
protected boolean	isFilledToSend(int target, boolean sync) Return true if we are filled to send
protected boolean	sendSyncForward(int target) Handle the sync

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

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

AllGatherBatchFinalReceiver

public AllGatherBatchFinalReceiver(TreeBroadcast bCast)

Method Detail

sendSyncForward

protected boolean sendSyncForward(int target)

Description copied from class: SourceReceiver

Handle the sync

Specified by:

sendSyncForward in class SourceReceiver

Parameters:

target - target

Returns:

the needFurtherProgress

handleMessage

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

Specified by:

handleMessage in class BaseGatherBatchReceiver

isFilledToSend

protected boolean isFilledToSend(int target,
                                 boolean sync)

Description copied from class: SourceReceiver

Return true if we are filled to send

Specified by:

isFilledToSend in class SourceReceiver

Returns:

true if we are filled enough to send