diff options
| author | Costa Tsaousis <costa@netdata.cloud> | 2022-09-07 15:28:30 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-09-07 15:28:30 +0300 |
| commit | 3f6a75250d8251b0142248ed2f33f7d857ee21c8 (patch) | |
| tree | f8fd7544a2fb509b295e6bd5267baab6014bc787 /streaming | |
| parent | 17e0676b5bb6b11ad9aec705ade05163dcc2de31 (diff) | |
Obsolete RRDSET state (#13635)
* move chart_labels to rrdset
* rename chart_labels to rrdlabels
* renamed hash_id to uuid
* turned is_ar_chart into an rrdset flag
* removed rrdset state
* removed unused senders_connected member of rrdhost
* removed unused host flag RRDHOST_FLAG_MULTIHOST
* renamed rrdhost host_labels to rrdlabels
* Update exporting unit tests
Co-authored-by: Vladimir Kobal <vlad@prokk.net>
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/rrdpush.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/streaming/rrdpush.c b/streaming/rrdpush.c index 67fc48aa09..21a759dc09 100644 --- a/streaming/rrdpush.c +++ b/streaming/rrdpush.c @@ -131,7 +131,7 @@ unsigned int remote_clock_resync_iterations = 60; static inline int should_send_chart_matching(RRDSET *st) { // Do not stream anomaly rates charts. - if (unlikely(st->state->is_ar_chart)) + if (unlikely(rrdset_is_ar_chart(st))) return false; if (rrdset_flag_check(st, RRDSET_FLAG_ANOMALY_DETECTION)) @@ -197,8 +197,8 @@ static int send_clabels_callback(const char *name, const char *value, RRDLABEL_S return 1; } void rrdpush_send_clabels(RRDHOST *host, RRDSET *st) { - if (st->state && st->state->chart_labels) { - if(rrdlabels_walkthrough_read(st->state->chart_labels, send_clabels_callback, host->sender->build) > 0) + if (st->rrdlabels) { + if(rrdlabels_walkthrough_read(st->rrdlabels, send_clabels_callback, host->sender->build) > 0) buffer_sprintf(host->sender->build,"CLABEL_COMMIT\n"); } } @@ -406,12 +406,12 @@ static int send_labels_callback(const char *name, const char *value, RRDLABEL_SR return 1; } void rrdpush_send_labels(RRDHOST *host) { - if (!host->host_labels || !rrdhost_flag_check(host, RRDHOST_FLAG_STREAM_LABELS_UPDATE) || (rrdhost_flag_check(host, RRDHOST_FLAG_STREAM_LABELS_STOP))) + if (!host->rrdlabels || !rrdhost_flag_check(host, RRDHOST_FLAG_STREAM_LABELS_UPDATE) || (rrdhost_flag_check(host, RRDHOST_FLAG_STREAM_LABELS_STOP))) return; sender_start(host->sender); - rrdlabels_walkthrough_read(host->host_labels, send_labels_callback, host->sender->build); + rrdlabels_walkthrough_read(host->rrdlabels, send_labels_callback, host->sender->build); buffer_sprintf(host->sender->build, "OVERWRITE %s\n", "labels"); sender_commit(host->sender); |