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
|
package misc;
import mpjdev.*;
import mpjbuf.*;
import java.io.*;
import java.util.Vector;
public class SameProcess {
public static void main(String[] args) throws Exception {
MPJDev.init(args);
Buffer wb = new Buffer(16);
Buffer rb = new Buffer(16);
int id = MPJDev.WORLD.id();
int size = MPJDev.WORLD.size();
int tag = 99;
int[] send = new int[2]; send[0]=1; send[1]=2;
int[] recv = new int[2]; recv[0]=0; recv[1]=0;
Vector v = new Vector();
v.add("a"); v.add("b"); v.add("c"); v.add("d");
Object [] sendObj = new Object[2]; sendObj[0]=v; sendObj[1]=v;
Object [] recvObj = new Object[2]; recvObj[0]=null; recvObj[1]=null;
if(id == 0) {
wb.putSectionHeader(Buffer.INT);
wb.write(send, 0, send.length);
wb.commit();
Request req = MPJDev.WORLD.isend(wb, 0, tag);
wb.clear();
MPJDev.WORLD.recv(rb, 0, tag);
rb.commit();
rb.getSectionHeader(Buffer.INT);
rb.read(recv, 0, recv.length);
req.iwait();
if(java.util.Arrays.equals(send, recv)) {
System.out.println("Basic Datatype PASSED");
}else {
System.out.println("BasicDatatype FAILED");
}
rb.clear();
wb.putSectionHeader(Buffer.OBJECT);
wb.write(sendObj, 0, sendObj.length);
wb.commit();
Request req1 = MPJDev.WORLD.isend(wb, 0, tag);
wb.clear();
MPJDev.WORLD.recv(rb, 0, tag);
rb.commit();
rb.getSectionHeader(Buffer.OBJECT);
rb.read(recvObj, 0, recvObj.length);
req1.iwait();
if(java.util.Arrays.equals(sendObj, recvObj)) {
System.out.println("Objects PASSED");
}else {
System.out.println("Objects FAILED");
}
rb.clear();
wb.clear();
Request req2 = MPJDev.WORLD.irecv(rb, 0, tag);
wb.putSectionHeader(Buffer.OBJECT);
wb.write(sendObj, 0, sendObj.length);
wb.commit();
MPJDev.WORLD.send(wb, 0, tag);
wb.clear();
req2.iwait();
rb.commit();
rb.getSectionHeader(Buffer.OBJECT);
rb.read(recvObj, 0, recvObj.length);
if(java.util.Arrays.equals(sendObj, recvObj)) {
System.out.println("(with recv posted first) Objects PASSED");
}else {
System.out.println("Objects FAILED");
}
} else if (id == 1) {
try {
Thread.currentThread().sleep(10000);
}
catch (Exception e) {}
}
MPJDev.finish();
}
}
|
