4 types derived from ResourceCounter
InMemory.FunctionalTests (1)
src\Servers\Kestrel\shared\test\EventRaisingResourceCounter.cs (1)
9internal class EventRaisingResourceCounter : ResourceCounter
Microsoft.AspNetCore.Server.Kestrel.Core (2)
Internal\Infrastructure\ResourceCounter.cs (2)
16private sealed class UnlimitedCounter : ResourceCounter 24internal sealed class FiniteCounter : ResourceCounter
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
src\Servers\Kestrel\shared\test\EventRaisingResourceCounter.cs (1)
9internal class EventRaisingResourceCounter : ResourceCounter
31 references to ResourceCounter
InMemory.FunctionalTests (7)
ConnectionLimitTests.cs (3)
32var counter = new EventRaisingResourceCounter(ResourceCounter.Quota(1)); 180var counter = new EventRaisingResourceCounter(ResourceCounter.Quota(uint.MaxValue)); 233private TestServer CreateServerWithMaxConnections(RequestDelegate app, ResourceCounter concurrentConnectionCounter, IMeterFactory meterFactory = null)
src\Servers\Kestrel\shared\test\EventRaisingResourceCounter.cs (2)
11private readonly ResourceCounter _wrapped; 13public EventRaisingResourceCounter(ResourceCounter wrapped)
src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)
59ConnectionManager = new ConnectionManager(Log, ResourceCounter.Unlimited);
UpgradeTests.cs (1)
306serviceContext.ConnectionManager = new ConnectionManager(serviceContext.Log, ResourceCounter.Quota(limit));
Microsoft.AspNetCore.Server.Kestrel.Core (12)
Internal\Infrastructure\ConnectionManager.cs (5)
22public ConnectionManager(KestrelTrace trace, ResourceCounter upgradedConnections) 34public ResourceCounter UpgradedConnectionCount { get; } 89private static ResourceCounter GetCounter(long? number) 91? ResourceCounter.Quota(number.Value) 92: ResourceCounter.Unlimited;
Internal\Infrastructure\ResourceCounter.cs (2)
13public static ResourceCounter Unlimited { get; } = new UnlimitedCounter(); 14public static ResourceCounter Quota(long amount) => new FiniteCounter(amount);
Middleware\ConnectionLimitMiddleware.cs (5)
14private readonly ResourceCounter _concurrentConnectionCounter; 19: this(next, ResourceCounter.Quota(connectionLimit), trace, metrics) 24internal ConnectionLimitMiddleware(Func<T, Task> next, ResourceCounter concurrentConnectionCounter, KestrelTrace trace, KestrelMetrics metrics) 58private readonly ResourceCounter _concurrentConnectionCounter; 61public ConnectionReleasor(ResourceCounter normalConnectionCounter)
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (10)
HttpConnectionManagerTests.cs (1)
23var httpConnectionManager = new ConnectionManager(trace, ResourceCounter.Unlimited);
ResourceCounterTests.cs (6)
18Assert.Throws<ArgumentOutOfRangeException>(() => ResourceCounter.Quota(max)); 24var counter = ResourceCounter.Quota(1); 36var counter = ResourceCounter.Quota(max); 51var counter = new ResourceCounter.FiniteCounter(long.MaxValue);
src\Servers\Kestrel\shared\test\EventRaisingResourceCounter.cs (2)
11private readonly ResourceCounter _wrapped; 13public EventRaisingResourceCounter(ResourceCounter wrapped)
src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)
59ConnectionManager = new ConnectionManager(Log, ResourceCounter.Unlimited);
Sockets.BindTests (1)
src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)
59ConnectionManager = new ConnectionManager(Log, ResourceCounter.Unlimited);
Sockets.FunctionalTests (1)
src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)
59ConnectionManager = new ConnectionManager(Log, ResourceCounter.Unlimited);