13 instantiations of Heartbeat
InMemory.FunctionalTests (1)
src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)
40Heartbeat = new Heartbeat(
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\KestrelServerImpl.cs (1)
91var heartbeat = new Heartbeat(
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (9)
DateHeaderValueManagerTests.cs (3)
45using (var heartbeat = new Heartbeat(new IHeartbeatHandler[] { dateHeaderValueManager }, timeProvider, DebuggerWrapper.Singleton, testKestrelTrace, Heartbeat.Interval)) 67using (var heartbeat = new Heartbeat(new[] { dateHeaderValueManager, mockHeartbeatHandler.Object }, timeProvider, DebuggerWrapper.Singleton, testKestrelTrace, Heartbeat.Interval)) 93using (var heartbeat = new Heartbeat(new IHeartbeatHandler[] { dateHeaderValueManager }, timeProvider, DebuggerWrapper.Singleton, testKestrelTrace, Heartbeat.Interval))
HeartbeatTests.cs (4)
67using (var heartbeat = new Heartbeat(new[] { heartbeatHandler.Object }, timeProvider, debugger.Object, kestrelTrace, TimeSpan.FromMilliseconds(intervalMs))) 121using (var heartbeat = new Heartbeat(new[] { heartbeatHandler.Object }, timeProvider, debugger.Object, kestrelTrace, Heartbeat.Interval)) 164using (var heartbeat = new Heartbeat(new[] { heartbeatHandler.Object }, timeProvider, debugger.Object, kestrelTrace, Heartbeat.Interval)) 193using (var heartbeat = new Heartbeat(new[] { heartbeatHandler.Object }, timeProvider, DebuggerWrapper.Singleton, kestrelTrace, Heartbeat.Interval))
KestrelServerTests.cs (1)
732testContext.Heartbeat = new Heartbeat(
src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)
40Heartbeat = new Heartbeat(
Sockets.BindTests (1)
src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)
40Heartbeat = new Heartbeat(
Sockets.FunctionalTests (1)
src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)
40Heartbeat = new Heartbeat(
77 references to Heartbeat
InMemory.FunctionalTests (29)
Http2\Http2TestBase.cs (2)
1397while (timeProvider.GetTimestamp(Heartbeat.Interval) < endTime) 1399TriggerTick(Heartbeat.Interval);
Http2\Http2TimeoutTests.cs (11)
25AdvanceTime(limits.KeepAliveTimeout + Heartbeat.Interval); 45AdvanceTime(limits.KeepAliveTimeout + Heartbeat.Interval); 65AdvanceTime(limits.KeepAliveTimeout + Heartbeat.Interval); 93AdvanceTime(limits.KeepAliveTimeout + Heartbeat.Interval); 182AdvanceTime(limits.RequestHeadersTimeout + Heartbeat.Interval); 219limits.MinResponseDataRate.GracePeriod + Heartbeat.Interval - TimeSpan.FromSeconds(.5)); 376limits.MinResponseDataRate.GracePeriod + Heartbeat.Interval - TimeSpan.FromSeconds(.5)); 428limits.MinResponseDataRate.GracePeriod + Heartbeat.Interval - TimeSpan.FromSeconds(.5); 485limits.MinResponseDataRate.GracePeriod + Heartbeat.Interval - TimeSpan.FromSeconds(.5)); 536limits.MinResponseDataRate.GracePeriod + Heartbeat.Interval - TimeSpan.FromSeconds(.5); 602limits.MinResponseDataRate.GracePeriod + Heartbeat.Interval - TimeSpan.FromSeconds(.5);
Http3\Http3TimeoutTests.cs (4)
74Http3Api.AdvanceTime(limits.KeepAliveTimeout + Heartbeat.Interval + TimeSpan.FromTicks(1)); 120Http3Api.AdvanceTime(limits.KeepAliveTimeout + Heartbeat.Interval + TimeSpan.FromTicks(1)); 471limits.MinResponseDataRate.GracePeriod + Heartbeat.Interval - TimeSpan.FromSeconds(.5)); 512limits.MinResponseDataRate.GracePeriod + Heartbeat.Interval - TimeSpan.FromSeconds(.5);
KeepAliveTimeoutTests.cs (3)
46testContext.FakeTimeProvider.Advance(_keepAliveTimeout + Heartbeat.Interval + TimeSpan.FromTicks(1)); 80testContext.FakeTimeProvider.Advance(_keepAliveTimeout + Heartbeat.Interval); 194testContext.FakeTimeProvider.Advance(_keepAliveTimeout + Heartbeat.Interval + TimeSpan.FromTicks(1));
RequestHeadersTimeoutTests.cs (3)
42testContext.FakeTimeProvider.Advance(RequestHeadersTimeout + Heartbeat.Interval + TimeSpan.FromTicks(1)); 74testContext.FakeTimeProvider.Advance(RequestHeadersTimeout + Heartbeat.Interval + TimeSpan.FromTicks(1)); 107testContext.FakeTimeProvider.Advance(RequestHeadersTimeout + Heartbeat.Interval + TimeSpan.FromTicks(1));
RequestTests.cs (1)
1635new MinDataRate(bytesPerSecond: double.MaxValue, gracePeriod: Heartbeat.Interval + TimeSpan.FromTicks(1));
ResponseDrainingTests.cs (1)
65testContext.FakeTimeProvider.Advance(Heartbeat.Interval - TimeSpan.FromSeconds(.5));
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)
208while (timeProvider.GetTimestamp(Heartbeat.Interval) < endTime) 210timeProvider.Advance(Heartbeat.Interval);
src\Servers\Kestrel\shared\test\TestContextFactory.cs (1)
30Heartbeat heartbeat = null)
src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)
45Heartbeat.Interval);
Microsoft.AspNetCore.Server.Kestrel.Core (12)
Http2Limits.cs (4)
165if (value < Heartbeat.Interval && value != Timeout.InfiniteTimeSpan) 167throw new ArgumentOutOfRangeException(nameof(value), CoreStrings.FormatArgumentTimeSpanGreaterOrEqual(Heartbeat.Interval)); 190if (value < Heartbeat.Interval && value != Timeout.InfiniteTimeSpan) 192throw new ArgumentOutOfRangeException(nameof(value), CoreStrings.FormatArgumentTimeSpanGreaterOrEqual(Heartbeat.Interval));
Internal\Infrastructure\Heartbeat.cs (2)
30_timerThread = new Thread(state => ((Heartbeat)state!).TimerLoop()) 66_trace.LogError(0, ex, $"{nameof(Heartbeat)}.{nameof(OnHeartbeat)}");
Internal\Infrastructure\TimeoutControl.cs (1)
39_heartbeatIntervalTicks = Heartbeat.Interval.ToTicks(_timeProvider);
Internal\KestrelServerImpl.cs (2)
91var heartbeat = new Heartbeat( 96Heartbeat.Interval);
Internal\ServiceContext.cs (1)
30public Heartbeat Heartbeat { get; set; } = default!;
MinDataRate.cs (2)
26if (gracePeriod <= Heartbeat.Interval) 28throw new ArgumentOutOfRangeException(nameof(gracePeriod), CoreStrings.FormatMinimumGracePeriodRequired(Heartbeat.Interval.TotalSeconds));
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (30)
DateHeaderValueManagerTests.cs (6)
45using (var heartbeat = new Heartbeat(new IHeartbeatHandler[] { dateHeaderValueManager }, timeProvider, DebuggerWrapper.Singleton, testKestrelTrace, Heartbeat.Interval)) 67using (var heartbeat = new Heartbeat(new[] { dateHeaderValueManager, mockHeartbeatHandler.Object }, timeProvider, DebuggerWrapper.Singleton, testKestrelTrace, Heartbeat.Interval)) 93using (var heartbeat = new Heartbeat(new IHeartbeatHandler[] { dateHeaderValueManager }, timeProvider, DebuggerWrapper.Singleton, testKestrelTrace, Heartbeat.Interval))
HeartbeatTests.cs (9)
19Assert.Equal(TimeSpan.FromSeconds(1), Heartbeat.Interval); 67using (var heartbeat = new Heartbeat(new[] { heartbeatHandler.Object }, timeProvider, debugger.Object, kestrelTrace, TimeSpan.FromMilliseconds(intervalMs))) 121using (var heartbeat = new Heartbeat(new[] { heartbeatHandler.Object }, timeProvider, debugger.Object, kestrelTrace, Heartbeat.Interval)) 140+ $"\"{Heartbeat.Interval.ToString("c", CultureInfo.InvariantCulture)}\". " 164using (var heartbeat = new Heartbeat(new[] { heartbeatHandler.Object }, timeProvider, debugger.Object, kestrelTrace, Heartbeat.Interval)) 193using (var heartbeat = new Heartbeat(new[] { heartbeatHandler.Object }, timeProvider, DebuggerWrapper.Singleton, kestrelTrace, Heartbeat.Interval))
KestrelServerTests.cs (1)
737Heartbeat.Interval);
MinDataRateTests.cs (3)
46Assert.StartsWith(CoreStrings.FormatMinimumGracePeriodRequired(Heartbeat.Interval.TotalSeconds), exception.Message); 51Heartbeat.Interval + TimeSpan.FromTicks(1), 60Heartbeat.Interval
src\Servers\Kestrel\shared\test\TestContextFactory.cs (1)
30Heartbeat heartbeat = null)
src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)
45Heartbeat.Interval);
TimeoutControlTests.cs (9)
34_timeoutControl.Tick(_timeProvider.GetTimestamp(now + 2, Heartbeat.Interval)); 276_timeProvider.Advance(TimeSpan.FromSeconds(2) + Heartbeat.Interval + TimeSpan.FromTicks(1)); 383AdvanceClock(TimeSpan.FromSeconds(4) + Heartbeat.Interval + TimeSpan.FromTicks(1)); 401AdvanceClock(TimeSpan.FromSeconds(1) + Heartbeat.Interval + TimeSpan.FromTicks(1)); 429AdvanceClock(TimeSpan.FromSeconds(5) + Heartbeat.Interval + TimeSpan.FromTicks(1)); 465AdvanceClock(Heartbeat.Interval + minRate.GracePeriod + TimeSpan.FromSeconds((numWrites - 1) * writeSize / minRate.BytesPerSecond)); 489_timeProvider.Advance(TimeSpan.FromSeconds(4) + Heartbeat.Interval + TimeSpan.FromTicks(1)); 524while (_timeProvider.GetTimestamp(Heartbeat.Interval) < endTime) 526_timeProvider.Advance(Heartbeat.Interval);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (3)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)
208while (timeProvider.GetTimestamp(Heartbeat.Interval) < endTime) 210timeProvider.Advance(Heartbeat.Interval);
src\Servers\Kestrel\shared\test\TestContextFactory.cs (1)
30Heartbeat heartbeat = null)
Microsoft.AspNetCore.Server.Kestrel.Tests (1)
WebHostBuilderKestrelExtensionsTests.cs (1)
124var handlers = (IHeartbeatHandler[])typeof(Heartbeat).GetField("_callbacks", BindingFlags.NonPublic | BindingFlags.Instance).GetValue(server.ServiceContext.Heartbeat);
Sockets.BindTests (1)
src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)
45Heartbeat.Interval);
Sockets.FunctionalTests (1)
src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)
45Heartbeat.Interval);