diff options
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/replication.c | 2 | ||||
| -rw-r--r-- | streaming/rrdpush.c | 8 |
2 files changed, 5 insertions, 5 deletions
diff --git a/streaming/replication.c b/streaming/replication.c index 1a7be31eea..34f05b4f3b 100644 --- a/streaming/replication.c +++ b/streaming/replication.c @@ -392,7 +392,7 @@ static void replication_query_execute(BUFFER *wb, struct replication_query *q, s if (likely( d->sp.start_time_s <= min_end_time && d->sp.end_time_s >= min_end_time && !storage_point_is_unset(d->sp) && - !storage_point_is_empty(d->sp))) { + !storage_point_is_gap(d->sp))) { buffer_sprintf(wb, PLUGINSD_KEYWORD_REPLAY_SET " \"%s\" " NETDATA_DOUBLE_FORMAT " \"%s\"\n", rrddim_id(d->rd), d->sp.sum, d->sp.flags & SN_FLAG_RESET ? "R" : ""); diff --git a/streaming/rrdpush.c b/streaming/rrdpush.c index 969f6eb6bf..a7b2a80643 100644 --- a/streaming/rrdpush.c +++ b/streaming/rrdpush.c @@ -498,8 +498,8 @@ int connect_to_one_of_destinations( // move the current item to the end of the list // without this, this destination will break the loop again and again // not advancing the destinations to find one that may work - DOUBLE_LINKED_LIST_REMOVE_UNSAFE(host->destinations, d, prev, next); - DOUBLE_LINKED_LIST_APPEND_UNSAFE(host->destinations, d, prev, next); + DOUBLE_LINKED_LIST_REMOVE_ITEM_UNSAFE(host->destinations, d, prev, next); + DOUBLE_LINKED_LIST_APPEND_ITEM_UNSAFE(host->destinations, d, prev, next); break; } @@ -522,7 +522,7 @@ bool destinations_init_add_one(char *entry, void *data) { __atomic_add_fetch(&netdata_buffers_statistics.rrdhost_senders, sizeof(struct rrdpush_destinations), __ATOMIC_RELAXED); - DOUBLE_LINKED_LIST_APPEND_UNSAFE(t->list, d, prev, next); + DOUBLE_LINKED_LIST_APPEND_ITEM_UNSAFE(t->list, d, prev, next); t->count++; info("STREAM: added streaming destination No %d: '%s' to host '%s'", t->count, string2str(d->destination), rrdhost_hostname(t->host)); @@ -549,7 +549,7 @@ void rrdpush_destinations_init(RRDHOST *host) { void rrdpush_destinations_free(RRDHOST *host) { while (host->destinations) { struct rrdpush_destinations *tmp = host->destinations; - DOUBLE_LINKED_LIST_REMOVE_UNSAFE(host->destinations, tmp, prev, next); + DOUBLE_LINKED_LIST_REMOVE_ITEM_UNSAFE(host->destinations, tmp, prev, next); string_freez(tmp->destination); freez(tmp); __atomic_sub_fetch(&netdata_buffers_statistics.rrdhost_senders, sizeof(struct rrdpush_destinations), __ATOMIC_RELAXED); |