summaryrefslogtreecommitdiffstats
path: root/testpar/t_mdset.c
blob: 3fd3bdb48212e3a6140fe55701e22ed425baab38 (plain)
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
#include <testphdf5.h>

#define DIM  2
#define SIZE 32
#define NUMITEMS 500 /* 988 */

void multiple_dset_write(char *filename)
{
  int i, j, nprocs, rank;
  hid_t iof, plist, dataset, memspace, filespace;
  hssize_t chunk_origin [DIM];
  hsize_t chunk_dims [DIM], file_dims [DIM];
  double outme [SIZE][SIZE];

  MPI_Comm_rank (MPI_COMM_WORLD, &rank);
  MPI_Comm_size (MPI_COMM_WORLD, &nprocs);

  VRFY((nprocs <= SIZE), "nprocs <= SIZE");

  chunk_origin [0] = 0;
  chunk_origin [1] = rank * (SIZE / nprocs);
  chunk_dims [0] = SIZE;
  chunk_dims [1] = SIZE / nprocs;

  for (i = 0; i < DIM; i++)
    file_dims [i] = SIZE;

  for (i = 0; i < SIZE; i++)
    for (j = 0; j < SIZE; j++)
      outme [i][j] = rank;

  plist = H5Pcreate (H5P_FILE_ACCESS);
  H5Pset_fapl_mpio(plist, MPI_COMM_WORLD, MPI_INFO_NULL);
  iof = H5Fcreate (filename, H5F_ACC_TRUNC, H5P_DEFAULT, plist);
  H5Pclose (plist);

  memspace = H5Screate_simple (DIM, chunk_dims, NULL);
  filespace = H5Screate_simple (DIM, file_dims, NULL);
  H5Sselect_hyperslab (filespace, H5S_SELECT_SET, chunk_origin, NULL, chunk_dims
, NULL);

  for (i = 0; i < NUMITEMS; i++) {
    char dname [100];

    sprintf (dname, "dataset %d", i);
    dataset = H5Dcreate (iof, dname, H5T_NATIVE_FLOAT, filespace, H5P_DEFAULT);
    VRFY((dataset > 0), "dataset create succeeded"); 

    H5Dwrite (dataset, H5T_NATIVE_DOUBLE, memspace, filespace, H5P_DEFAULT, outme);

    H5Dclose (dataset);
    if (! ((i+1) % 10)) {
	printf("created %d datasets\n", i+1);
	MPI_Barrier(MPI_COMM_WORLD);
    }
}

  H5Sclose (filespace);
  H5Sclose (memspace);
  H5Fclose (iof);
}