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
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
/*
* Copyright (C) by Argonne National Laboratory
* See COPYRIGHT in top-level directory
*/
#ifndef MPITEST_H_INCLUDED
#define MPITEST_H_INCLUDED
#include "mpitestconf.h"
#include <mpi.h>
#include "mtest_mpix.h"
#include "mpithreadtest.h"
#include "mtest_common.h"
#ifdef HAVE_STRING_H
#include <string.h>
#endif
#ifdef HAVE_UNISTD_H
#include <unistd.h>
#endif
#if defined NEEDS_STRDUP_DECL && !defined strdup
extern char *strdup(const char *);
#endif
#if defined NEEDS_USLEEP_DECL && !defined usleep
extern int usleep(useconds_t);
#endif
/*
* Init and finalize test
*/
void MTest_Init(int *, char ***);
void MTest_Init_thread(int *, char ***, int, int *);
void MTest_Finalize(int);
void MTestPrintError(int);
void MTestPrintErrorMsg(const char[], int);
void MTestPrintfMsg(int, const char[], ...);
void MTestError(const char[]);
int MTestReturnValue(int);
int MTestGetStressLevel(void);
/*
* Utilities
*/
void MTestSleep(int);
void MTestGetDbgInfo(int *dbgflag, int *verbose);
int MTestGetIntracomm(MPI_Comm *, int);
int MTestGetIntracommGeneral(MPI_Comm *, int, int);
int MTestGetIntercomm(MPI_Comm *, int *, int);
int MTestGetComm(MPI_Comm *, int);
int MTestTestIntercomm(MPI_Comm intercomm);
int MTestTestIntracomm(MPI_Comm intracomm);
int MTestTestComm(MPI_Comm comm);
const char *MTestGetIntracommName(void);
const char *MTestGetIntercommName(void);
void MTestFreeComm(MPI_Comm *);
void MTestCommRandomize(void);
int MTestSpawnPossible(int *);
#ifdef HAVE_MPI_WIN_CREATE
int MTestGetWin(MPI_Win *, int);
const char *MTestGetWinName(void);
void MTestFreeWin(MPI_Win *);
#endif
int MTestIsBasicDtype(MPI_Datatype type);
/* These macros permit overrides via:
* make CPPFLAGS='-DMTEST_MPI_VERSION=X -DMTEST_MPI_SUBVERSION=Y'
* where X and Y are the major and minor versions of the MPI standard that is
* being tested. The override should work similarly if added to the CPPFLAGS at
* configure time. */
#ifndef MTEST_MPI_VERSION
#define MTEST_MPI_VERSION MPI_VERSION
#endif
#ifndef MTEST_MPI_SUBVERSION
#define MTEST_MPI_SUBVERSION MPI_SUBVERSION
#endif
/* Makes it easier to conditionally compile test code for a particular minimum
* version of the MPI Standard. Right now there is only a MIN flavor but it
* would be easy to add MAX or EXACT flavors if they become necessary at some
* point. Example usage:
------8<-------
#if MTEST_HAVE_MIN_MPI_VERSION(2,2)
... test for some feature that is only available in MPI-2.2 or later ...
#endif
------8<-------
*/
#define MTEST_HAVE_MIN_MPI_VERSION(major_,minor_) \
((MTEST_MPI_VERSION == (major_) && MTEST_MPI_SUBVERSION >= (minor_)) || \
(MTEST_MPI_VERSION > (major_)))
/* useful for avoid valgrind warnings about padding bytes */
#define MTEST_VG_MEM_INIT(addr_, size_) \
do { \
memset(addr_, 0, size_); \
} while (0)
/* convenient error checking routines */
static inline int MTestCheckStatus(MPI_Status * p_status, MPI_Datatype el_type,
int exp_count, int exp_source, int exp_tag, bool verbose)
{
int errs = 0;
if (MTestIsBasicDtype(el_type)) {
int count;
MPI_Get_count(p_status, el_type, &count);
if (count != exp_count) {
errs++;
if (verbose) {
printf("Status expect count %d, got %d\n", exp_count, count);
}
}
}
if (exp_source != MPI_ANY_SOURCE && p_status->MPI_SOURCE != exp_source) {
errs++;
if (verbose) {
printf("Status expect source %d, got %d\n", exp_source, p_status->MPI_SOURCE);
}
}
if (exp_tag != MPI_ANY_TAG && p_status->MPI_TAG != exp_tag) {
errs++;
if (verbose) {
printf("Status expect tag %d, got %d\n", exp_tag, p_status->MPI_TAG);
}
}
return errs;
}
#endif /* MPITEST_H_INCLUDED */
|
