This source file includes following definitions.
- ADIOI_TESTFS_IreadContig
- ADIOI_TESTFS_IreadStrided
1
2
3
4
5
6
7
8 #include "ad_testfs.h"
9 #include "adioi.h"
10
11
12
13
14
15 void ADIOI_TESTFS_IreadContig(ADIO_File fd, void *buf, int count,
16 MPI_Datatype datatype, int file_ptr_type,
17 ADIO_Offset offset, ADIO_Request *request, int
18 *error_code)
19 {
20 ADIO_Status status;
21 int myrank, nprocs;
22 MPI_Count typesize, len;
23
24 *error_code = MPI_SUCCESS;
25
26 MPI_Comm_size(fd->comm, &nprocs);
27 MPI_Comm_rank(fd->comm, &myrank);
28 MPI_Type_size_x(datatype, &typesize);
29 FPRINTF(stdout, "[%d/%d] ADIOI_TESTFS_IreadContig called on %s\n",
30 myrank, nprocs, fd->filename);
31 FPRINTF(stdout, "[%d/%d] calling ADIOI_TESTFS_ReadContig\n",
32 myrank, nprocs);
33
34 len = count * typesize;
35 ADIOI_TESTFS_ReadContig(fd, buf, len, MPI_BYTE, file_ptr_type,
36 offset, &status, error_code);
37
38 MPIO_Completed_request_create(&fd, len, error_code, request);
39 }
40
41 void ADIOI_TESTFS_IreadStrided(ADIO_File fd, void *buf, int count,
42 MPI_Datatype datatype, int file_ptr_type,
43 ADIO_Offset offset, ADIO_Request *request, int
44 *error_code)
45 {
46 ADIO_Status status;
47 int myrank, nprocs;
48 MPI_Count typesize;
49
50 MPI_Comm_size(fd->comm, &nprocs);
51 MPI_Comm_rank(fd->comm, &myrank);
52 MPI_Type_size_x(datatype, &typesize);
53 FPRINTF(stdout, "[%d/%d] ADIOI_TESTFS_IreadStrided called on %s\n",
54 myrank, nprocs, fd->filename);
55 FPRINTF(stdout, "[%d/%d] calling ADIOI_TESTFS_ReadStrided\n",
56 myrank, nprocs);
57
58 ADIOI_TESTFS_ReadStrided(fd, buf, count, datatype, file_ptr_type,
59 offset, &status, error_code);
60 MPIO_Completed_request_create(&fd, count*typesize, error_code, request);
61 }
62