Heartbeat

src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)

Internal\KestrelServerImpl.cs (1)

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(

src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)

40Heartbeat = new Heartbeat(

src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)

40Heartbeat = new Heartbeat(

Http2\Http2TestBase.cs (2)

1397while (timeProvider.GetTimestamp(Heartbeat.Interval) < endTime) 1399TriggerTick(Heartbeat.Interval);

Http2\Http2TimeoutTests.cs (11)

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);

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));

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);

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)

WebHostBuilderKestrelExtensionsTests.cs (1)

124var handlers = (IHeartbeatHandler[])typeof(Heartbeat).GetField("_callbacks", BindingFlags.NonPublic | BindingFlags.Instance).GetValue(server.ServiceContext.Heartbeat);

src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)

45Heartbeat.Interval);

src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)

45Heartbeat.Interval);