diff options
| author | Costa Tsaousis <costa@netdata.cloud> | 2023-02-09 20:27:05 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-02-09 20:27:05 +0200 |
| commit | 414f416c5d290db3c3eed9073258c834fac7f2f7 (patch) | |
| tree | aeed0a2619a1f42c60ec816311d1dd10c8e5ccc1 /streaming/sender.c | |
| parent | 8043106b60ec3d8d32b3a9ff3ef53991e73d9037 (diff) | |
Virtual hosts for data collection (#14464)
* support multiple hosts at pluginsd structures
* cleanup obsolete code
* use a lookup hashtable to quickly find the keyword to execute, without traversing the whole linked list of keywords
* more cleanup
* move new hash function to inlined.h
* minimize comparisons, eliminate a pre-parsing of the first keyword for each line
* cleanup parser from old code
* move parser into libnetdata
* unique entries in parser keywords hashtable
* move all hashing functions to inlined.h, name their sources, simple_hash() now defaults to FNV1a, it was FNV1
* small_hash() for parser
* plugins.d now can switch hosts, and also create/update them
* update hash function and hashtable size
* updated message
* unittest all hashing functions
* reset the chart when setting a new host
* remove host tags
* enable archived hosts when a collector pushes host info
* do not need localhost to swtich to localhost
* disable ARAL and OWA with -DFSANITIZE_ADDRESS=1
Diffstat (limited to 'streaming/sender.c')
| -rw-r--r-- | streaming/sender.c | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/streaming/sender.c b/streaming/sender.c index d1ce9b0f86..1bae576e34 100644 --- a/streaming/sender.c +++ b/streaming/sender.c @@ -1,7 +1,6 @@ // SPDX-License-Identifier: GPL-3.0-or-later #include "rrdpush.h" -#include "parser/parser.h" #define WORKER_SENDER_JOB_CONNECT 0 #define WORKER_SENDER_JOB_PIPE_READ 1 @@ -937,7 +936,7 @@ void execute_commands(struct sender_state *s) { // internal_error(true, "STREAM %s [send to %s] received command over connection: %s", rrdhost_hostname(s->host), s->connected_to, start); char *words[PLUGINSD_MAX_WORDS] = { NULL }; - size_t num_words = pluginsd_split_words(start, words, PLUGINSD_MAX_WORDS, NULL, NULL, 0); + size_t num_words = pluginsd_split_words(start, words, PLUGINSD_MAX_WORDS); const char *keyword = get_word(words, num_words, 0); |