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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
package mpi.dtyp;
// a test program from MPICH test suite.
/****************************************************************************
MPI-Java version :
Sung-Hoon Ko(shko@npac.syr.edu)
Northeast Parallel Architectures Center at Syracuse University
03/22/98
****************************************************************************/
import mpi.*;
import mpjbuf.BufferFactory;
public class pack {
public static void main(String args[]) throws Exception {
try {
pack c = new pack(args);
}
catch (Exception e) {
}
}
public pack() {
}
public pack(String[] args) throws Exception {
/*
* Check pack/unpack of mixed datatypes.
*/
final int BUF_SIZE = 100;
int myrank;
// byte buffer[] = new byte[BUF_SIZE];
mpjbuf.Buffer buffer = null;
int n[] = new int[1];
int size[] = new int[1];
int src, dest, errcnt, errs;
double a[] = new double[1];
double b[] = new double[1];
int pos;
int apos[] = new int[1];
Status status;
MPI.Init(args);
myrank = MPI.COMM_WORLD.Rank();
int tasks = MPI.COMM_WORLD.Size();
if (tasks > 2) {
if (myrank == 1) {
System.out.println("pack runs with 2 tasks! ");
}
MPI.Finalize();
return;
}
src = 0;
dest = 1;
errcnt = 0;
if (myrank == src) {
buffer = new mpjbuf.Buffer(
BufferFactory.create(10000 + MPI.SEND_OVERHEAD), MPI.SEND_OVERHEAD,
10000 + MPI.SEND_OVERHEAD);
// MPI.COMM_WORLD.Pack_size(BUF_SIZE, MPI.INT) );
pos = 0;
n[0] = 10;
a[0] = 1.1;
b[0] = 2.2;
pos = MPI.COMM_WORLD.Pack(n, 0, 1, MPI.INT, buffer, pos);
// System.out.println("s(1) -- pos "+pos);
pos = MPI.COMM_WORLD.Pack(a, 0, 1, MPI.DOUBLE, buffer, pos);
// System.out.println("s(2) -- pos "+pos);
pos = MPI.COMM_WORLD.Pack(b, 0, 1, MPI.DOUBLE, buffer, pos);
// System.out.println("s(3) -- pos "+pos);
apos[0] = pos;
MPI.COMM_WORLD.Send(apos, 0, 1, MPI.INT, dest, 999);
MPI.COMM_WORLD.Send(buffer, 0, pos, MPI.PACKED, dest, 99);
BufferFactory.destroy(buffer.getStaticBuffer());
} else {
buffer = new mpjbuf.Buffer(
BufferFactory.create(10000 + MPI.RECV_OVERHEAD), MPI.RECV_OVERHEAD,
10000 + MPI.RECV_OVERHEAD);
// MPI.COMM_WORLD.Pack_size(BUF_SIZE, MPI.INT) );
status = MPI.COMM_WORLD.Recv(size, 0, 1, MPI.INT, src, 999);
status = MPI.COMM_WORLD.Recv(buffer, 0, size[0], MPI.PACKED, src, 99);
pos = 0;
pos = MPI.COMM_WORLD.Unpack(buffer, pos, n, 0, 1, MPI.INT);
// System.out.println("r(1) -- pos "+pos);
pos = MPI.COMM_WORLD.Unpack(buffer, pos, a, 0, 1, MPI.DOUBLE);
// System.out.println("r(2) -- pos "+pos);
pos = MPI.COMM_WORLD.Unpack(buffer, pos, b, 0, 1, MPI.DOUBLE);
// System.out.println("r(3) -- pos "+pos);
/* Check results */
if (n[0] != 10) {
errcnt++;
System.out.println("Wrong value for n; got " + n[0] + " expected 10");
}
if (a[0] != 1.1) {
errcnt++;
System.out.println("Wrong value for a; got " + a[0] + " expected 1.1");
}
if (b[0] != 2.2) {
errcnt++;
System.out.println("Wrong value for b; got " + b[0] + " expected 2.2");
}
BufferFactory.destroy(buffer.getStaticBuffer());
}
if (myrank == 1)
System.out.println("Pack TEST COMPLETE");
MPI.Finalize();
}
}
|
