Check SocketPoolOptions timeout properties

Author: cnblogs-dudu

Enyim.Caching/Configuration/MemcachedClientConfiguration.cs

@@ -52,20 +52,27 @@ public MemcachedClientConfiguration(
             SocketPool = new SocketPoolConfiguration();
             if (options.SocketPool != null)
             {
+                options.SocketPool.CheckTimeout();
+
                 SocketPool.MinPoolSize = options.SocketPool.MinPoolSize;
                 _logger.LogInformation($"{nameof(SocketPool.MinPoolSize)}: {SocketPool.MinPoolSize}");
+
                 SocketPool.MaxPoolSize = options.SocketPool.MaxPoolSize;
                 _logger.LogInformation($"{nameof(SocketPool.MaxPoolSize)}: {SocketPool.MaxPoolSize}");
-                SocketPool.ConnectionTimeout = options.SocketPool.ConnectionTimeout;
-                _logger.LogInformation($"{nameof(SocketPool.ConnectionTimeout)}: {SocketPool.ConnectionTimeout}");
+
+                SocketPool.ConnectionTimeout = options.SocketPool.ConnectionTimeout;                
+                _logger.LogInformation($"{nameof(SocketPool.ConnectionTimeout)}: {SocketPool.ConnectionTimeout}");                              
+
                 SocketPool.ReceiveTimeout = options.SocketPool.ReceiveTimeout;
                 _logger.LogInformation($"{nameof(SocketPool.ReceiveTimeout)}: {SocketPool.ReceiveTimeout}");
+
                 SocketPool.DeadTimeout = options.SocketPool.DeadTimeout;
                 _logger.LogInformation($"{nameof(SocketPool.DeadTimeout)}: {SocketPool.DeadTimeout}");
+
                 SocketPool.QueueTimeout = options.SocketPool.QueueTimeout;
                 _logger.LogInformation($"{nameof(SocketPool.QueueTimeout)}: {SocketPool.QueueTimeout}");
             }
-            
+
             Protocol = options.Protocol;
 
             if (options.Authentication != null && !string.IsNullOrEmpty(options.Authentication.Type))

Enyim.Caching/Configuration/MemcachedClientOptions.cs

@@ -66,5 +66,21 @@ public class SocketPoolOptions
         public TimeSpan ReceiveTimeout { get; set; } = new TimeSpan(0, 0, 10);
         public TimeSpan DeadTimeout { get; set; } = new TimeSpan(0, 0, 10);
         public TimeSpan QueueTimeout { get; set; } = new TimeSpan(0, 0, 0, 0, 100);
+
+        public void CheckTimeout()
+        {
+            CheckTimeout(nameof(ConnectionTimeout), ConnectionTimeout);
+            CheckTimeout(nameof(ReceiveTimeout), ReceiveTimeout);
+            CheckTimeout(nameof(DeadTimeout), DeadTimeout);
+            CheckTimeout(nameof(QueueTimeout), QueueTimeout);
+        }
+
+        private void CheckTimeout(string paramName, TimeSpan value)
+        {
+            if (value.TotalHours > 1)
+            {
+                throw new ArgumentOutOfRangeException(paramName, $"{paramName} must be <= 1 hour");
+            }
+        }
     }
 }