src\Shared\ChildProcess.cs (11)
63_lastActivityTimestamp = options.TimeProvider.GetTimestamp();
337_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false);
372_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false);
380await signalTask.WaitAsync(_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false);
433await process.WaitForExitAsync().WaitAsync(_options.TerminationTimeout, _options.TimeProvider).ConfigureAwait(false);
437using var deadline = new CancellationTokenSource(_options.TerminationTimeout, _options.TimeProvider);
442await Task.Delay(TimeSpan.FromMilliseconds(25), _options.TimeProvider, deadline.Token).ConfigureAwait(false);
588await process.WaitForExitAsync().WaitAsync(_options.TerminationTimeout, _options.TimeProvider).ConfigureAwait(false);
664if (_options.TimeProvider.GetElapsedTime(Interlocked.Read(ref _lastActivityTimestamp)) >= _options.OutputDrainIdleTimeout)
674await drained.WaitAsync(s_drainPollInterval, _options.TimeProvider, cancellationToken).ConfigureAwait(false);
691private void RecordActivity() => Interlocked.Exchange(ref _lastActivityTimestamp, _options.TimeProvider.GetTimestamp());