diff options
Diffstat (limited to 'exporting/process_data.c')
| -rw-r--r-- | exporting/process_data.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/exporting/process_data.c b/exporting/process_data.c index c7792fa558..1713790102 100644 --- a/exporting/process_data.c +++ b/exporting/process_data.c @@ -44,7 +44,7 @@ int mark_scheduled_instances(struct engine *engine) for (struct instance *instance = engine->instance_root; instance; instance = instance->next) { if (!instance->disabled && (engine->now % instance->config.update_every >= - instance->config.update_every - localhost->rrd_update_every)) { + instance->config.update_every - rrdb.localhost->update_every)) { instance->scheduled = 1; instances_were_scheduled = 1; instance->before = engine->now; @@ -77,8 +77,8 @@ NETDATA_DOUBLE exporting_calculate_value_from_stored_data( time_t before = instance->before; // find the edges of the rrd database for this chart - time_t first_t = storage_engine_oldest_time_s(rd->tiers[0].backend, rd->tiers[0].db_metric_handle); - time_t last_t = storage_engine_latest_time_s(rd->tiers[0].backend, rd->tiers[0].db_metric_handle); + time_t first_t = storage_engine_oldest_time_s(st->storage_engine_id, rd->tiers[0].db_metric_handle); + time_t last_t = storage_engine_latest_time_s(st->storage_engine_id, rd->tiers[0].db_metric_handle); time_t update_every = st->update_every; struct storage_engine_query_handle handle; @@ -126,7 +126,7 @@ NETDATA_DOUBLE exporting_calculate_value_from_stored_data( size_t counter = 0; NETDATA_DOUBLE sum = 0; - for (storage_engine_query_init(rd->tiers[0].backend, rd->tiers[0].db_metric_handle, &handle, after, before, STORAGE_PRIORITY_SYNCHRONOUS); !storage_engine_query_is_finished(&handle);) { + for (storage_engine_query_init(st->storage_engine_id, rd->tiers[0].db_metric_handle, &handle, after, before, STORAGE_PRIORITY_SYNCHRONOUS); !storage_engine_query_is_finished(&handle);) { STORAGE_POINT sp = storage_engine_query_next_metric(&handle); points_read++; |