X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fwrite_redis.c;h=231738c5bc6993e6c25b0f66dcc1c53a635ba4b0;hb=49ac868d2346c77335272b8a643bca295db9feaa;hp=da5b7bbe8ba1ffa84ddae9ab8e2fc5325c7a69ad;hpb=a359afebf9e55cdb46b445e3d46d728a4d6fe992;p=collectd.git diff --git a/src/write_redis.c b/src/write_redis.c index da5b7bbe..231738c5 100644 --- a/src/write_redis.c +++ b/src/write_redis.c @@ -73,10 +73,11 @@ static int wr_write (const data_set_t *ds, /* {{{ */ value_size = sizeof (value); value_ptr = &value[0]; status = format_values (value_ptr, value_size, ds, vl, /* store rates = */ 0); - pthread_mutex_lock (&node->lock); if (status != 0) return (status); + pthread_mutex_lock (&node->lock); + if (node->conn == NULL) { node->conn = redisConnectWithTimeout ((char *)node->host, node->port, node->timeout);