Redis pool - Lock on close

This commit is contained in:
DanB
2016-10-04 17:40:48 +02:00
parent db61fb7b67
commit ed4a14805b

View File

@@ -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 {