From ed4a14805bb4dc6a6ce9f8e02e6cea86d79ac674 Mon Sep 17 00:00:00 2001
From: DanB <danb@cgrates.org>
Date: Tue, 4 Oct 2016 17:40:48 +0200
Subject: [PATCH] Redis pool - Lock on close

---
 engine/storage_redis.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/engine/storage_redis.go b/engine/storage_redis.go
index 666cbc02f..2ef9e5ce6 100644
--- a/engine/storage_redis.go
+++ b/engine/storage_redis.go
@@ -134,7 +134,9 @@ func (rs *RedisStorage) Cmd(cmd string, args ...interface{}) *redis.Resp {
 }
 
 func (rs *RedisStorage) Close() {
+	rs.poolLock.Lock()
 	rs.dbPool.Empty()
+	rs.poolLock.Unlock()
 }
 
 func (rs *RedisStorage) Flush(ignore string) error {