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
|
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
* Copyright by The HDF Group. *
* All rights reserved. *
* *
* This file is part of HDF5. The full HDF5 copyright notice, including *
* terms governing use, modification, and redistribution, is contained in *
* the COPYING file, which can be found at the root of the source code *
* distribution tree, or in https://www.hdfgroup.org/licenses. *
* If you do not have access to either file, you may request a copy from *
* help@hdfgroup.org. *
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
/* Test for H5Oflush. For the current design, H5Oflush doesn't work correctly
* with parallel. It causes an assertion failure in metadata cache during
* H5Fclose. This test makes sure H5Oflush fails for dataset, group, and named
* datatype properly until the problem is solved. */
#include "testphdf5.h"
#include "H5Dprivate.h"
#include "H5private.h"
#define DATASETNAME "IntArray"
#define NX 5
#define NY 6
#define RANK 2
void
test_oflush(void)
{
int mpi_size, mpi_rank;
hid_t file, dataset;
hid_t dataspace;
hid_t fapl_id;
const char *filename;
hid_t gid, dtype_flush;
hsize_t dimsf[2];
herr_t ret;
int data[NX][NY];
int i, j;
MPI_Comm_rank(MPI_COMM_WORLD, &mpi_rank);
MPI_Comm_size(MPI_COMM_WORLD, &mpi_size);
/* Make sure MPIO driver is used */
fapl_id = create_faccess_plist(MPI_COMM_WORLD, MPI_INFO_NULL, FACC_MPIO);
VRFY((fapl_id >= 0), "fapl creation succeeded");
/* Data buffer initialization */
for (j = 0; j < NX; j++)
for (i = 0; i < NY; i++)
data[j][i] = i + j;
filename = GetTestParameters();
file = H5Fcreate(filename, H5F_ACC_TRUNC, H5P_DEFAULT, fapl_id);
VRFY((file >= 0), "file creation succeeded");
/* Describe the size of the array and create the data space for fixed
* size dataset */
dimsf[0] = NX;
dimsf[1] = NY;
dataspace = H5Screate_simple(RANK, dimsf, NULL);
VRFY((dataspace >= 0), "data space creation succeeded");
/* Create a new dataset within the file using defined dataspace and
* datatype and default dataset creation properties */
dataset = H5Dcreate2(file, DATASETNAME, H5T_NATIVE_INT, dataspace, H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT);
VRFY((dataset >= 0), "dataset creation succeeded");
/* Write the data to the dataset using default transfer properties */
ret = H5Dwrite(dataset, H5T_NATIVE_INT, H5S_ALL, H5S_ALL, H5P_DEFAULT, data);
VRFY((ret >= 0), "dataset creation succeeded");
/* Make sure H5Oflush fails with dataset */
H5E_BEGIN_TRY
{
ret = H5Oflush(dataset);
}
H5E_END_TRY
VRFY((ret < 0), "H5Oflush should fail as expected");
H5Sclose(dataspace);
H5Dclose(dataset);
/* Create a group */
gid = H5Gcreate(file, "group", H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT);
VRFY((gid >= 0), "group creation succeeded");
/* Make sure H5Oflush fails with group */
H5E_BEGIN_TRY
{
ret = H5Oflush(gid);
}
H5E_END_TRY
VRFY((ret < 0), "H5Oflush should fail as expected");
H5Gclose(gid);
/* Create a named datatype */
dtype_flush = H5Tcopy(H5T_NATIVE_INT);
H5Tcommit(file, "dtype", dtype_flush, H5P_DEFAULT, H5P_DEFAULT, H5P_DEFAULT);
/* Make sure H5Oflush fails with named datatype */
H5E_BEGIN_TRY
{
ret = H5Oflush(dtype_flush);
}
H5E_END_TRY
VRFY((ret < 0), "H5Oflush should fail as expected");
H5Tclose(dtype_flush);
/* Close and release resources */
H5Fclose(file);
H5Pclose(fapl_id);
}
|
