diff options
author | Emmanuel Vasilakis <mrzammler@mm.st> | 2022-11-03 12:10:31 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-11-03 12:10:31 +0200 |
commit | cd28c686158840afb020d6b984aa9f96ac656742 (patch) | |
tree | 396e3a7c3e6f32f361fb46284549034693425b8f /aclk | |
parent | c270b6067bc91233696dc038c6356c1e384e13cf (diff) |
Enable aclk conversation log even without NETDATA_INTERNAL CHECKS (#13917)
enable aclk conversation without INTERNAL CHECKS
Diffstat (limited to 'aclk')
-rw-r--r-- | aclk/aclk_rx_msgs.c | 19 | ||||
-rw-r--r-- | aclk/aclk_tx_msgs.c | 9 |
2 files changed, 16 insertions, 12 deletions
diff --git a/aclk/aclk_rx_msgs.c b/aclk/aclk_rx_msgs.c index 4a5ddc0d2d..6a1fc0534a 100644 --- a/aclk/aclk_rx_msgs.c +++ b/aclk/aclk_rx_msgs.c @@ -527,15 +527,16 @@ void aclk_handle_new_cloud_msg(const char *message_type, const char *msg, size_t return; } -#ifdef NETDATA_INTERNAL_CHECKS - if (!strncmp(message_type, "cmd", strlen("cmd"))) { - log_aclk_message_bin(msg, msg_len, 0, topic, msg_descriptor->name); - } else { - char *json = protomsg_to_json(msg, msg_len, msg_descriptor->name); - log_aclk_message_bin(json, strlen(json), 0, topic, msg_descriptor->name); - freez(json); - } -#endif + + if (aclklog_enabled) { + if (!strncmp(message_type, "cmd", strlen("cmd"))) { + log_aclk_message_bin(msg, msg_len, 0, topic, msg_descriptor->name); + } else { + char *json = protomsg_to_json(msg, msg_len, msg_descriptor->name); + log_aclk_message_bin(json, strlen(json), 0, topic, msg_descriptor->name); + freez(json); + } + } if (aclk_stats_enabled) { ACLK_STATS_LOCK; diff --git a/aclk/aclk_tx_msgs.c b/aclk/aclk_tx_msgs.c index f7c4c08593..e46a6395e4 100644 --- a/aclk/aclk_tx_msgs.c +++ b/aclk/aclk_tx_msgs.c @@ -39,11 +39,14 @@ uint16_t aclk_send_bin_message_subtopic_pid(mqtt_wss_client client, char *msg, s #ifdef NETDATA_INTERNAL_CHECKS aclk_stats_msg_published(packet_id); - char *json = protomsg_to_json(msg, msg_len, msgname); - log_aclk_message_bin(json, strlen(json), 1, topic, msgname); - freez(json); #endif + if (aclklog_enabled) { + char *json = protomsg_to_json(msg, msg_len, msgname); + log_aclk_message_bin(json, strlen(json), 1, topic, msgname); + freez(json); + } + return packet_id; } |