Change PooledRedisClientManager to use RedisConfig.DefaultMaxPoolSize…

… if specified
ServiceStack · Nov 27, 2015 · e16b5f2 · e16b5f2
1 parent 9694e1e
commit e16b5f2
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/src/ServiceStack.Redis/PooledRedisClientManager.cs b/src/ServiceStack.Redis/PooledRedisClientManager.cs
@@ -128,8 +128,8 @@ public PooledRedisClientManager(IEnumerable<string> readWriteHosts, IEnumerable<
 
             this.Config = config ?? new RedisClientManagerConfig
             {
-                MaxWritePoolSize = masters.Length * PoolSizeMultiplier,
-                MaxReadPoolSize = slaves.Length * PoolSizeMultiplier,
+                MaxWritePoolSize = RedisConfig.DefaultMaxPoolSize ?? masters.Length * PoolSizeMultiplier,
+                MaxReadPoolSize = RedisConfig.DefaultMaxPoolSize ?? slaves.Length * PoolSizeMultiplier,
             };
 
             this.OnFailover = new List<Action<IRedisClientsManager>>();
@@ -655,6 +655,9 @@ public void Start()
                 {"readClientsWithExceptions", "" + readClientsWithExceptions},
                 {"readClientsInUse", "" + readClientsInUse},
                 {"readClientsConnected", "" + readClientsConnected},
+
+                {"RedisResolver.ReadOnlyHostsCount", "" + RedisResolver.ReadOnlyHostsCount},
+                {"RedisResolver.ReadWriteHostsCount", "" + RedisResolver.ReadWriteHostsCount},
             };
 
             return ret;

diff --git a/src/ServiceStack.Redis/RedisManagerPool.cs b/src/ServiceStack.Redis/RedisManagerPool.cs
@@ -48,7 +48,7 @@ public partial class RedisManagerPool
 
         public IRedisResolver RedisResolver { get; set; }
 
-        public int MaxPoolSize { get; set; }
+        public int MaxPoolSize { get; private set; }
 
         public RedisManagerPool() : this(RedisConfig.DefaultHost) { }
         public RedisManagerPool(string host) : this(new[] { host }) { }