diff options
| author | Costa Tsaousis <costa@netdata.cloud> | 2022-10-17 22:10:21 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-10-17 22:10:21 +0300 |
| commit | 66d914d00d5790c7e57d59a5331fabaabdd2b73a (patch) | |
| tree | 99d933f0d1e3bc08cdcb92188de0cc3b79379939 /database | |
| parent | d4e22b8d0e749334b91a23b0d947422c00a8caa5 (diff) | |
fix tiers update frequency (#13844)
* fix tiers update frequency
* dont change mqtt_websockets
Diffstat (limited to 'database')
| -rw-r--r-- | database/rrddim.c | 4 | ||||
| -rw-r--r-- | database/rrdset.c | 2 |
2 files changed, 3 insertions, 3 deletions
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); |