[svn-r5550] Purpose:

    Code Improvement

Description:
    Split the metadata accumulator code into two parts: one for allowing writes
    of the accumulator buffer during reads (when the buffer is dirty and needs
    to be flushed to disk in order to hold the new metadata being read in) and
    another for only allowing writes of the buffer during writes.

    This allows the MPI-I/O VFL driver to use the metadata accumulator (but
    only during writes) and benefit from the reduced number of metadata I/O
    operations that it brings.

Platforms tested:
    IRIX64 6.5 (modi4) w/parallel

1 files changed, 47 insertions, 36 deletions

diff --git a/src/H5FD.c b/src/H5FD.c
index 129b133..55661aa 100644
--- a/src/H5FD.c
+++ b/src/H5FD.c
@@ -2300,51 +2300,62 @@ H5FD_read(H5FD_t *file, H5FD_mem_t type, hid_t dxpl_id, haddr_t addr, size_t siz
         } /* end if */
         /* Current read doesn't overlap with metadata accumulator, read it into accumulator */
         else {
-            /* Flush current contents, if dirty */
-            if(file->accum_dirty) {
-                if ((file->cls->write)(file, H5FD_MEM_DEFAULT, dxpl_id, file->accum_loc, file->accum_size, file->meta_accum)<0)
-                    HRETURN_ERROR(H5E_VFL, H5E_WRITEERROR, FAIL, "driver write request failed");
-
-                /* Reset accumulator dirty flag */
-                file->accum_dirty=FALSE;
-            } /* end if */
-
-            /* Cache the new piece of metadata */
-            /* Check if we need to resize the buffer */
-            if(size>file->accum_buf_size) {
-                /* Grow the metadata accumulator buffer */
-                if ((file->meta_accum=H5FL_BLK_REALLOC(meta_accum,file->meta_accum,size))==NULL)
-                    HRETURN_ERROR(H5E_RESOURCE, H5E_NOSPACE, FAIL, "unable to allocate metadata accumulator buffer");
+            /* Only update the metadata accumulator if it is not dirty or if
+             * we are allowed to write the accumulator out during reads (when
+             * it is dirty)
+             */
+            if(file->feature_flags&H5FD_FEAT_ACCUMULATE_METADATA_READ || !file->accum_dirty) {
+                /* Flush current contents, if dirty */
+                if(file->accum_dirty) {
+                    if ((file->cls->write)(file, H5FD_MEM_DEFAULT, dxpl_id, file->accum_loc, file->accum_size, file->meta_accum)<0)
+                        HRETURN_ERROR(H5E_VFL, H5E_WRITEERROR, FAIL, "driver write request failed");
 
-                /* Note the new buffer size */
-                file->accum_buf_size=size;
-            } /* end if */
-            else {
-                /* Check if we should shrink the accumulator buffer */
-                if(size<(file->accum_buf_size/H5FD_ACCUM_THROTTLE) &&
-                        file->accum_buf_size>H5FD_ACCUM_THRESHOLD) {
-                    size_t new_size=(file->accum_buf_size/H5FD_ACCUM_THROTTLE); /* New size of accumulator buffer */
+                    /* Reset accumulator dirty flag */
+                    file->accum_dirty=FALSE;
+                } /* end if */
 
-                    /* Shrink the accumulator buffer */
-                    if ((file->meta_accum=H5FL_BLK_REALLOC(meta_accum,file->meta_accum,new_size))==NULL)
+                /* Cache the new piece of metadata */
+                /* Check if we need to resize the buffer */
+                if(size>file->accum_buf_size) {
+                    /* Grow the metadata accumulator buffer */
+                    if ((file->meta_accum=H5FL_BLK_REALLOC(meta_accum,file->meta_accum,size))==NULL)
                         HRETURN_ERROR(H5E_RESOURCE, H5E_NOSPACE, FAIL, "unable to allocate metadata accumulator buffer");
 
                     /* Note the new buffer size */
-                    file->accum_buf_size=new_size;
+                    file->accum_buf_size=size;
                 } /* end if */
-            } /* end else */
+                else {
+                    /* Check if we should shrink the accumulator buffer */
+                    if(size<(file->accum_buf_size/H5FD_ACCUM_THROTTLE) &&
+                            file->accum_buf_size>H5FD_ACCUM_THRESHOLD) {
+                        size_t new_size=(file->accum_buf_size/H5FD_ACCUM_THROTTLE); /* New size of accumulator buffer */
 
-            /* Update accumulator information */
-            file->accum_loc=addr;
-            file->accum_size=size;
-            file->accum_dirty=FALSE;
+                        /* Shrink the accumulator buffer */
+                        if ((file->meta_accum=H5FL_BLK_REALLOC(meta_accum,file->meta_accum,new_size))==NULL)
+                            HRETURN_ERROR(H5E_RESOURCE, H5E_NOSPACE, FAIL, "unable to allocate metadata accumulator buffer");
+
+                        /* Note the new buffer size */
+                        file->accum_buf_size=new_size;
+                    } /* end if */
+                } /* end else */
+
+                /* Update accumulator information */
+                file->accum_loc=addr;
+                file->accum_size=size;
+                file->accum_dirty=FALSE;
 
-            /* Read into accumulator */
-            if ((file->cls->read)(file, H5FD_MEM_DEFAULT, dxpl_id, file->accum_loc, file->accum_size, file->meta_accum)<0)
-                HRETURN_ERROR(H5E_VFL, H5E_READERROR, FAIL, "driver read request failed");
+                /* Read into accumulator */
+                if ((file->cls->read)(file, H5FD_MEM_DEFAULT, dxpl_id, file->accum_loc, file->accum_size, file->meta_accum)<0)
+                    HRETURN_ERROR(H5E_VFL, H5E_READERROR, FAIL, "driver read request failed");
 
-            /* Copy into buffer */
-            HDmemcpy(buf,file->meta_accum,size);
+                /* Copy into buffer */
+                HDmemcpy(buf,file->meta_accum,size);
+            } /* end if */
+            else {
+                /* Dispatch to driver */
+                if ((file->cls->read)(file, type, dxpl_id, addr, size, buf)<0)
+                    HRETURN_ERROR(H5E_VFL, H5E_READERROR, FAIL, "driver read request failed");
+            } /* end else */
         } /* end else */
     } /* end if */
     else {