diff options
| author | kyang2014 <kyang2014@users.noreply.github.com> | 2021-10-01 20:43:41 (GMT) |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-10-01 20:43:41 (GMT) |
| commit | 5592111747b1e6ea1e934a3c13d3395312215c31 (patch) | |
| tree | b3975d174f840759cf4f4dab5162f4b9e41fa8a2 /src | |
| parent | 1c3e79c1234831f3d01920921406bdb2fea0b56f (diff) | |
| parent | 34478970510246c45ffa76d2b868aff90727eda1 (diff) | |
| download | hdf5-5592111747b1e6ea1e934a3c13d3395312215c31.zip hdf5-5592111747b1e6ea1e934a3c13d3395312215c31.tar.gz hdf5-5592111747b1e6ea1e934a3c13d3395312215c31.tar.bz2 | |
Merge pull request #1006 from kyang2014/feature/vfd_swmr
Feature/vfd swmr
Diffstat (limited to 'src')
| -rw-r--r-- | src/H5Fvfd_swmr.c | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/src/H5Fvfd_swmr.c b/src/H5Fvfd_swmr.c index d7cb830..69e03a0 100644 --- a/src/H5Fvfd_swmr.c +++ b/src/H5Fvfd_swmr.c @@ -1014,7 +1014,19 @@ H5F_vfd_swmr_reader_end_of_tick(H5F_t *f, hbool_t entering_api) /* This is ok if we're entering the API, but it should * not happen if we're exiting the API. */ + /* JRM review this */ + /* The following line is added for more meaningful error message when + * the long running API on the reader side exceeds the max_lag of ticks. + * KY 2021-09-02 + * */ + if (!entering_api && tmp_tick_num >= shared->tick_num + shared->vfd_swmr_config.max_lag) { + HGOTO_ERROR(H5E_FILE, H5E_SYSTEM, FAIL, + "Reader's API time exceeds max_lag of ticks, may increase the value of max_lag."); + } +#if 0 /* Kent */ + /* The original code */ HDassert(entering_api || tmp_tick_num < shared->tick_num + shared->vfd_swmr_config.max_lag); +#endif if (!entering_api) { H5FD_vfd_swmr_record_elapsed_ticks(shared->lf, tmp_tick_num - shared->tick_num); @@ -1102,7 +1114,14 @@ H5F_vfd_swmr_reader_end_of_tick(H5F_t *f, hbool_t entering_api) * case where the new entry is *longer*, because the * extension could overlap with a second entry. */ + + /* JRM review this */ + /* Kent: need to comment out the line to make reader iterate + * a large number of groups + * */ +#if 0 /*Kent*/ HDassert(oent->length == nent->length); +#endif /* the page has been altered -- evict it and * any contained metadata cache entries. |