diff options
| author | Timotej S <6674623+underhood@users.noreply.github.com> | 2021-07-07 16:32:37 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-07-07 16:32:37 +0200 |
| commit | d005dee55800818b26f6308c433e6aed8079f7fe (patch) | |
| tree | 2e884e10d333dfa947b1b20d360dcad805a492ed /streaming/receiver.c | |
| parent | 59394b5f9d8891cb59c42ac87fd8f0d41b28db94 (diff) | |
ACLK-NG New Cloud NodeInstance related msgs (#11234)
Adds new cloud arch NodeInstance messages as per design.
Co-authored-by: Stelios Fragkakis <52996999+stelfrag@users.noreply.github.com>
Diffstat (limited to 'streaming/receiver.c')
| -rw-r--r-- | streaming/receiver.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/streaming/receiver.c b/streaming/receiver.c index e1fcaafb38..6771387920 100644 --- a/streaming/receiver.c +++ b/streaming/receiver.c @@ -454,11 +454,11 @@ static int rrdpush_receive(struct receiver_state *rpt) cd.version = rpt->stream_version; -#if defined(ENABLE_ACLK) && !defined(ACLK_NG) +#if defined(ENABLE_ACLK) // in case we have cloud connection we inform cloud // new slave connected if (netdata_cloud_setting) - aclk_host_state_update(rpt->host, ACLK_CMD_CHILD_CONNECT); + aclk_host_state_update(rpt->host, 1); #endif size_t count = streaming_parser(rpt, &cd, fp); @@ -468,11 +468,11 @@ static int rrdpush_receive(struct receiver_state *rpt) error("STREAM %s [receive from [%s]:%s]: disconnected (completed %zu updates).", rpt->hostname, rpt->client_ip, rpt->client_port, count); -#if defined(ENABLE_ACLK) && !defined(ACLK_NG) +#if defined(ENABLE_ACLK) // in case we have cloud connection we inform cloud // new slave connected if (netdata_cloud_setting) - aclk_host_state_update(rpt->host, ACLK_CMD_CHILD_DISCONNECT); + aclk_host_state_update(rpt->host, 0); #endif // During a shutdown there is cleanup code in rrdhost that will cancel the sender thread |