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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
package microbenchmarkmpiJava.barrier;
//
// mpiJava version : Taboada
// July 2002
// DES
//
import java.io.*;
import java.text.NumberFormat;
import mpi.*;
public class Barrier {
public static void main(String[] args) throws MPIException {
}
public Barrier() {
}
public Barrier(String[] args) throws Exception {
double startwtime, endwtime, pot2npesd;
int i, iterations, ns, my_pe, npes, pot2npes;
Status status;
long time;
MPI.Init(args);
my_pe = MPI.COMM_WORLD.Rank();
npes = MPI.COMM_WORLD.Size();
MPI.COMM_WORLD.Barrier();
iterations = Integer.parseInt(System.getProperty("ITERATIONS"));
pot2npes = (int)(Math.log(npes)/0.69314718);
pot2npesd = (double)(Math.log(npes)/0.69314718);
//Format the Number to Display
NumberFormat nf = NumberFormat.getInstance();
nf.setMaximumFractionDigits(6);
nf.setMinimumFractionDigits(6);
for (ns = 0; ns < iterations; ns++) {
MPI.COMM_WORLD.Barrier();
startwtime = MPI.Wtime();
MPI.COMM_WORLD.Barrier();
endwtime = MPI.Wtime();
if ( my_pe == 0) {
time = (long) (1000000*(endwtime - startwtime));
System.out.println(nf.format(((double) time/1000000))+" \t "+time+" \t "+npes+" \t "+pot2npes+" \t "+nf.format(pot2npesd));
}
}
MPI.Finalize();
if(my_pe == 0)
System.out.println("Barrier TEST COMPLETE");
}
}
|
