diff options
Diffstat (limited to 'examples/h5ff_client_prefetch.c')
| -rw-r--r-- | examples/h5ff_client_prefetch.c | 42 |
1 files changed, 20 insertions, 22 deletions
diff --git a/examples/h5ff_client_prefetch.c b/examples/h5ff_client_prefetch.c index aca2605..ad50559 100644 --- a/examples/h5ff_client_prefetch.c +++ b/examples/h5ff_client_prefetch.c @@ -269,20 +269,19 @@ int main(int argc, char **argv) { /* Read from prefetched Replicas */
/* set dxpl to read from replica in BB */
dxpl_id = H5Pcreate (H5P_DATASET_XFER);
- ret = H5Pset_read_replica(dxpl_id, dset_replica);
+ ret = H5Pset_dxpl_replica(dxpl_id, dset_replica);
assert(0 == ret);
-
ret = H5Dread_ff(did, dtid, H5S_ALL, H5S_ALL, dxpl_id, rdata1, rid2, H5_EVENT_STACK_NULL);
assert(ret == 0);
printf("Read Data1: ");
for(i=0;i<nelem;++i)
printf("%d ",rdata1[i]);
printf("\n");
+ H5Pclose(dxpl_id);
dxpl_id = H5Pcreate (H5P_DATASET_XFER);
- ret = H5Pset_read_replica(dxpl_id, map_replica);
+ ret = H5Pset_dxpl_replica(dxpl_id, map_replica);
assert(0 == ret);
-
key = 1;
value = -1;
ret = H5Mget_ff(map, H5T_STD_I32LE, &key, H5T_STD_I32LE, &value,
@@ -290,37 +289,36 @@ int main(int argc, char **argv) { assert(0 == ret);
printf("Value recieved = %d\n", value);
assert(1000 == value);
-
H5Pclose(dxpl_id);
/* evict Replicas */
- tapl_id = H5Pcreate (H5P_DATATYPE_ACCESS);
- ret = H5Pset_evict_replica(tapl_id, dt_replica);
- assert(0 == ret);
- ret = H5Tevict_ff(dtid, 3, tapl_id, H5_EVENT_STACK_NULL);
+ dxpl_id = H5Pcreate (H5P_DATASET_XFER);
+ ret = H5Pset_dxpl_replica(dxpl_id, dset_replica);
+ assert(0 == ret);
+ ret = H5Tevict_ff(dtid, 3, dxpl_id, H5_EVENT_STACK_NULL);
assert(0 == ret);
- H5Pclose(tapl_id);
+ H5Pclose(dxpl_id);
- dapl_id = H5Pcreate (H5P_DATASET_ACCESS);
- ret = H5Pset_evict_replica(dapl_id, dset_replica);
+ dxpl_id = H5Pcreate (H5P_DATASET_XFER);
+ ret = H5Pset_dxpl_replica(dxpl_id, dset_replica);
assert(0 == ret);
- ret = H5Devict_ff(did, 3, dapl_id, H5_EVENT_STACK_NULL);
+ ret = H5Devict_ff(did, 3, dxpl_id, H5_EVENT_STACK_NULL);
assert(0 == ret);
- H5Pclose(dapl_id);
+ H5Pclose(dxpl_id);
- mapl_id = H5Pcreate (H5P_MAP_ACCESS);
- ret = H5Pset_evict_replica(mapl_id, map_replica);
+ dxpl_id = H5Pcreate (H5P_DATASET_XFER);
+ ret = H5Pset_dxpl_replica(dxpl_id, map_replica);
assert(0 == ret);
- ret = H5Mevict_ff(map, 3, mapl_id, H5_EVENT_STACK_NULL);
+ ret = H5Mevict_ff(map, 3, dxpl_id, H5_EVENT_STACK_NULL);
assert(0 == ret);
- H5Pclose(mapl_id);
+ H5Pclose(dxpl_id);
- gapl_id = H5Pcreate (H5P_GROUP_ACCESS);
- ret = H5Pset_evict_replica(gapl_id, grp_replica);
+ dxpl_id = H5Pcreate (H5P_DATASET_XFER);
+ ret = H5Pset_dxpl_replica(dxpl_id, grp_replica);
assert(0 == ret);
- ret = H5Gevict_ff(gid, 3, gapl_id, H5_EVENT_STACK_NULL);
+ ret = H5Gevict_ff(gid, 3, dxpl_id, H5_EVENT_STACK_NULL);
assert(0 == ret);
- H5Pclose(gapl_id);
+ H5Pclose(dxpl_id);
}
MPI_Barrier(MPI_COMM_WORLD);
|