update the pvfs2 fbtl to return the number of bytes generated.

This commit was SVN r32699.

ompi/mca/fbtl/pvfs2/fbtl_pvfs2_preadv.c

@@ -34,7 +34,7 @@ size_t  mca_fbtl_pvfs2_preadv (mca_io_ompio_file_t *fh)
 {
     int i;
     int ret;
-    size_t k;
+    size_t k,rret=0;
     int merge = 0;
     char *merge_buf = NULL;
     size_t merge_length = 0;
@@ -43,6 +43,7 @@ size_t  mca_fbtl_pvfs2_preadv (mca_io_ompio_file_t *fh)
     PVFS_Request file_req;
     PVFS_Request mem_req;
     mca_fs_pvfs2 *pvfs2_fs;
+    int total_bytes_read=0;
 
     pvfs2_fs = (mca_fs_pvfs2 *)fh->f_fs_ptr;
 
@@ -93,7 +94,8 @@ size_t  mca_fbtl_pvfs2_preadv (mca_io_ompio_file_t *fh)
 		perror("PVFS_sys_write() error");
 		return OMPI_ERROR;
 	    }
-	    
+	    total_bytes_read += (int)resp_io.total_completed;
+
 	    k = 0;
 	    while (merge >= 0) {
 		memcpy (fh->f_io_array[i-merge].memory_address,
@@ -137,8 +139,10 @@ size_t  mca_fbtl_pvfs2_preadv (mca_io_ompio_file_t *fh)
 		perror("PVFS_sys_write() error");
 		return OMPI_ERROR;
 	    }
+	    total_bytes_read += (int)resp_io.total_completed;
 	}
     }
 
-    return OMPI_SUCCESS;
+    rret = (size_t) total_bytes_read;
+    return rret;
 }

ompi/mca/fbtl/pvfs2/fbtl_pvfs2_pwritev.c

@@ -36,7 +36,7 @@ size_t  mca_fbtl_pvfs2_pwritev (mca_io_ompio_file_t *fh )
     int i;
     int merge = 0;
     int ret;
-    size_t k;
+    size_t k,rret;
     char *merge_buf = NULL;
     size_t merge_length = 0;
     OMPI_MPI_OFFSET_TYPE merge_offset = 0;
@@ -44,6 +44,7 @@ size_t  mca_fbtl_pvfs2_pwritev (mca_io_ompio_file_t *fh )
     PVFS_Request file_req;
     PVFS_Request mem_req;
     mca_fs_pvfs2 *pvfs2_fs;
+    int total_bytes_written=0;
 
     pvfs2_fs = (mca_fs_pvfs2 *)fh->f_fs_ptr;
 
@@ -110,6 +111,7 @@ size_t  mca_fbtl_pvfs2_pwritev (mca_io_ompio_file_t *fh )
 		perror("PVFS_sys_write() error");
 		return OMPI_ERROR;
 	    }
+	    total_bytes_written += (int)resp_io.total_completed;
 	    
 	    merge = 0;
 	    merge_offset = 0;
@@ -146,8 +148,11 @@ size_t  mca_fbtl_pvfs2_pwritev (mca_io_ompio_file_t *fh )
 		perror("PVFS_sys_write() error");
 		return OMPI_ERROR;
 	    }
+	    total_bytes_written += (int)resp_io.total_completed;
+
 	}
     }
-
-    return OMPI_SUCCESS;
+    
+    rret = (size_t) total_bytes_written;
+    return rret;
 }