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

close queues when nodes are stopped

Browse source
This commit is contained in:
Steffen Vogel 2022-01-11 07:29:28 -05:00
parent 7f7ae44acc
commit 2ee4bc7589
2 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lib/nodes/mqtt.cpp
View file

@ -479,6 +479,10 @@ int villas::node::mqtt_stop(NodeCompat *n)
if (ret != MOSQ_ERR_SUCCESS)
goto mosquitto_error;
ret = queue_signalled_close(&m->queue);
if (ret)
return ret;
return 0;
mosquitto_error:

4
lib/nodes/redis.cpp
View file

@ -563,6 +563,10 @@ int villas::node::redis_stop(NodeCompat *n)
break;
}
ret = queue_signalled_close(&r->queue);
if (ret)
return ret;
return 0;
}