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

Class DFWIOUtils

java.lang.Object

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

public final class DFWIOUtils
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	HEADER_SIZE
static int	SHORT_HEADER_SIZE

Method Summary

Modifier and Type	Method and Description
static void	buildHeader(DataBuffer buffer, OutMessage sendMessage, int noOfMessages) Builds the header of the message.
static java.lang.String	getOperationName(int target, DataFlowOperation op, int refresh)
static boolean	sendFinalSyncForward(int target, SyncState syncState, java.util.Map<java.lang.Integer,byte[]> barriers, DataFlowOperation operation, java.util.Map<java.lang.Integer,java.lang.Boolean> isSyncSent)
static boolean	sendSyncForward(int target, SyncState syncState, java.util.Map<java.lang.Integer,byte[]> barriers, DataFlowOperation operation, java.util.Map<java.lang.Integer,java.lang.Boolean> isSyncSent)

Methods inherited from class java.lang.Object

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

Field Detail

HEADER_SIZE

public static final int HEADER_SIZE

See Also:

Constant Field Values

SHORT_HEADER_SIZE

public static final int SHORT_HEADER_SIZE

See Also:

Constant Field Values

Method Detail

getOperationName

public static java.lang.String getOperationName(int target,
                                                DataFlowOperation op,
                                                int refresh)

buildHeader

public static void buildHeader(DataBuffer buffer,
                               OutMessage sendMessage,
                               int noOfMessages)

Builds the header of the message. The length value is inserted later so 0 is added as a place holder value. The header structure is |source|flags|destinationID|length|

Parameters:

buffer - the buffer to which the header is placed

sendMessage - the message that the header is build for

noOfMessages - number of messages in this single message

sendSyncForward

public static boolean sendSyncForward(int target,
                                      SyncState syncState,
                                      java.util.Map<java.lang.Integer,byte[]> barriers,
                                      DataFlowOperation operation,
                                      java.util.Map<java.lang.Integer,java.lang.Boolean> isSyncSent)

sendFinalSyncForward

public static boolean sendFinalSyncForward(int target,
                                           SyncState syncState,
                                           java.util.Map<java.lang.Integer,byte[]> barriers,
                                           DataFlowOperation operation,
                                           java.util.Map<java.lang.Integer,java.lang.Boolean> isSyncSent)