1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
package mpi.perf;
import mpi.*;
class bcast_bench {
static public void main(String[] args) throws MPIException {
final int MAXLEN = 1024;
int root,i,j=MAXLEN,k;
byte out[] = new byte[MAXLEN];
int REPEAT = 1000;
int WARM_UP = 10;
int myself,tasks;
//double time;
for(i=0;i<j;i++) {
out[i] = 's' ; //(byte)i+j;
}
MPI.Init(args);
myself = MPI.COMM_WORLD.Rank();
tasks = MPI.COMM_WORLD.Size();
root = 0;
long startTime, endTime;
for(j=0;j<WARM_UP;j++) {
MPI.COMM_WORLD.Bcast(out,0,1024,MPI.BYTE,root);
}
//startTime = MPI.Wtime();
for(j=0;j<REPEAT ;j++) {
MPI.COMM_WORLD.Bcast(out,0,1024,MPI.BYTE,root);
}
//endTime = MPI.Wtime();
if(myself == tasks-1) {
// System.out.println(tasks+" "+
// ((endTime - startTime)/(1000*REPEAT)) );
}
MPI.COMM_WORLD.Barrier();
MPI.Finalize();
}
}
|
