edu.iu.harp.collective

Class BcastCollective

java.lang.Object

edu.iu.harp.collective.BcastCollective

public class BcastCollective
extends java.lang.Object

Broadcast Collective communication

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	LOG

Constructor Summary

Constructors

Constructor and Description
BcastCollective()

Method Summary

Modifier and Type	Method and Description
static <P extends Simple> boolean	broadcast(java.lang.String contextName, java.lang.String operationName, Table<P> table, int bcastWorkerID, boolean useMSTBcast, DataMap dataMap, Workers workers) The broadcast communication operation
static void	main(java.lang.String[] args)
static boolean	runByteArrayChainBcast(java.lang.String contextName, int workerID, int numBytes, int numLoops, DataMap dataMap, Workers workers)
static boolean	runChainBcast(java.lang.String contextName, int workerID, int numBytes, int numLoops, DataMap dataMap, Workers workers) Test for broadcasting using chain method
static boolean	runDoubleArrayTableBcast(java.lang.String contextName, int workerID, int numBytes, int numLoops, DataMap dataMap, Workers workers)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Logger LOG

Constructor Detail

BcastCollective

public BcastCollective()

Method Detail

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception

runChainBcast

public static boolean runChainBcast(java.lang.String contextName,
                                    int workerID,
                                    int numBytes,
                                    int numLoops,
                                    DataMap dataMap,
                                    Workers workers)

Test for broadcasting using chain method

runByteArrayChainBcast

public static boolean runByteArrayChainBcast(java.lang.String contextName,
                                             int workerID,
                                             int numBytes,
                                             int numLoops,
                                             DataMap dataMap,
                                             Workers workers)

runDoubleArrayTableBcast

public static boolean runDoubleArrayTableBcast(java.lang.String contextName,
                                               int workerID,
                                               int numBytes,
                                               int numLoops,
                                               DataMap dataMap,
                                               Workers workers)

broadcast

public static <P extends Simple> boolean broadcast(java.lang.String contextName,
                                                   java.lang.String operationName,
                                                   Table<P> table,
                                                   int bcastWorkerID,
                                                   boolean useMSTBcast,
                                                   DataMap dataMap,
                                                   Workers workers)

The broadcast communication operation

Parameters:

contextName - the name of the context

operationName - the name of the operation

table - the data Table

bcastWorkerID - the worker which broadcasts

useMSTBcast - use MST method or not

dataMap - the DataMap

workers - the Workers

Returns:

true if succeeded, false otherwise