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
|
/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
/*
*
* (C) 2014 by Argonne National Laboratory.
* See COPYRIGHT in top-level directory.
*/
#include <stdio.h>
#include "mpi.h"
#include "mpitest.h"
#define ELEM_PER_PROC 1
static int errors = 0;
int main(int argc, char *argv[])
{
int rank, nprocs;
int shm_rank, shm_nprocs;
MPI_Comm shm_comm;
MPI_Win shm_win;
int *my_base;
int one = 1;
int result_data;
MTest_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
MPI_Comm_size(MPI_COMM_WORLD, &nprocs);
/* run with two processes. */
MPI_Comm_split_type(MPI_COMM_WORLD, MPI_COMM_TYPE_SHARED, rank, MPI_INFO_NULL, &shm_comm);
MPI_Comm_rank(shm_comm, &shm_rank);
MPI_Comm_size(shm_comm, &shm_nprocs);
if (shm_nprocs >= 2) {
MPI_Win_allocate_shared(sizeof(int) * ELEM_PER_PROC, sizeof(int), MPI_INFO_NULL,
shm_comm, &my_base, &shm_win);
/* Test for FENCE with no asserts. */
if (shm_rank == 1) {
*my_base = 0;
MPI_Win_fence(0, shm_win);
MPI_Win_fence(0, shm_win);
if (my_base[0] != one) {
errors++;
printf("Expected: my_base[0] = %d Actual: my_base[0] = %d\n", one, my_base[0]);
}
}
if (shm_rank == 0) {
MPI_Win_fence(0, shm_win);
MPI_Put(&one, 1, MPI_INT, 1, 0, 1, MPI_INT, shm_win);
MPI_Win_fence(0, shm_win);
}
/* Test for FENCE with assert MPI_MODE_NOPRECEDE. */
if (shm_rank == 1) {
MPI_Win_lock(MPI_LOCK_EXCLUSIVE, 1, 0, shm_win);
MPI_Put(&one, 1, MPI_INT, 1, 0, 1, MPI_INT, shm_win);
MPI_Win_unlock(1, shm_win);
MPI_Win_fence(MPI_MODE_NOPRECEDE, shm_win);
MPI_Win_fence(0, shm_win);
}
if (shm_rank == 0) {
result_data = 0;
MPI_Win_fence(MPI_MODE_NOPRECEDE, shm_win);
MPI_Get(&result_data, 1, MPI_INT, 1, 0, 1, MPI_INT, shm_win);
MPI_Win_fence(0, shm_win);
if (result_data != one) {
errors++;
printf("Expected: result_data = %d Actual: result_data = %d\n", one, result_data);
}
}
MPI_Win_free(&shm_win);
}
MPI_Comm_free(&shm_comm);
MTest_Finalize(errors);
MPI_Finalize();
return 0;
}
|
