summaryrefslogtreecommitdiffstats
path: root/src/H5Flow.c
diff options
context:
space:
mode:
authorAlbert Cheng <acheng@hdfgroup.org>1998-06-07 04:38:16 (GMT)
committerAlbert Cheng <acheng@hdfgroup.org>1998-06-07 04:38:16 (GMT)
commitdadb964ba64517ce3ae2628e6155555fc5542e65 (patch)
tree7eab1ce899c9a358baf10d36aca93ceda9a1e318 /src/H5Flow.c
parent1e8ebeecfc67073a3019f9c2084a5977d2b8c62e (diff)
downloadhdf5-dadb964ba64517ce3ae2628e6155555fc5542e65.zip
hdf5-dadb964ba64517ce3ae2628e6155555fc5542e65.tar.gz
hdf5-dadb964ba64517ce3ae2628e6155555fc5542e65.tar.bz2
[svn-r411] Added data-transfer-mode to various function to specify which
mode to use for data transfer. Currently, INDEPENDENT transfer is the default mode. Collective is supported for files opened via the MPIO driver. Specific changes to individual files follow. H5D.c: Replaced previous kludge of passing xfer_mode via the file access_mode with xfer_mode function parameter all the way to the low level I/O drivers. H5Dprivate.h: The H5D_xfer_t.xfer_mode is now used in serial and parallel modes. Removed the "HAVE_PARALLEL" macro condition to support it. H5Dpublic.h: Added H5D_XFER_DFLT as a new value for H5D_transfer_t and removed the HAVE_PARALLEL condition macro to make the H5D_transfer_t definition available to both serial and parallel version. H5B.c: H5F.c: H5Farray.c: H5Fcore.c: H5Ffamily.c: H5Fistore.c: H5Flow.c: H5Fmpio.c: H5Fsec2.c: H5Fsplit.c: H5Fstdio.c: H5Gnode.c: H5HG.c: H5HL.c: H5O.c: H5Sprivate.h: H5Ssimp.c: debug.c: Added xfer_mode to the argument lists of the following routines to specify data transfer mode. Then updated calls to these routines with appropriate transfer mode. Whenever cases that collective mode is inappropriate (e.g. object header read-write, flush), H5D_XFER_DFLT is used. The H5D_XFER_DFLT mode is currently acting the same as the independent mode. H5F_block_read H5F_block_write H5F_arr_read H5F_arr_write H5F_core_read H5F_core_write H5F_fam_read H5F_fam_write H5F_mpio_read H5F_mpio_write H5F_low_write H5F_low_read H5F_sec2_read H5F_sec2_write H5F_split_read H5F_split_write H5F_stdio_read H5F_stdio_write H5S_simp_fgath H5S_simp_fscat H5S_simp_read H5S_simp_write H5Fprivate.h: H5P.c: Removed access_mode field from struct H5F_access_t type. The access-mode was the initial design to control independent or collective I/O mode. It is now supported by the data transfer mode.
Diffstat (limited to 'src/H5Flow.c')
-rw-r--r--src/H5Flow.c20
1 files changed, 14 insertions, 6 deletions
diff --git a/src/H5Flow.c b/src/H5Flow.c
index faa2202..82e1f1a 100644
--- a/src/H5Flow.c
+++ b/src/H5Flow.c
@@ -214,11 +214,14 @@ H5F_low_close(H5F_low_t *lf, const H5F_access_t *access_parms)
* Wednesday, October 22, 1997
*
* Modifications:
+ * June 2, 1998 Albert Cheng
+ * Added xfer_mode argument
*
*-------------------------------------------------------------------------
*/
herr_t
H5F_low_read(H5F_low_t *lf, const H5F_access_t *access_parms,
+ const H5D_transfer_t xfer_mode,
const haddr_t *addr, size_t size, uint8 *buf/*out*/)
{
herr_t ret_value = FAIL;
@@ -230,8 +233,8 @@ H5F_low_read(H5F_low_t *lf, const H5F_access_t *access_parms,
assert(buf);
if (lf->type->read) {
- if ((ret_value = (lf->type->read) (lf, access_parms, addr, size,
- buf)) < 0) {
+ if ((ret_value = (lf->type->read) (lf, access_parms, xfer_mode,
+ addr, size, buf)) < 0) {
HRETURN_ERROR(H5E_IO, H5E_READERROR, ret_value, "read failed");
}
} else {
@@ -263,11 +266,14 @@ H5F_low_read(H5F_low_t *lf, const H5F_access_t *access_parms,
* Wednesday, October 22, 1997
*
* Modifications:
+ * June 2, 1998 Albert Cheng
+ * Added xfer_mode argument
*
*-------------------------------------------------------------------------
*/
herr_t
H5F_low_write(H5F_low_t *lf, const H5F_access_t *access_parms,
+ const H5D_transfer_t xfer_mode,
const haddr_t *addr, size_t size, const uint8 *buf)
{
herr_t ret_value = FAIL;
@@ -289,8 +295,8 @@ H5F_low_write(H5F_low_t *lf, const H5F_access_t *access_parms,
/* Write the data */
if (lf->type->write) {
- if ((ret_value = (lf->type->write) (lf, access_parms, addr, size,
- buf)) < 0) {
+ if ((ret_value = (lf->type->write) (lf, access_parms, xfer_mode,
+ addr, size, buf)) < 0) {
HRETURN_ERROR(H5E_IO, H5E_WRITEERROR, ret_value, "write failed");
}
} else {
@@ -340,8 +346,10 @@ H5F_low_flush(H5F_low_t *lf, const H5F_access_t *access_parms)
if (addr_defined(&(lf->eof)) && H5F_addr_gt(&(lf->eof), &last_byte)) {
last_byte = lf->eof;
last_byte.offset -= 1;
- if (H5F_low_read(lf, access_parms, &last_byte, 1, buf) >= 0) {
- H5F_low_write(lf, access_parms, &last_byte, 1, buf);
+ if (H5F_low_read(lf, access_parms, H5D_XFER_DFLT, &last_byte,
+ 1, buf) >= 0) {
+ H5F_low_write(lf, access_parms, H5D_XFER_DFLT, &last_byte,
+ 1, buf);
}
}
/* Invoke the subclass the flush method */