Commit c200ecc3 authored by Steffen Vogel's avatar Steffen Vogel 🎅🏼

Merge branch 'mqtt-fix-thread' into 'master'

use warnings instead of errors in async mqtt thread

See merge request acs/public/villas/VILLASnode!54
parents a56d875b 2d6eb5e5
......@@ -57,13 +57,13 @@ static void * mosquitto_loop_thread(void *ctx)
ret = mosquitto_reconnect(m->client);
if (ret != MOSQ_ERR_SUCCESS)
error("MQTT: reconnection to broker failed for node %s: %s", node_name(node), mosquitto_strerror(ret));
warning("MQTT: reconnection to broker failed for node %s: %s", node_name(node), mosquitto_strerror(ret));
else
warning("MQTT: successfully reconnected to broker for node %s: %s", node_name(node), mosquitto_strerror(ret));
ret = mosquitto_loop(m->client, -1, 1);
ret = mosquitto_loop(m->client, 0, 1);
if (ret != MOSQ_ERR_SUCCESS)
error("MQTT: persisting connection error for node %s: %s", node_name(node), mosquitto_strerror(ret));
warning("MQTT: persisting connection error for node %s: %s", node_name(node), mosquitto_strerror(ret));
}
}
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment