diff options
author | Adrien BĂ©raud <adrien.beraud@savoirfairelinux.com> | 2022-05-11 09:17:40 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-05-11 16:17:40 +0300 |
commit | 9adf4dd782b8587ca3daffeb46c6c3ea98fb76d8 (patch) | |
tree | c5bd3c3088b740649013f7800d65a93a92ba6798 /database/ram | |
parent | bc8ed60700d10f280ca7a1df02e89e027ecd9609 (diff) |
Configurable storage engine for Netdata agents: step 2 (#12808)
Diffstat (limited to 'database/ram')
-rw-r--r-- | database/ram/rrddim_mem.c | 67 | ||||
-rw-r--r-- | database/ram/rrddim_mem.h | 29 |
2 files changed, 96 insertions, 0 deletions
diff --git a/database/ram/rrddim_mem.c b/database/ram/rrddim_mem.c new file mode 100644 index 0000000000..b17f03ca50 --- /dev/null +++ b/database/ram/rrddim_mem.c @@ -0,0 +1,67 @@ +// SPDX-License-Identifier: GPL-3.0-or-later + +#include "rrddim_mem.h" + +// ---------------------------------------------------------------------------- +// RRDDIM legacy data collection functions + +void rrddim_collect_init(RRDDIM *rd) { + rd->values[rd->rrdset->current_entry] = SN_EMPTY_SLOT; + rd->state->handle = calloc(1, sizeof(struct mem_collect_handle)); +} +void rrddim_collect_store_metric(RRDDIM *rd, usec_t point_in_time, storage_number number) { + (void)point_in_time; + rd->values[rd->rrdset->current_entry] = number; +} +int rrddim_collect_finalize(RRDDIM *rd) { + free((struct mem_collect_handle*)rd->state->handle); + return 0; +} + +// ---------------------------------------------------------------------------- +// RRDDIM legacy database query functions + +void rrddim_query_init(RRDDIM *rd, struct rrddim_query_handle *handle, time_t start_time, time_t end_time) { + handle->rd = rd; + handle->start_time = start_time; + handle->end_time = end_time; + struct mem_query_handle* h = calloc(1, sizeof(struct mem_query_handle)); + h->slot = rrdset_time2slot(rd->rrdset, start_time); + h->last_slot = rrdset_time2slot(rd->rrdset, end_time); + h->finished = 0; + handle->handle = (STORAGE_QUERY_HANDLE *)h; +} + +storage_number rrddim_query_next_metric(struct rrddim_query_handle *handle, time_t *current_time) { + RRDDIM *rd = handle->rd; + struct mem_query_handle* h = (struct mem_query_handle*)handle->handle; + long entries = rd->rrdset->entries; + long slot = h->slot; + + (void)current_time; + if (unlikely(h->slot == h->last_slot)) + h->finished = 1; + storage_number n = rd->values[slot++]; + + if(unlikely(slot >= entries)) slot = 0; + h->slot = slot; + + return n; +} + +int rrddim_query_is_finished(struct rrddim_query_handle *handle) { + struct mem_query_handle* h = (struct mem_query_handle*)handle->handle; + return h->finished; +} + +void rrddim_query_finalize(struct rrddim_query_handle *handle) { + freez(handle->handle); +} + +time_t rrddim_query_latest_time(RRDDIM *rd) { + return rrdset_last_entry_t_nolock(rd->rrdset); +} + +time_t rrddim_query_oldest_time(RRDDIM *rd) { + return rrdset_first_entry_t_nolock(rd->rrdset); +} diff --git a/database/ram/rrddim_mem.h b/database/ram/rrddim_mem.h new file mode 100644 index 0000000000..9a215387ae --- /dev/null +++ b/database/ram/rrddim_mem.h @@ -0,0 +1,29 @@ +// SPDX-License-Identifier: GPL-3.0-or-later + +#ifndef NETDATA_RRDDIMMEM_H +#define NETDATA_RRDDIMMEM_H + +#include "database/rrd.h" + +struct mem_collect_handle { + long slot; + long entries; +}; +struct mem_query_handle { + long slot; + long last_slot; + uint8_t finished; +}; + +extern void rrddim_collect_init(RRDDIM *rd); +extern void rrddim_collect_store_metric(RRDDIM *rd, usec_t point_in_time, storage_number number); +extern int rrddim_collect_finalize(RRDDIM *rd); + +extern void rrddim_query_init(RRDDIM *rd, struct rrddim_query_handle *handle, time_t start_time, time_t end_time); +extern storage_number rrddim_query_next_metric(struct rrddim_query_handle *handle, time_t *current_time); +extern int rrddim_query_is_finished(struct rrddim_query_handle *handle); +extern void rrddim_query_finalize(struct rrddim_query_handle *handle); +extern time_t rrddim_query_latest_time(RRDDIM *rd); +extern time_t rrddim_query_oldest_time(RRDDIM *rd); + +#endif |