diff options
Diffstat (limited to 'src/database/engine/pdc.c')
| -rw-r--r-- | src/database/engine/pdc.c | 17 |
1 files changed, 14 insertions, 3 deletions
diff --git a/src/database/engine/pdc.c b/src/database/engine/pdc.c index 1b57a49ba6..4808baefa4 100644 --- a/src/database/engine/pdc.c +++ b/src/database/engine/pdc.c @@ -635,7 +635,7 @@ inline VALIDATED_PAGE_DESCRIPTOR validate_extent_page_descr(const struct rrdeng_ size_t entries = 0; switch (descr->type) { - case PAGE_METRICS: + case PAGE_RAW_METRICS: case PAGE_TIER: end_time_s = descr->end_time_ut / USEC_PER_SEC; entries = 0; @@ -644,6 +644,10 @@ inline VALIDATED_PAGE_DESCRIPTOR validate_extent_page_descr(const struct rrdeng_ end_time_s = start_time_s + descr->gorilla.delta_time_s; entries = descr->gorilla.entries; break; + case PAGE_CONSTANT_METRICS: + end_time_s = start_time_s + descr->constant.delta_time_s; + entries = descr->constant.entries; + break; default: // Nothing to do. Validate page will notify the user. break; @@ -689,7 +693,7 @@ VALIDATED_PAGE_DESCRIPTOR validate_page( bool known_page_type = true; switch (page_type) { - case PAGE_METRICS: + case PAGE_RAW_METRICS: case PAGE_TIER: // always calculate entries by size vd.entries = page_entries_by_size(vd.page_length, vd.point_size); @@ -702,6 +706,10 @@ VALIDATED_PAGE_DESCRIPTOR validate_page( internal_fatal(entries == 0, "0 number of entries found on gorilla page"); vd.entries = entries; break; + case PAGE_CONSTANT_METRICS: + internal_fatal(entries == 0, "0 number of entries found on constant page"); + vd.entries = entries; + break; default: known_page_type = false; break; @@ -873,13 +881,16 @@ static void epdl_extent_loading_error_log(struct rrdengine_instance *ctx, EPDL * if (descr) { start_time_s = (time_t)(descr->start_time_ut / USEC_PER_SEC); switch (descr->type) { - case PAGE_METRICS: + case PAGE_RAW_METRICS: case PAGE_TIER: end_time_s = (time_t)(descr->end_time_ut / USEC_PER_SEC); break; case PAGE_GORILLA_METRICS: end_time_s = (time_t) start_time_s + (descr->gorilla.delta_time_s); break; + case PAGE_CONSTANT_METRICS: + end_time_s = (time_t) start_time_s + (descr->constant.delta_time_s); + break; } uuid_unparse_lower(descr->uuid, uuid); used_descr = true; |