1 write to _timeProvider
Aspire.Hosting.RemoteHost (1)
Ats\ExternalCapabilityRegistry.cs (1)
74
_timeProvider
= timeProvider;
15 references to _timeProvider
Aspire.Hosting.RemoteHost (15)
Ats\ExternalCapabilityRegistry.cs (15)
191
.WaitAsync(timeoutPerHost,
_timeProvider
, cancellationToken).ConfigureAwait(false);
237
var started =
_timeProvider
.GetTimestamp();
246
.WaitAsync(timeoutPerHost,
_timeProvider
, cancellationToken).ConfigureAwait(false);
284
packageName, host.GetHashCode(),
_timeProvider
.GetElapsedTime(started), timeoutPerHost);
334
.WaitAsync(timeout,
_timeProvider
, discoveryCancellation.Token).ConfigureAwait(false);
466
var started =
_timeProvider
.GetTimestamp();
483
invocationCancellation.Token).WaitAsync(_invocationTimeout,
_timeProvider
, invocationCancellation.Token).ConfigureAwait(false);
517
invocationId, capabilityId, registration.ClientRpc.GetHashCode(),
_timeProvider
.GetElapsedTime(started), _invocationTimeout);
528
invocationId, capabilityId, registration.ClientRpc.GetHashCode(),
_timeProvider
.GetElapsedTime(started));
534
invocationId, capabilityId, registration.ClientRpc.GetHashCode(),
_timeProvider
.GetElapsedTime(started));
540
invocationId, capabilityId, registration.ClientRpc.GetHashCode(),
_timeProvider
.GetElapsedTime(started));
561
var started =
_timeProvider
.GetTimestamp();
578
callbackId, owner.InvocationId, owner.CapabilityId, host.GetHashCode(),
_timeProvider
.GetElapsedTime(started), _callbackTimeout);
587
callbackId, owner.InvocationId, owner.CapabilityId, host.GetHashCode(),
_timeProvider
.GetElapsedTime(started));
594
callbackId, owner.InvocationId, owner.CapabilityId, host.GetHashCode(),
_timeProvider
.GetElapsedTime(started));