2 writes to TimeProvider
Aspire.Cli.Tests (2)
tests\Shared\Processes\ChildProcessTests.cs (2)
40TimeProvider = new FakeTimeProvider(), 71TimeProvider = clock,
11 references to TimeProvider
aspire (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); 376await signalTask.WaitAsync(_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false); 429await process.WaitForExitAsync().WaitAsync(_options.TerminationTimeout, _options.TimeProvider).ConfigureAwait(false); 433using var deadline = new CancellationTokenSource(_options.TerminationTimeout, _options.TimeProvider); 438await Task.Delay(TimeSpan.FromMilliseconds(25), _options.TimeProvider, deadline.Token).ConfigureAwait(false); 584await process.WaitForExitAsync().WaitAsync(_options.TerminationTimeout, _options.TimeProvider).ConfigureAwait(false); 660if (_options.TimeProvider.GetElapsedTime(Interlocked.Read(ref _lastActivityTimestamp)) >= _options.OutputDrainIdleTimeout) 670await drained.WaitAsync(s_drainPollInterval, _options.TimeProvider, cancellationToken).ConfigureAwait(false); 687private void RecordActivity() => Interlocked.Exchange(ref _lastActivityTimestamp, _options.TimeProvider.GetTimestamp());