|
| CcjLink (ColGroupMaster groupMaster) throws CCJException |
|
String | getMyHostName () |
|
int | getNumVnodes () |
|
int | getRank () |
|
ColGroup | getGroup () |
|
void | barrier () |
|
Serializable | broadcast (Serializable value, int root) |
|
Serializable[] | gatherAll (Serializable[] myElements) |
|
int[] | gatherAll (int[] myElements) |
|
int[][] | gatherAll2dArray (int[] myElements) |
|
double[] | gatherAll (double[] myElements) |
|
double[] | sumAll (double[] partialSums) |
|
int[] | sumAll (int[] partialSums) |
|
int[] | maxAll (int[] partialMaxs) |
|
double[] | maxAll (double[] partialMaxs) |
|
Serializable | maxAll (Serializable partialMaxs) |
|
double[] | minAll (double[] partialMins) |
|
Serializable | minAll (Serializable partialMins) |
|
int[] | minAll (int[] partialMins) |
|
double[] | scanSums (double[] myElements) |
|
int[] | scanSums (int[] myElements) |
|
int[] | scatter2dArray (int[][] in) |
|
int[] | scatterIntArray (int[] in) |
|
int[][] | gather (int[] in) |
|
Serializable[][] | gather (Serializable[] in) |
|
void | setupReceives (int numReceives) |
|
Serializable | receive (int senderId) |
|
void | send (int[] exportObject, int destinationVnode) |
|
void | send (double[] exportObject, int destinationVnode) |
|
void | send (Serializable exportObject, int destinationVnode) |
|
void | run () |
|
CcjLink
provides the wrappers and data representation objects that CcjComm
uses to interact with CCJ.
- Author
- Jason Cross
Jpetra.CcjSupport.CcjLink.CcjLink |
( |
ColGroupMaster |
groupMaster | ) |
throws CCJException |
|
inline |
Contacts the root vnode and joins the vnode group
unless this
is the root vnode, then it listens for connections.
void Jpetra.CcjSupport.CcjLink.barrier |
( |
| ) |
|
|
inline |
Wrapper to CCJ barrier
. Causes each vnode in group</group> to wait until all vnodees are ready.
Serializable Jpetra.CcjSupport.CcjLink.broadcast |
( |
Serializable |
value, |
|
|
int |
root |
|
) |
| |
|
inline |
Wrapper to CCJ broadcast
. Broadcasts value
from the root
vnode to all other vnodees in group
.
Referenced by Jpetra.CcjComm.broadcast().
Serializable [] Jpetra.CcjSupport.CcjLink.gatherAll |
( |
Serializable[] |
myElements | ) |
|
|
inline |
Wrapper to CCJ allGather
. Broadcasts value
from the root
vnode to all other vnodees in group
.
int [] Jpetra.CcjSupport.CcjLink.gatherAll |
( |
int[] |
myElements | ) |
|
|
inline |
Wrapper to CCJ allGather
. Broadcasts value
from the root
vnode to all other vnodees in group
.
double [] Jpetra.CcjSupport.CcjLink.gatherAll |
( |
double[] |
myElements | ) |
|
|
inline |
Wrapper to CCJ allGather
.
int Jpetra.CcjSupport.CcjLink.getNumVnodes |
( |
| ) |
|
|
inline |
Accessor for numVnodes
provided by CCJ.
- Returns
numVnodes
int Jpetra.CcjSupport.CcjLink.getRank |
( |
| ) |
|
|
inline |
Accessor for rank
provided by CCJ.
- Returns
rank
int [] Jpetra.CcjSupport.CcjLink.maxAll |
( |
int[] |
partialMaxs | ) |
|
|
inline |
Wrapper to CCJ allReduce
.
double [] Jpetra.CcjSupport.CcjLink.maxAll |
( |
double[] |
partialMaxs | ) |
|
|
inline |
Wrapper to CCJ allReduce
.
Serializable Jpetra.CcjSupport.CcjLink.maxAll |
( |
Serializable |
partialMaxs | ) |
|
|
inline |
Wrapper to CCJ allReduce
.
double [] Jpetra.CcjSupport.CcjLink.minAll |
( |
double[] |
partialMins | ) |
|
|
inline |
Wrapper to CCJ allReduce
.
Serializable Jpetra.CcjSupport.CcjLink.minAll |
( |
Serializable |
partialMins | ) |
|
|
inline |
Wrapper to CCJ allReduce
.
int [] Jpetra.CcjSupport.CcjLink.minAll |
( |
int[] |
partialMins | ) |
|
|
inline |
Wrapper to CCJ allReduce
.
void Jpetra.CcjSupport.CcjLink.run |
( |
| ) |
|
|
inline |
not used but required to extend CCJ ColMember
double [] Jpetra.CcjSupport.CcjLink.scanSums |
( |
double[] |
myElements | ) |
|
|
inline |
int [] Jpetra.CcjSupport.CcjLink.scanSums |
( |
int[] |
myElements | ) |
|
|
inline |
void Jpetra.CcjSupport.CcjLink.send |
( |
int[] |
exportObject, |
|
|
int |
destinationVnode |
|
) |
| |
|
inline |
Sends an int arry to a single specified vnode. Wrapper to CCJ send_async
Note: this is NOT a blocking operation.
- Parameters
-
exportObject | the int array to be sent |
destinationVnode | the vnode ID of the receiving vnode |
void Jpetra.CcjSupport.CcjLink.send |
( |
double[] |
exportObject, |
|
|
int |
destinationVnode |
|
) |
| |
|
inline |
Sends a double arry to a single specified vnode. Wrapper to CCJ send_async
Note: this is NOT a blocking operation.
- Parameters
-
exportObject | the double array to be sent |
destinationVnode | the vnode ID of the receiving vnode |
void Jpetra.CcjSupport.CcjLink.send |
( |
Serializable |
exportObject, |
|
|
int |
destinationVnode |
|
) |
| |
|
inline |
Sends a Serializable arry to a single specified vnode. Wrapper to CCJ send_async
Note: this is NOT a blocking operation.
- Parameters
-
exportObject | the Serializable array to be sent |
destinationVnode | the vnode ID of the receiving vnode |
void Jpetra.CcjSupport.CcjLink.setupReceives |
( |
int |
numReceives | ) |
|
|
inline |
Wrapper to CCJ setupRecords
which tells CCJ how many messages to expect to receive.
- Parameters
-
numReceives | the number of messages that CCJ should expect to receive |
double [] Jpetra.CcjSupport.CcjLink.sumAll |
( |
double[] |
partialSums | ) |
|
|
inline |
Wrapper to CCJ allReduce
.
int [] Jpetra.CcjSupport.CcjLink.sumAll |
( |
int[] |
partialSums | ) |
|
|
inline |
Wrapper to CCJ allReduce
.
The documentation for this class was generated from the following file: