Allow to set the max by config

neo-project · Jan 7, 2020 · ab43e2e · ab43e2e
1 parent 67b962c
commit ab43e2e
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/neo/Network/RPC/RpcServer.cs b/neo/Network/RPC/RpcServer.cs
@@ -32,15 +32,17 @@ public sealed class RpcServer : IDisposable
     {
         public Wallet Wallet { get; set; }
         public Fixed8 MaxGasInvoke { get; }
+        public int MaxConcurrentConnections { get; }
 
         private IWebHost host;
         private readonly NeoSystem system;
 
-        public RpcServer(NeoSystem system, Wallet wallet = null, Fixed8 maxGasInvoke = default(Fixed8))
+        public RpcServer(NeoSystem system, Wallet wallet = null, Fixed8 maxGasInvoke = default(Fixed8), int maxConcurrentConnections = Peer.DefaultMaxConnections)
         {
             this.system = system;
             this.Wallet = wallet;
             this.MaxGasInvoke = maxGasInvoke;
+            this.MaxConcurrentConnections = maxConcurrentConnections;
         }
 
         private static JObject CreateErrorResponse(JObject id, int code, string message, JObject data = null)
@@ -362,7 +364,7 @@ public void Start(IPAddress bindAddress, int port, string sslCert = null, string
             host = new WebHostBuilder().UseKestrel(options => options.Listen(bindAddress, port, listenOptions =>
             {
                 // Default value is unlimited
-                options.Limits.MaxConcurrentConnections = Peer.DefaultMaxConnections;
+                options.Limits.MaxConcurrentConnections = MaxConcurrentConnections;
                 // Default value is 2 minutes
                 options.Limits.KeepAliveTimeout = TimeSpan.FromMinutes(1);
                 // Default value is 30 seconds