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

Class GatherBatchFinalReceiver

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.gather.GatherBatchFinalReceiver

All Implemented Interfaces:

MessageReceiver

public class GatherBatchFinalReceiver
extends BaseGatherBatchReceiver

Field Summary

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

gatheredValuesMap, LOG

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
GatherBatchFinalReceiver(BulkReceiver bulkReceiver) Constructs the gather batch final receiver

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	isFilledToSend(int target, boolean sync) Return true if we are filled to send
void	onSyncEvent(int target, byte[] value) This method is called when there is a sync event on the operation
protected boolean	sendSyncForward(int target) Handle the sync

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

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

GatherBatchFinalReceiver

public GatherBatchFinalReceiver(BulkReceiver bulkReceiver)

Constructs the gather batch final receiver

Parameters:

bulkReceiver - the receiver

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 BaseGatherBatchReceiver

expectedIds - expected task ids

handleMessage

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

Specified by:

handleMessage in class BaseGatherBatchReceiver

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

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

onSyncEvent

public void onSyncEvent(int target,
                        byte[] value)

Description copied from class: SourceReceiver

This method is called when there is a sync event on the operation

Overrides:

onSyncEvent in class BaseGatherBatchReceiver

Parameters:

target - the target to which the sync event belong

value - the byte value, can be null