From 35cc8ca6e8bd5a2efceefd057118d8758f7d30bf Mon Sep 17 00:00:00 2001 From: Steffen Vogel Date: Thu, 19 Apr 2018 11:02:12 +0200 Subject: [PATCH] mqtt: reduce debug level --- lib/nodes/mqtt.c | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/lib/nodes/mqtt.c b/lib/nodes/mqtt.c index 5043db59e..be8e27b87 100644 --- a/lib/nodes/mqtt.c +++ b/lib/nodes/mqtt.c @@ -99,12 +99,12 @@ static void * mqtt_thread(void *ctx) { int ret; - debug(1, "MQTT: started thread"); + debug(5, "MQTT: started thread"); while (1) { // pthread_mutex_lock(&polling.mutex); - debug(1, "MQTT: Polling on %d clients", polling.length); + debug(5, "MQTT: Polling on %d clients", polling.length); ret = poll(polling.fds, polling.length, -1); if (ret < 0) @@ -153,7 +153,7 @@ static void mqtt_connect_cb(struct mosquitto *mosq, void *userdata, int result) struct node *n = (struct node *) userdata; struct mqtt *m = (struct mqtt *) n->_vd; - debug(1, "MQTT: Node %s connected to broker %s", node_name(n), m->host); + debug(5, "MQTT: Node %s connected to broker %s", node_name(n), m->host); // mqtt_register_client(mosq); } @@ -163,7 +163,7 @@ static void mqtt_disconnect_cb(struct mosquitto *mosq, void *userdata, int resul struct node *n = (struct node *) userdata; struct mqtt *m = (struct mqtt *) n->_vd; - debug(1, "MQTT: Node %s disconnected from broker %s", node_name(n), m->host); + debug(5, "MQTT: Node %s disconnected from broker %s", node_name(n), m->host); // mqtt_unregister_client(mosq) } @@ -175,7 +175,7 @@ static void mqtt_message_cb(struct mosquitto *mosq, void *userdata, const struct struct mqtt *m = (struct mqtt *) n->_vd; struct sample *smp; - debug(1, "MQTT: Node %s received a message of %d bytes from broker %s", node_name(n), msg->payloadlen, m->host); + debug(5, "MQTT: Node %s received a message of %d bytes from broker %s", node_name(n), msg->payloadlen, m->host); smp = sample_alloc(&m->pool); if (!smp) {