summaryrefslogtreecommitdiffstats
path: root/src/H5F.c
diff options
context:
space:
mode:
authorRobert Kim Yates <rkyates@llnl.gov>1998-08-28 23:37:58 (GMT)
committerRobert Kim Yates <rkyates@llnl.gov>1998-08-28 23:37:58 (GMT)
commit1373661a78b7a6d3c7526cd8f80b9ba3460a1d74 (patch)
tree83bd2e2ef70d44c57fa8fd53453aea99067ab10a /src/H5F.c
parent96c2b5fec405a2dd4a63b7482a431dfc984523df (diff)
downloadhdf5-1373661a78b7a6d3c7526cd8f80b9ba3460a1d74.zip
hdf5-1373661a78b7a6d3c7526cd8f80b9ba3460a1d74.tar.gz
hdf5-1373661a78b7a6d3c7526cd8f80b9ba3460a1d74.tar.bz2
[svn-r630] Added code to eliminate redundant writes of metadata,
so only proc 0 writes it to disk. The elimination is activated only when the environment variable HDF5_MPI_1_METAWRITE is nonzero; otherwise all processes that opened the file will write the metadata to disk.
Diffstat (limited to 'src/H5F.c')
-rw-r--r--src/H5F.c15
1 files changed, 15 insertions, 0 deletions
diff --git a/src/H5F.c b/src/H5F.c
index b0fdf4e..8191747 100644
--- a/src/H5F.c
+++ b/src/H5F.c
@@ -47,6 +47,7 @@ static char RcsId[] = "@(#)$Revision$";
#include <H5MMprivate.h> /*core memory management */
#include <H5Pprivate.h> /*property lists */
#include <H5Tprivate.h> /*data types */
+#include <H5Fmpioprivate.h> /*MPI-IO parallel stuff */
#include <ctype.h>
#include <sys/types.h>
@@ -138,6 +139,16 @@ H5F_init_interface(void)
interface_initialize_g = TRUE;
FUNC_ENTER(H5F_init_interface, FAIL);
+#ifdef HAVE_PARALLEL
+ {
+ /* Allow MPI buf-and-file-type optimizations? */
+ const char *s = getenv ("HDF5_MPI_1_METAWRITE");
+ if (s && isdigit(*s)) {
+ H5_mpi_1_metawrite_g = (int)HDstrtol (s, NULL, 0);
+ }
+ }
+#endif
+
/* Initialize the atom group for the file IDs */
if (H5I_init_group(H5_FILE, H5I_FILEID_HASHSIZE, 0,
(herr_t (*)(void*))H5F_close)<0 ||
@@ -1416,6 +1427,7 @@ H5Fflush(hid_t object_id)
* Aug 29 1997
*
* Modifications:
+ * rky 980828 Only p0 writes metadata to disk.
*
*-------------------------------------------------------------------------
*/
@@ -1481,6 +1493,9 @@ H5F_flush(H5F_t *f, hbool_t invalidate)
}
/* write the boot block to disk */
+#ifdef HAVE_PARALLEL
+ H5F_mpio_tas_allsame( f->shared->lf, TRUE ); /* only p0 will write */
+#endif
if (H5F_low_write(f->shared->lf, f->shared->access_parms,
H5D_XFER_DFLT,
&(f->shared->boot_addr), (size_t)(p-buf), buf)<0) {