diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2023-07-20 04:49:55 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2023-07-20 04:49:55 +0000 |
commit | ab1bb5b7f1c3c3a7b240ab7fc8661459ecd7decb (patch) | |
tree | 7a900833aad3ccc685712c6c2a7d87576d54f427 /aclk/aclk_tx_msgs.c | |
parent | Adding upstream version 1.40.1. (diff) | |
download | netdata-upstream/1.41.0.tar.xz netdata-upstream/1.41.0.zip |
Adding upstream version 1.41.0.upstream/1.41.0
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'aclk/aclk_tx_msgs.c')
-rw-r--r-- | aclk/aclk_tx_msgs.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/aclk/aclk_tx_msgs.c b/aclk/aclk_tx_msgs.c index d11e96cfb..26e20dfb2 100644 --- a/aclk/aclk_tx_msgs.c +++ b/aclk/aclk_tx_msgs.c @@ -32,7 +32,7 @@ uint16_t aclk_send_bin_message_subtopic_pid(mqtt_wss_client client, char *msg, s const char *topic = aclk_get_topic(subtopic); if (unlikely(!topic)) { - error("Couldn't get topic. Aborting message send."); + netdata_log_error("Couldn't get topic. Aborting message send."); return 0; } @@ -61,7 +61,7 @@ static int aclk_send_message_with_bin_payload(mqtt_wss_client client, json_objec int len; if (unlikely(!topic || topic[0] != '/')) { - error ("Full topic required!"); + netdata_log_error("Full topic required!"); json_object_put(msg); return HTTP_RESP_INTERNAL_SERVER_ERROR; } @@ -172,7 +172,7 @@ void aclk_http_msg_v2_err(mqtt_wss_client client, const char *topic, const char json_object_object_add(msg, "error-description", tmp); if (aclk_send_message_with_bin_payload(client, msg, topic, payload, payload_len)) { - error("Failed to send cancellation message for http reply %zu %s", payload_len, payload); + netdata_log_error("Failed to send cancellation message for http reply %zu %s", payload_len, payload); } } @@ -220,7 +220,7 @@ uint16_t aclk_send_agent_connection_update(mqtt_wss_client client, int reachable rrdhost_aclk_state_lock(localhost); if (unlikely(!localhost->aclk_state.claimed_id)) { - error("Internal error. Should not come here if not claimed"); + netdata_log_error("Internal error. Should not come here if not claimed"); rrdhost_aclk_state_unlock(localhost); return 0; } @@ -233,7 +233,7 @@ uint16_t aclk_send_agent_connection_update(mqtt_wss_client client, int reachable rrdhost_aclk_state_unlock(localhost); if (!msg) { - error("Error generating agent::v1::UpdateAgentConnection payload"); + netdata_log_error("Error generating agent::v1::UpdateAgentConnection payload"); return 0; } @@ -255,7 +255,7 @@ char *aclk_generate_lwt(size_t *size) { rrdhost_aclk_state_lock(localhost); if (unlikely(!localhost->aclk_state.claimed_id)) { - error("Internal error. Should not come here if not claimed"); + netdata_log_error("Internal error. Should not come here if not claimed"); rrdhost_aclk_state_unlock(localhost); return NULL; } @@ -265,7 +265,7 @@ char *aclk_generate_lwt(size_t *size) { rrdhost_aclk_state_unlock(localhost); if (!msg) - error("Error generating agent::v1::UpdateAgentConnection payload for LWT"); + netdata_log_error("Error generating agent::v1::UpdateAgentConnection payload for LWT"); return msg; } |