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

Class DirectBatchFinalReceiver

java.lang.Object

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

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

edu.iu.dsc.tws.comms.dfw.io.direct.DirectBatchFinalReceiver

All Implemented Interfaces:

MessageReceiver

public class DirectBatchFinalReceiver
extends TargetFinalReceiver

Field Summary

Fields

Modifier and Type	Field and Description
protected BulkReceiver	receiver The receiver to be used to deliver the message

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

barriers, stateCleared, syncReceived, targetStates

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

destination, groupingSize, highWaterMark, lock, messages, operation, representSource, syncState, targets, thisDestinations, thisSources, workerId

Constructor Summary

Constructors

Constructor and Description
DirectBatchFinalReceiver(BulkReceiver receiver)
DirectBatchFinalReceiver(BulkReceiver receiver, boolean useDisk, MessageType actualDataType)

Method Summary

Modifier and Type	Method and Description
protected void	addSyncMessage(int source, int target) Add a sync message
protected void	addSyncMessageBarrier(int source, int target, byte[] barrier) Add a sync message
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	isAllEmpty(int target)
protected boolean	isFilledToSend(int target) Return true if we are filled to send
protected void	merge(int dest, java.util.List<java.lang.Object> dests) Swap the messages to the ready queue
protected boolean	onSyncEvent(int target, byte[] value) This method is called when there is a sync event on the operation
protected boolean	sendToTarget(int source, int target) Send the values to a target

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

canAcceptMessage, clean, isComplete, progress, sync

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

addMessage, clearTarget, onMessage

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

Field Detail

receiver

protected BulkReceiver receiver

The receiver to be used to deliver the message

Constructor Detail

DirectBatchFinalReceiver

public DirectBatchFinalReceiver(BulkReceiver receiver)

DirectBatchFinalReceiver

public DirectBatchFinalReceiver(BulkReceiver receiver,
                                boolean useDisk,
                                MessageType actualDataType)

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 TargetFinalReceiver

expectedIds - expected task ids

addSyncMessage

protected void addSyncMessage(int source,
                              int target)

Description copied from class: TargetReceiver

Add a sync message

Overrides:

addSyncMessage in class TargetFinalReceiver

Parameters:

source - source

target - target

addSyncMessageBarrier

protected void addSyncMessageBarrier(int source,
                                     int target,
                                     byte[] barrier)

Description copied from class: TargetReceiver

Add a sync message

Overrides:

addSyncMessageBarrier in class TargetFinalReceiver

Parameters:

source - source

target - target

barrier - the barrier message

merge

protected void merge(int dest,
                     java.util.List<java.lang.Object> dests)

Description copied from class: TargetReceiver

Swap the messages to the ready queue

Specified by:

merge in class TargetReceiver

Parameters:

dest - the target

dests - message queue to switch to ready

isAllEmpty

protected boolean isAllEmpty(int target)

Specified by:

isAllEmpty in class TargetFinalReceiver

sendToTarget

protected boolean sendToTarget(int source,
                               int target)

Description copied from class: TargetReceiver

Send the values to a target

Specified by:

sendToTarget in class TargetReceiver

Parameters:

source - the sources

target - the target

Returns:

true if all the values are sent successfully

isFilledToSend

protected boolean isFilledToSend(int target)

Description copied from class: TargetReceiver

Return true if we are filled to send

Specified by:

isFilledToSend in class TargetReceiver

Returns:

true if we are filled enough to send

onSyncEvent

protected boolean onSyncEvent(int target,
                              byte[] value)

Description copied from class: TargetReceiver

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

Specified by:

onSyncEvent in class TargetReceiver

Parameters:

target - the target to which the sync event belong

value - the byte value, can be null