fix tiers update frequency (#13844)
* fix tiers update frequency * dont change mqtt_websockets
Costa Tsaousis committed
Oct 17, 2022 at 22:10 UTC
66d914d00d5790c7e57d59a5331fabaabdd2b73a
2 files changed
+3
-3
database/rrddim.c
+2
-2
@@ -122,7 +122,7 @@ static void rrddim_insert_callback(const DICTIONARY_ITEM *item __maybe_unused, v
122
size_t initialized = 0;
123
for (int tier = 0; tier < storage_tiers; tier++) {
124
if (rd->tiers[tier]) {
125
- 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]);
125
+ 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);
126
initialized++;
127
}
128
}
@@ -255,7 +255,7 @@ static bool rrddim_conflict_callback(const DICTIONARY_ITEM *item __maybe_unused,
255
for(int tier = 0; tier < storage_tiers ;tier++) {
256
if (rd->tiers[tier])
257
rd->tiers[tier]->db_collection_handle =
258
- rd->tiers[tier]->collect_ops.init(rd->tiers[tier]->db_metric_handle, st->update_every * storage_tiers_grouping_iterations[tier]);
258
+ rd->tiers[tier]->collect_ops.init(rd->tiers[tier]->db_metric_handle, get_tier_grouping(tier) * st->update_every);
259
}
260
261
rrddim_flag_clear(rd, RRDDIM_FLAG_ARCHIVED);
database/rrdset.c
+1
-1
@@ -315,7 +315,7 @@ static bool rrdset_conflict_callback(const DICTIONARY_ITEM *item __maybe_unused,
315
rrddim_foreach_read(rd, st) {
316
for (int tier = 0; tier < storage_tiers; tier++) {
317
if (rd->tiers[tier] && rd->tiers[tier]->db_collection_handle)
318
- rd->tiers[tier]->collect_ops.change_collection_frequency(rd->tiers[tier]->db_collection_handle, st->update_every);
318
+ rd->tiers[tier]->collect_ops.change_collection_frequency(rd->tiers[tier]->db_collection_handle, get_tier_grouping(tier) * st->update_every);
319
}
320
}
321
rrddim_foreach_done(rd);