This source file includes following definitions.
- ADIOI_PVFS2_Flush
1
2
3
4
5
6
7
8 #include "ad_pvfs2.h"
9 #include "ad_pvfs2_common.h"
10
11
12
13
14
15
16
17
18 void ADIOI_PVFS2_Flush(ADIO_File fd, int *error_code)
19 {
20 int ret, rank, dummy=0, dummy_in=0;
21 ADIOI_PVFS2_fs *pvfs_fs;
22 static char myname[] = "ADIOI_PVFS2_FLUSH";
23
24 *error_code = MPI_SUCCESS;
25
26 pvfs_fs = (ADIOI_PVFS2_fs*)fd->fs_ptr;
27
28 MPI_Comm_rank(fd->comm, &rank);
29
30
31
32
33 MPI_Reduce(&dummy_in, &dummy, 1, MPI_INT, MPI_SUM,
34 fd->hints->ranklist[0], fd->comm);
35
36
37 if (rank == fd->hints->ranklist[0]) {
38 ret = PVFS_sys_flush(pvfs_fs->object_ref, &(pvfs_fs->credentials));
39 }
40 MPI_Bcast(&ret, 1, MPI_INT, fd->hints->ranklist[0], fd->comm);
41
42
43 if (ret != 0) {
44 *error_code = MPIO_Err_create_code(MPI_SUCCESS,
45 MPIR_ERR_RECOVERABLE,
46 myname, __LINE__,
47 ADIOI_PVFS2_error_convert(ret),
48 "Error in PVFS_sys_flush", 0);
49 }
50
51 }
52
53
54
55