diff options
| author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-08-26 08:15:24 +0000 |
|---|---|---|
| committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-08-26 08:15:35 +0000 |
| commit | f09848204fa5283d21ea43e262ee41aa578e1808 (patch) | |
| tree | c62385d7adf209fa6a798635954d887f718fb3fb /src/aclk/aclk_rx_msgs.c | |
| parent | Releasing debian version 1.46.3-2. (diff) | |
| download | netdata-f09848204fa5283d21ea43e262ee41aa578e1808.tar.xz netdata-f09848204fa5283d21ea43e262ee41aa578e1808.zip | |
Merging upstream version 1.47.0.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/aclk/aclk_rx_msgs.c')
| -rw-r--r-- | src/aclk/aclk_rx_msgs.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/aclk/aclk_rx_msgs.c b/src/aclk/aclk_rx_msgs.c index 60e421928..8db8e3f1e 100644 --- a/src/aclk/aclk_rx_msgs.c +++ b/src/aclk/aclk_rx_msgs.c @@ -106,13 +106,13 @@ static inline int aclk_v2_payload_get_query(const char *payload, char **query_ur else if(strncmp(payload, "DELETE /", 8) == 0) start = payload + 7; else { - errno = 0; + errno_clear(); netdata_log_error("Only accepting requests that start with GET, POST, PUT, DELETE from CLOUD."); return 1; } if(!(end = strstr(payload, HTTP_1_1 HTTP_ENDL))) { - errno = 0; + errno_clear(); netdata_log_error("Doesn't look like HTTP GET request."); return 1; } @@ -127,7 +127,7 @@ static int aclk_handle_cloud_http_request_v2(struct aclk_request *cloud_to_agent { aclk_query_t query; - errno = 0; + errno_clear(); if (cloud_to_agent->version < ACLK_V_COMPRESSION) { netdata_log_error( "This handler cannot reply to request with version older than %d, received %d.", @@ -347,7 +347,7 @@ int start_alarm_streaming(const char *msg, size_t msg_len) netdata_log_error("Error parsing StartAlarmStreaming"); return 1; } - aclk_start_alert_streaming(res.node_id, res.resets); + aclk_start_alert_streaming(res.node_id, res.version); freez(res.node_id); return 0; } @@ -361,7 +361,7 @@ int send_alarm_checkpoint(const char *msg, size_t msg_len) freez(sac.claim_id); return 1; } - aclk_send_alarm_checkpoint(sac.node_id, sac.claim_id); + aclk_alert_version_check(sac.node_id, sac.claim_id, sac.version); freez(sac.node_id); freez(sac.claim_id); return 0; @@ -375,7 +375,7 @@ int send_alarm_configuration(const char *msg, size_t msg_len) freez(config_hash); return 1; } - aclk_send_alarm_configuration(config_hash); + aclk_send_alert_configuration(config_hash); freez(config_hash); return 0; } |