diff options
| author | Stelios Fragkakis <52996999+stelfrag@users.noreply.github.com> | 2020-05-25 20:25:08 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-05-25 20:25:08 +0300 |
| commit | 570d5253f53b46ce59b3fd93a53b15f56f946038 (patch) | |
| tree | 490cda44451f87f1dc46457f381cbc8296238ee4 /streaming | |
| parent | 4fb41597da6961813679c1b795793600ddc0a402 (diff) | |
Implement new incremental parser (#9074)
Implemented a new parser for the pluginsd language
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/rrdpush.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/streaming/rrdpush.c b/streaming/rrdpush.c index cd7b3b93e2..fa3cc2d478 100644 --- a/streaming/rrdpush.c +++ b/streaming/rrdpush.c @@ -1,6 +1,7 @@ // SPDX-License-Identifier: GPL-3.0-or-later #include "rrdpush.h" +#include "../parser/parser.h" /* * rrdpush @@ -1214,6 +1215,7 @@ static int rrdpush_receive(int fd .obsolete = 0, .started_t = now_realtime_sec(), .next = NULL, + .version = 0, }; // put the client IP and port into the buffers used by plugins.d @@ -1289,6 +1291,7 @@ static int rrdpush_receive(int fd info("STREAM %s [receive from [%s]:%s]: receiving metrics...", host->hostname, client_ip, client_port); log_stream_connection(client_ip, client_port, key, host->machine_guid, host->hostname, "CONNECTED"); + cd.version = stream_version; size_t count = pluginsd_process(host, &cd, fp, 1); log_stream_connection(client_ip, client_port, key, host->machine_guid, host->hostname, "DISCONNECTED"); |