edu.iu.harp.collective

Class Communication

java.lang.Object

edu.iu.harp.collective.Communication

public class Communication
extends java.lang.Object

These methods are used for communicating non-partition transferable.

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	LOG

Constructor Summary

Constructors

Constructor and Description
Communication()

Method Summary

Modifier and Type	Method and Description
static boolean	allgather(java.lang.String contextName, java.lang.String operationName, java.util.List<Transferable> objs, DataMap dataMap, Workers workers) Allgather collective communication operation
static boolean	barrier(java.lang.String contextName, java.lang.String operationName, DataMap dataMap, Workers workers) In barrier, each worker send a message to master.
static boolean	chainBcast(java.lang.String contextName, int bcastWorkerID, java.lang.String operationName, java.util.List<Transferable> objs, Workers workers) The broadcast communication operation using chain method.
static boolean	chainBcastAndRecv(java.lang.String contextName, int bcastWorkerID, java.lang.String operationName, java.util.List<Transferable> objs, Workers workers, DataMap dataMap) The broadcast communication operation using chain method.
static boolean	gather(java.lang.String contextName, java.lang.String operationName, java.util.List<Transferable> objs, int gatherWorkerID, DataMap dataMap, Workers workers) Gather collective communication operation
static boolean	mstBcast(java.lang.String contextName, int bcastWorkerID, java.lang.String operationName, java.util.List<Transferable> objs, Workers workers) The broadcast communication operation using MST method.
static boolean	mstBcastAndRecv(java.lang.String contextName, int bcastWorkerID, java.lang.String operationName, java.util.List<Transferable> objs, Workers workers, DataMap dataMap) The broadcast communication operation using MST method.

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

Communication

public Communication()

Method Detail

barrier

public static boolean barrier(java.lang.String contextName,
                              java.lang.String operationName,
                              DataMap dataMap,
                              Workers workers)

In barrier, each worker send a message to master. If the master gets all the messages, sends true to all workers to leave the barrier. Else it sends false to all the workers.

Parameters:

contextName - the name of operation context

operationName - the name of the operation

dataMap - the DataMap

workers - the Workers

Returns:

true if succeeded, false otherwise

gather

public static boolean gather(java.lang.String contextName,
                             java.lang.String operationName,
                             java.util.List<Transferable> objs,
                             int gatherWorkerID,
                             DataMap dataMap,
                             Workers workers)

Gather collective communication operation

Parameters:

contextName - the name of the context

operationName - the name of the operation

objs - the list of Transferable objects

gatherWorkerID - the WorkerID to send

dataMap - the DataMap

workers - the Workers

Returns:

true if succeeded, false otherwise

allgather

public static boolean allgather(java.lang.String contextName,
                                java.lang.String operationName,
                                java.util.List<Transferable> objs,
                                DataMap dataMap,
                                Workers workers)

Allgather collective communication operation

Parameters:

contextName - the name of the context

operationName - the name of the operation

objs - the list of Transferable objects

dataMap - the DataMap

workers - the Workers

Returns:

true if succeeded, false otherwise

chainBcast

public static boolean chainBcast(java.lang.String contextName,
                                 int bcastWorkerID,
                                 java.lang.String operationName,
                                 java.util.List<Transferable> objs,
                                 Workers workers)

The broadcast communication operation using chain method. If the self is not the bcastWorkerID, quit.

Parameters:

contextName - the name of the context

bcastWorkerID - the worker doing broadcast

operationName - the name of the operation

objs - the list of Transferable objects

workers - the Workers

Returns:

true if succeeded, false otherwise

chainBcastAndRecv

public static boolean chainBcastAndRecv(java.lang.String contextName,
                                        int bcastWorkerID,
                                        java.lang.String operationName,
                                        java.util.List<Transferable> objs,
                                        Workers workers,
                                        DataMap dataMap)

The broadcast communication operation using chain method. If the self is not the bcastWorkerID, wait for the data.

Parameters:

contextName - the name of the context

bcastWorkerID - the worker doing broadcast

operationName - the name of the operation

objs - the list of Transferable objects

workers - the Workers

dataMap - the DataMap

Returns:

true if succeeded, false otherwise

mstBcast

public static boolean mstBcast(java.lang.String contextName,
                               int bcastWorkerID,
                               java.lang.String operationName,
                               java.util.List<Transferable> objs,
                               Workers workers)

The broadcast communication operation using MST method. If the self is not the bcastWorkerID, quit.

Parameters:

contextName - the name of the context

bcastWorkerID - the worker doing broadcast

operationName - the name of the operation

objs - the list of Transferable objects

workers - the Workers

Returns:

true if succeeded, false otherwise

mstBcastAndRecv

public static boolean mstBcastAndRecv(java.lang.String contextName,
                                      int bcastWorkerID,
                                      java.lang.String operationName,
                                      java.util.List<Transferable> objs,
                                      Workers workers,
                                      DataMap dataMap)

The broadcast communication operation using MST method. If the self is not the bcastWorkerID, wait for the data.

Parameters:

contextName - the name of the context

bcastWorkerID - the worker doing broadcast

operationName - the name of the operation

objs - the list of Transferable objects

workers - the Workers

dataMap - the DataMap

Returns:

true if succeeded, false otherwise