9 writes to TimeProvider
Aspire.Hosting.Native.Core.Tests (9)
DcpWorkloadCleanupTests.cs (1)
129
var options = new NativeServerOptions {
TimeProvider
= clock, CleanupTimeout = TimeSpan.FromSeconds(2) };
NativeAuxiliaryBackchannelTests.cs (1)
27
var options = new NativeServerOptions {
TimeProvider
= clock, MaximumConnections = 2 };
NativeCliProtocolTests.cs (1)
101
var options = new NativeServerOptions {
TimeProvider
= clock, MaximumConnections = 2 };
NativeProviderClientTests.cs (1)
414
TimeProvider
= clock,
NativeProviderLifecycleTests.cs (1)
454
TimeProvider
= clock,
NativeRpcAuthoringTests.cs (1)
148
TimeProvider
= clock,
NativeSocketIsolationTests.cs (1)
27
var options = new NativeServerOptions {
TimeProvider
= clock };
NativeTimeProviderTests.cs (2)
24
var options = new NativeServerOptions {
TimeProvider
= clock };
265
TimeProvider
= clock, ControllerRequestTimeout = TimeSpan.FromSeconds(2),
49 references to TimeProvider
Aspire.Hosting.Native.Server (49)
Auxiliary\NativeAuxiliaryBackchannel.cs (5)
271
await Task.Delay(_options.RetryInterval, _options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
295
await Task.Delay(_options.RetryInterval, _options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
353
await Task.Delay(_options.RetryInterval, _options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
442
using var timeout = new CancellationTokenSource(TimeSpan.FromSeconds(request.TimeoutSeconds), _options.
TimeProvider
);
470
await Task.Delay(_options.RetryInterval, _options.
TimeProvider
, lifetime.Token).ConfigureAwait(false);
Cli\NativeCliProtocol.cs (1)
136
await Task.Delay(_options.RetryInterval, _options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
Dashboard\DcpDashboard.cs (2)
68
using var requestTimeout = new TimeProviderCancellation(options.ControllerRequestTimeout, options.
TimeProvider
, cancellationToken);
93
await Task.Delay(options.RetryInterval, options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
Dashboard\NativeDashboardHost.cs (1)
102
using var timeout = new CancellationTokenSource(_options.DashboardShutdownTimeout, _options.
TimeProvider
);
Dcp\DcpApiClient.cs (9)
90
using var operation = new NativeDiagnostics.Operation("dcp.connection.ready", null, null, _options.
TimeProvider
);
95
_options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
139
await Task.Delay(_options.RetryInterval, _options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
145
using var timeout = new TimeProviderCancellation(_options.ControllerLogReadTimeout, _options.
TimeProvider
, cancellationToken);
181
using var timeout = new TimeProviderCancellation(_options.ControllerRequestTimeout, _options.
TimeProvider
, cancellationToken);
223
await Task.Delay(_options.RetryInterval, _options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
229
using var cleanup = new CancellationTokenSource(_options.CleanupTimeout, _options.
TimeProvider
);
257
using var forcedExit = new CancellationTokenSource(_options.CleanupTimeout, _options.
TimeProvider
);
262
await _output.WaitAsync(_options.CleanupTimeout, _options.
TimeProvider
).ConfigureAwait(false);
Dcp\DcpWorkloadExecutor.cs (3)
75
await Task.Delay(options.RetryInterval, options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
211
await Task.Delay(options.RetryInterval, options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
287
using var cleanup = new CancellationTokenSource(options.CleanupTimeout, options.
TimeProvider
);
NativeDiagnosticPump.cs (1)
44
await _consumer.WaitAsync(_options.CleanupTimeout, _options.
TimeProvider
).ConfigureAwait(false);
NativeServerHostedService.cs (9)
30
await lifetime.RequestStopAsync(settings.Options.CleanupTimeout, settings.Options.
TimeProvider
,
52
}, settings.Options.
TimeProvider
);
94
using var startup = new TimeProviderCancellation(options.ControllerStartupTimeout, options.
TimeProvider
, shutdown.Token);
215
using var cleanup = new CancellationTokenSource(options.CleanupTimeout, options.
TimeProvider
);
238
await Task.Delay(options.RetryInterval, options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
246
await Task.Delay(Timeout.InfiniteTimeSpan, options.
TimeProvider
, shutdown.Token).ConfigureAwait(false);
254
using var cleanup = new CancellationTokenSource(options.CleanupTimeout, options.
TimeProvider
);
262
await Task.Delay(Timeout.InfiniteTimeSpan, options.
TimeProvider
, shutdown.Token).ConfigureAwait(false);
271
using var cleanup = new CancellationTokenSource(options.CleanupTimeout, options.
TimeProvider
);
NativeServerOptions.cs (2)
55
ArgumentNullException.ThrowIfNull(
TimeProvider
);
56
Runtime.TimeProvider =
TimeProvider
;
Program.cs (1)
34
builder.Services.AddSingleton(settings.Options.
TimeProvider
);
Rpc\NativeBackchannelRpc.cs (2)
25
using var firstRequest = new TimeProviderCancellation(options.BackchannelFirstRequestTimeout, options.
TimeProvider
, cancellationToken);
168
using var operation = new NativeDiagnostics.Operation("backchannel.request", null, null, options.
TimeProvider
)
Rpc\NativeProviderLifecycle.cs (3)
75
using var deadline = new CancellationTokenSource(options.ProviderInvocationTimeout, options.
TimeProvider
);
91
using var cancelDeadline = new CancellationTokenSource(options.ProviderInvocationTimeout, options.
TimeProvider
);
143
using var deadline = new CancellationTokenSource(options.ProviderInvocationTimeout, options.
TimeProvider
);
Rpc\NativeProviderRegistry.cs (5)
46
if (options.
TimeProvider
.GetElapsedTime(expectation.Created) >= options.ProviderRegistrationTimeout)
58
var pending = new Expectation(owner, packageName, options.
TimeProvider
.GetTimestamp());
75
options.
TimeProvider
.GetElapsedTime(expected.Created) >= options.ProviderRegistrationTimeout)
82
using var deadline = new CancellationTokenSource(options.ProviderRegistrationTimeout, options.
TimeProvider
);
133
await expected.Completion.Task.WaitAsync(options.ProviderRegistrationTimeout, options.
TimeProvider
, owner.Closed).ConfigureAwait(false);
Rpc\NativeRpcConnection.cs (3)
193
using var deadline = new CancellationTokenSource(_options.ProviderInvocationTimeout, _options.
TimeProvider
);
322
using var operation = new NativeDiagnostics.Operation("rpc.request", null, null, _options.
TimeProvider
);
476
using var operation = new NativeDiagnostics.Operation("rpc.request", null, null, _options.
TimeProvider
);
Rpc\NativeRpcListener.cs (1)
191
_options.AuthenticationTimeout, _options.
TimeProvider
, cancellationToken);
Rpc\NativeRpcPeer.cs (1)
40
using var deadline = new CancellationTokenSource(options.ProviderInvocationTimeout, options.
TimeProvider
);