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

redis: fix timeouts

Browse source
This commit is contained in:
Steffen Vogel 2022-01-11 07:39:29 -05:00
parent 04f3a77ec0
commit 6c735f4b18
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lib/nodes/redis.cpp
View file

@ -285,6 +285,10 @@ int villas::node::redis_init(NodeCompat *n)
new (&r->task) Task(CLOCK_REALTIME);
new (&r->key) std::string();
/* We need a timeout in order for RedisConnection::loop() to properly
* terminate after the node is stopped */
r->options.socket_timeout = std::chrono::milliseconds(500);
return 0;
}
@ -445,10 +449,10 @@ int villas::node::redis_parse(NodeCompat *n, json_t *json)
if (keepalive >= 0)
r->options.keep_alive = keepalive != 0;
if (socket_timeout >= 0)
if (socket_timeout > 0)
r->options.socket_timeout = std::chrono::milliseconds((int) (1000 * socket_timeout));
if (connect_timeout >= 0)
if (connect_timeout > 0)
r->options.connect_timeout = std::chrono::milliseconds((int) (1000 * connect_timeout));
return 0;