Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
Code Issues Releases Wiki Activity

mqtt: reduce debug level

Browse source
This commit is contained in:
Steffen Vogel 2018-04-19 11:02:12 +02:00
parent c5e2776440
commit 35cc8ca6e8
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
lib/nodes/mqtt.c
View file

@ -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) {