From 66d914d00d5790c7e57d59a5331fabaabdd2b73a Mon Sep 17 00:00:00 2001 From: Costa Tsaousis Date: Mon, 17 Oct 2022 22:10:21 +0300 Subject: fix tiers update frequency (#13844) * fix tiers update frequency * dont change mqtt_websockets --- database/rrddim.c | 4 ++-- database/rrdset.c | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) (limited to 'database') diff --git a/database/rrddim.c b/database/rrddim.c index 187f133f22..aef6e31990 100644 --- a/database/rrddim.c +++ b/database/rrddim.c @@ -122,7 +122,7 @@ static void rrddim_insert_callback(const DICTIONARY_ITEM *item __maybe_unused, v size_t initialized = 0; for (int tier = 0; tier < storage_tiers; tier++) { if (rd->tiers[tier]) { - rd->tiers[tier]->db_collection_handle = rd->tiers[tier]->collect_ops.init(rd->tiers[tier]->db_metric_handle, st->update_every * storage_tiers_grouping_iterations[tier]); + rd->tiers[tier]->db_collection_handle = rd->tiers[tier]->collect_ops.init(rd->tiers[tier]->db_metric_handle, get_tier_grouping(tier) * st->update_every); initialized++; } } @@ -255,7 +255,7 @@ static bool rrddim_conflict_callback(const DICTIONARY_ITEM *item __maybe_unused, for(int tier = 0; tier < storage_tiers ;tier++) { if (rd->tiers[tier]) rd->tiers[tier]->db_collection_handle = - rd->tiers[tier]->collect_ops.init(rd->tiers[tier]->db_metric_handle, st->update_every * storage_tiers_grouping_iterations[tier]); + rd->tiers[tier]->collect_ops.init(rd->tiers[tier]->db_metric_handle, get_tier_grouping(tier) * st->update_every); } rrddim_flag_clear(rd, RRDDIM_FLAG_ARCHIVED); diff --git a/database/rrdset.c b/database/rrdset.c index 0ab6c0fde8..f2386bcdb0 100644 --- a/database/rrdset.c +++ b/database/rrdset.c @@ -315,7 +315,7 @@ static bool rrdset_conflict_callback(const DICTIONARY_ITEM *item __maybe_unused, rrddim_foreach_read(rd, st) { for (int tier = 0; tier < storage_tiers; tier++) { if (rd->tiers[tier] && rd->tiers[tier]->db_collection_handle) - rd->tiers[tier]->collect_ops.change_collection_frequency(rd->tiers[tier]->db_collection_handle, st->update_every); + rd->tiers[tier]->collect_ops.change_collection_frequency(rd->tiers[tier]->db_collection_handle, get_tier_grouping(tier) * st->update_every); } } rrddim_foreach_done(rd); -- cgit v1.2.3