diff options
| author | Markos Fountoulakis <44345837+mfundul@users.noreply.github.com> | 2019-08-28 17:52:57 +0300 |
|---|---|---|
| committer | Chris Akritidis <43294513+cakrit@users.noreply.github.com> | 2019-08-28 16:52:57 +0200 |
| commit | 7fe3db883aa183ae9927942211d95e1fc04b2531 (patch) | |
| tree | cfe265de8d9a07459ace1ba7a80465adaca1b3ca /database/engine | |
| parent | a323fd7a97e541fd7401d3aa2234a9f6fa2fe3fd (diff) | |
Fix corrupted transaction payload handling during start-up of the database engine. (#6731)
Diffstat (limited to 'database/engine')
| -rw-r--r-- | database/engine/journalfile.c | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/database/engine/journalfile.c b/database/engine/journalfile.c index d6e4f3174d..fac680aa0e 100644 --- a/database/engine/journalfile.c +++ b/database/engine/journalfile.c @@ -269,7 +269,6 @@ static void restore_extent_metadata(struct rrdengine_instance *ctx, struct rrden extent = mallocz(sizeof(*extent) + count * sizeof(extent->pages[0])); extent->offset = jf_metric_data->extent_offset; extent->size = jf_metric_data->extent_size; - extent->number_of_pages = count; extent->datafile = journalfile->datafile; extent->next = NULL; @@ -282,7 +281,6 @@ static void restore_extent_metadata(struct rrdengine_instance *ctx, struct rrden error("Unknown page type encountered."); continue; } - ++valid_pages; temp_id = (uuid_t *)jf_metric_data->descr[i].uuid; uv_rwlock_rdlock(&pg_cache->metrics_index.lock); @@ -308,11 +306,16 @@ static void restore_extent_metadata(struct rrdengine_instance *ctx, struct rrden descr->end_time = jf_metric_data->descr[i].end_time; descr->id = &page_index->id; descr->extent = extent; - extent->pages[i] = descr; + extent->pages[valid_pages++] = descr; pg_cache_insert(ctx, page_index, descr); } + + extent->number_of_pages = valid_pages; + if (likely(valid_pages)) df_extent_insert(extent); + else + freez(extent); } /* |