8 writes to TimeProvider
Aspire.Hosting.Native.Core.Tests (7)
DeclarativeApplicationTests.cs (1)
307
TimeProvider
= clock,
NativeTimeProviderTests.cs (6)
76
new NativeRuntimeOptions {
TimeProvider
= clock });
101
var invitations = new RuntimeInvitations(UnavailableWorkloadExecutor.Instance, new NativeRuntimeOptions {
TimeProvider
= clock });
126
new NativeRuntimeOptions {
TimeProvider
= clock, WorkloadStartupTimeout = TimeSpan.FromSeconds(2) });
164
new NativeRuntimeOptions {
TimeProvider
= clock, WorkloadStartupTimeout = TimeSpan.FromSeconds(2) });
204
new NativeRuntimeOptions {
TimeProvider
= clock, WorkloadStartupTimeout = TimeSpan.FromSeconds(2) });
230
new NativeRuntimeOptions {
TimeProvider
= clock, ObservationInterval = TimeSpan.FromSeconds(1) });
Aspire.Hosting.Native.Server (1)
NativeServerOptions.cs (1)
56
Runtime.
TimeProvider
= TimeProvider;
28 references to TimeProvider
Aspire.Hosting.Native.Core (17)
Runtime\DeclarativeApplication.cs (5)
60
.WaitAsync(TimeSpan.FromMilliseconds(timeoutMilliseconds), options.
TimeProvider
);
66
using var deadline = new CancellationTokenSource(TimeSpan.FromMilliseconds(timeoutMilliseconds), options.
TimeProvider
);
291
await Task.Delay(options.ObservationInterval, options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
311
using var deadline = new CancellationTokenSource(options.WorkloadStartupTimeout, options.
TimeProvider
);
394
await Task.Delay(options.ObservationInterval, options.
TimeProvider
, cancellationToken).ConfigureAwait(false);
Runtime\NativeRuntimeOptions.cs (1)
18
ArgumentNullException.ThrowIfNull(
TimeProvider
);
Runtime\ResourceWorkload.cs (5)
257
using var operation = new NativeDiagnostics.Operation("runtime.workload", null, identity.GenerationId, options.
TimeProvider
);
264
using var allocation = new TimeProviderCancellation(options.WorkloadStartupTimeout, options.
TimeProvider
, _lifetime.Token);
271
using var values = new TimeProviderCancellation(options.WorkloadStartupTimeout, options.
TimeProvider
, _lifetime.Token);
277
using var startup = new TimeProviderCancellation(options.WorkloadStartupTimeout, options.
TimeProvider
, _lifetime.Token);
308
await Task.Delay(options.ObservationInterval, options.
TimeProvider
, _lifetime.Token).ConfigureAwait(false);
Runtime\RuntimeGeneration.cs (6)
213
using var timeout = new CancellationTokenSource(TimeSpan.FromMilliseconds(timeoutMilliseconds), options.
TimeProvider
);
609
public DateTimeOffset CreatedAt { get; } = options.
TimeProvider
.GetUtcNow();
684
await Task.WhenAny(changed, Task.Delay(TimeSpan.FromMilliseconds(timeoutMilliseconds), options.
TimeProvider
, delayCancellation.Token)).ConfigureAwait(false);
796
}, options.
TimeProvider
);
816
resource.Logs.Enqueue(new RuntimeLogEntry(++resource.LogSequence, options.
TimeProvider
.GetUtcNow(), stream, Redact(message)));
874
await Task.WhenAny(changed, Task.Delay(TimeSpan.FromMilliseconds(timeoutMilliseconds), options.
TimeProvider
, delayCancellation.Token)).ConfigureAwait(false);
Aspire.Hosting.Native.Core.Tests (1)
NativeTimeProviderTests.cs (1)
27
Assert.Same(clock, options.Runtime.
TimeProvider
);
Aspire.Hosting.Native.Server (10)
Api\ApplicationWorkspace.cs (2)
50
_pending = new Composition(_owner, new ApplicationModel(invitations.Options.
TimeProvider
)) { Workspace = this };
87
using var operation = new NativeDiagnostics.Operation("runtime.revision.commit", null, revision.Model.GenerationId, invitations.Options.
TimeProvider
);
Api\CompositionApi.cs (1)
35
_session = new ApplicationSession(invitations.Options.
TimeProvider
);
Api\RuntimeApi.cs (3)
499
_pending.Add(token, new Invitation<T>(execution, create, Options.
TimeProvider
.GetTimestamp()));
547
var now = Options.
TimeProvider
.GetTimestamp();
550
if (invitation.Execution.IsRevoked || Options.
TimeProvider
.GetElapsedTime(invitation.Created, now) >= TimeSpan.FromMinutes(1))
Dashboard\NativeDashboardService.cs (4)
83
await Task.Delay(options.ObservationInterval, options.
TimeProvider
, context.CancellationToken).ConfigureAwait(false);
130
await Task.Delay(options.ObservationInterval, options.
TimeProvider
, context.CancellationToken).ConfigureAwait(false);
270
await Task.Delay(options.ObservationInterval, options.
TimeProvider
, lifetime.Token).ConfigureAwait(false);
287
await Task.Delay(Timeout.InfiniteTimeSpan, options.
TimeProvider
, context.CancellationToken).ConfigureAwait(false);