3 writes to TimeProvider
Aspire.Hosting.RemoteHost (1)
Language\IntegrationHostProcessLauncher.cs (1)
59
TimeProvider
= timeProvider,
Aspire.Hosting.RemoteHost.Tests (2)
tests\Shared\Processes\ChildProcessTests.cs (2)
40
TimeProvider
= new FakeTimeProvider(),
71
TimeProvider
= clock,
12 references to TimeProvider
Aspire.Hosting.RemoteHost (11)
src\Shared\ChildProcess.cs (11)
63
_lastActivityTimestamp = options.
TimeProvider
.GetTimestamp();
337
_options.TerminationTimeout, _options.
TimeProvider
, CancellationToken.None).ConfigureAwait(false);
369
_options.TerminationTimeout, _options.
TimeProvider
, CancellationToken.None).ConfigureAwait(false);
376
await signalTask.WaitAsync(_options.TerminationTimeout, _options.
TimeProvider
, CancellationToken.None).ConfigureAwait(false);
429
await process.WaitForExitAsync().WaitAsync(_options.TerminationTimeout, _options.
TimeProvider
).ConfigureAwait(false);
433
using var deadline = new CancellationTokenSource(_options.TerminationTimeout, _options.
TimeProvider
);
438
await Task.Delay(TimeSpan.FromMilliseconds(25), _options.
TimeProvider
, deadline.Token).ConfigureAwait(false);
584
await process.WaitForExitAsync().WaitAsync(_options.TerminationTimeout, _options.
TimeProvider
).ConfigureAwait(false);
660
if (_options.
TimeProvider
.GetElapsedTime(Interlocked.Read(ref _lastActivityTimestamp)) >= _options.OutputDrainIdleTimeout)
670
await drained.WaitAsync(s_drainPollInterval, _options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
687
private void RecordActivity() => Interlocked.Exchange(ref _lastActivityTimestamp, _options.
TimeProvider
.GetTimestamp());
Aspire.Hosting.RemoteHost.Tests (1)
IntegrationHostProcessLauncherTests.cs (1)
110
Assert.Same(clock, options.
TimeProvider
);