1 write to _options
Aspire.Dashboard (1)
src\Shared\ChildProcess.cs (1)
54
_options
= options;
36 references to _options
Aspire.Dashboard (36)
src\Shared\ChildProcess.cs (36)
122
if (
_options
.Lifetime == ChildProcessLifetime.OwnedTree)
124
_completionPath =
_options
.CompletionPath;
130
startInfo =
_options
.CreateSupervisorStartInfo(_startInfo, _completionPath,
_options
.TerminationTimeout);
140
if (
_options
.Detached)
168
if (!
_options
.Detached && (startInfo.RedirectStandardOutput || startInfo.RedirectStandardError))
328
if (
_options
.RequestGracefulShutdownAsync is { } requestShutdown
329
&&
_options
.BeginGracefulShutdown?.Invoke() is { } gracefulToken)
337
_options
.TerminationTimeout,
_options
.TimeProvider, CancellationToken.None).ConfigureAwait(false);
368
&&
_options
.Lifetime == ChildProcessLifetime.AppHost
369
&& !
_options
.KillEntireProcessTreeOnCancel;
372
_options
.TerminationTimeout,
_options
.TimeProvider, CancellationToken.None).ConfigureAwait(false);
380
await signalTask.WaitAsync(
_options
.TerminationTimeout,
_options
.TimeProvider, CancellationToken.None).ConfigureAwait(false);
385
FileName, _processId,
_options
.TerminationTimeout);
433
await process.WaitForExitAsync().WaitAsync(
_options
.TerminationTimeout,
_options
.TimeProvider).ConfigureAwait(false);
437
using var deadline = new CancellationTokenSource(
_options
.TerminationTimeout,
_options
.TimeProvider);
442
await Task.Delay(TimeSpan.FromMilliseconds(25),
_options
.TimeProvider, deadline.Token).ConfigureAwait(false);
447
throw new TimeoutException($"Process group {_processId} still exists after cleanup timeout {
_options
.TerminationTimeout}.", ex);
454
FileName, _processId,
_options
.TerminationTimeout);
505
var entireProcessTree =
_options
.KillEntireProcessTreeOnCancel;
578
if (
_options
.Lifetime == ChildProcessLifetime.OwnedTree && !process.HasExited)
588
await process.WaitForExitAsync().WaitAsync(
_options
.TerminationTimeout,
_options
.TimeProvider).ConfigureAwait(false);
593
FileName, _processId,
_options
.TerminationTimeout);
619
_options
.StandardOutputCallback?.Invoke(line);
632
_options
.StandardErrorCallback?.Invoke(line);
664
if (
_options
.TimeProvider.GetElapsedTime(Interlocked.Read(ref _lastActivityTimestamp)) >=
_options
.OutputDrainIdleTimeout)
667
FileName, _processId,
_options
.OutputDrainIdleTimeout);
674
await drained.WaitAsync(s_drainPollInterval,
_options
.TimeProvider, cancellationToken).ConfigureAwait(false);
691
private void RecordActivity() => Interlocked.Exchange(ref _lastActivityTimestamp,
_options
.TimeProvider.GetTimestamp());