summaryrefslogtreecommitdiffstats
path: root/aclk
diff options
context:
space:
mode:
authorEmmanuel Vasilakis <mrzammler@mm.st>2022-11-03 12:10:31 +0200
committerGitHub <noreply@github.com>2022-11-03 12:10:31 +0200
commitcd28c686158840afb020d6b984aa9f96ac656742 (patch)
tree396e3a7c3e6f32f361fb46284549034693425b8f /aclk
parentc270b6067bc91233696dc038c6356c1e384e13cf (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.c19
-rw-r--r--aclk/aclk_tx_msgs.c9
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;
}