Read

70 references to Read

aspire (1)

src\Shared\ChildProcess.cs (1)

660if (_options.TimeProvider.GetElapsedTime(Interlocked.Read(ref _lastActivityTimestamp)) >= _options.OutputDrainIdleTimeout)

Aspire.Dashboard (1)

src\Shared\ChildProcess.cs (1)

660if (_options.TimeProvider.GetElapsedTime(Interlocked.Read(ref _lastActivityTimestamp)) >= _options.OutputDrainIdleTimeout)

Aspire.Hosting.RemoteHost (1)

src\Shared\ChildProcess.cs (1)

660if (_options.TimeProvider.GetElapsedTime(Interlocked.Read(ref _lastActivityTimestamp)) >= _options.OutputDrainIdleTimeout)

Aspire.Hosting.Tests (1)

Dcp\KubernetesServiceTests.cs (1)

2530var responseDelayTicks = Interlocked.Read(ref responseState.ResponseDelayTicks);

Client.ExpectedExceptions.IntegrationTests (2)

ExpectedExceptionTests.4.0.0.cs (1)

281if (Interlocked.Read(ref operationsQueued) >= operationCount)

ExpectedExceptionTests.4.1.0.cs (1)

531if (Interlocked.Read(ref operationsQueued) >= operationCount)

Microsoft.AspNetCore.Server.Kestrel.Core (5)

Internal\Http3\Http3Connection.cs (1)

92private long GetCurrentGoAwayStreamId() => Interlocked.Read(ref _highestOpenedRequestStreamId) + 4;

Internal\Infrastructure\TimeoutControl.cs (4)

64if (timestamp > Interlocked.Read(ref _timeoutTimestamp)) 80if (Interlocked.Read(ref _timeoutTimestamp) != long.MaxValue) 192Interlocked.Exchange(ref _timeoutTimestamp, Interlocked.Read(ref _lastTimestamp) + timeoutTicks + _heartbeatIntervalTicks); 289var currentTimeUpperBound = Interlocked.Read(ref _lastTimestamp) + _heartbeatIntervalTicks;

Microsoft.Build (4)

Graph\ParallelWorkSet.cs (2)

139while (!_cancellationToken.IsCancellationRequested && Interlocked.Read(ref _pendingCount) > 0) 178shouldStopAllWorkers = Interlocked.Read(ref _pendingCount) == 0 && IsCompleted;

parent\Shared\TypeLoader.cs (2)

780if (Interlocked.Read(ref _haveScannedPublicTypes) == 0) 784if (Interlocked.Read(ref _haveScannedPublicTypes) == 0)

Microsoft.Extensions.Caching.Memory (1)

MemoryCache.cs (1)

409TotalEvictions = Interlocked.Read(ref _accumulatedEvictions)

MSBuild (2)

parent\Shared\TypeLoader.cs (2)

780if (Interlocked.Read(ref _haveScannedPublicTypes) == 0) 784if (Interlocked.Read(ref _haveScannedPublicTypes) == 0)

System.Collections.Concurrent (2)

System\Collections\Concurrent\ConcurrentBag.cs (2)

207long initialEmptyToNonEmptyCounts = Interlocked.Read(ref _emptyToNonEmptyListTransitionCount); 221if (Interlocked.Read(ref _emptyToNonEmptyListTransitionCount) == initialEmptyToNonEmptyCounts)

System.Diagnostics.DiagnosticSource (1)

System\Diagnostics\RateLimiter.cs (1)

45long intervalStartTicks = Interlocked.Read(ref _intervalStartTicks);

System.Diagnostics.PerformanceCounter (1)

System\Diagnostics\PerformanceData\CounterSetInstanceCounterDataSet.cs (1)

38return Interlocked.Read(ref (*_offset));

System.Diagnostics.Process (1)

System\Diagnostics\Process.Linux.cs (1)

49long bootTimeTicks = Interlocked.Read(ref s_bootTimeTicks);

System.Net.Http (11)

System\Net\Http\HttpTelemetry.AnyOS.cs (9)

51_startedRequestsCounter ??= new PollingCounter("requests-started", this, () => Interlocked.Read(ref _startedRequests)) 57_startedRequestsPerSecondCounter ??= new IncrementingPollingCounter("requests-started-rate", this, () => Interlocked.Read(ref _startedRequests)) 67_failedRequestsCounter ??= new PollingCounter("requests-failed", this, () => Interlocked.Read(ref _failedRequests)) 73_failedRequestsPerSecondCounter ??= new IncrementingPollingCounter("requests-failed-rate", this, () => Interlocked.Read(ref _failedRequests)) 82_currentRequestsCounter ??= new PollingCounter("current-requests", this, () => -Interlocked.Read(ref _stoppedRequests) + Interlocked.Read(ref _startedRequests)) 87_totalHttp11ConnectionsCounter ??= new PollingCounter("http11-connections-current-total", this, () => Interlocked.Read(ref _openedHttp11Connections)) 92_totalHttp20ConnectionsCounter ??= new PollingCounter("http20-connections-current-total", this, () => Interlocked.Read(ref _openedHttp20Connections)) 97_totalHttp30ConnectionsCounter ??= new PollingCounter("http30-connections-current-total", this, () => Interlocked.Read(ref _openedHttp30Connections))

System\Net\Http\SocketsHttpHandler\FailedProxyCache.cs (1)

96if (_failedProxies.Count > LargeProxyConfigBoundary && Environment.TickCount64 >= Interlocked.Read(ref _nextFlushTicks))

System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)

2225if (Interlocked.Read(ref _keepAlivePingPayload) != payload)

System.Net.NameResolution (2)

System\Net\NameResolutionTelemetry.cs (2)

33_lookupsRequestedCounter ??= new PollingCounter("dns-lookups-requested", this, () => Interlocked.Read(ref _lookupsRequested)) 39_currentLookupsCounter ??= new PollingCounter("current-dns-lookups", this, () => Interlocked.Read(ref _currentLookups))

System.Net.Security (10)

System\Net\Security\NetSecurityTelemetry.cs (10)

System.Net.Sockets (7)

System\Net\Sockets\SocketsTelemetry.cs (7)

273_currentOutgoingConnectAttemptsCounter ??= new PollingCounter("current-outgoing-connect-attempts", this, () => Interlocked.Read(ref _currentOutgoingConnectAttempts)) 277_outgoingConnectionsEstablishedCounter ??= new PollingCounter("outgoing-connections-established", this, () => Interlocked.Read(ref _outgoingConnectionsEstablished)) 281_incomingConnectionsEstablishedCounter ??= new PollingCounter("incoming-connections-established", this, () => Interlocked.Read(ref _incomingConnectionsEstablished)) 285_bytesReceivedCounter ??= new PollingCounter("bytes-received", this, () => Interlocked.Read(ref _bytesReceived)) 289_bytesSentCounter ??= new PollingCounter("bytes-sent", this, () => Interlocked.Read(ref _bytesSent)) 293_datagramsReceivedCounter ??= new PollingCounter("datagrams-received", this, () => Interlocked.Read(ref _datagramsReceived)) 297_datagramsSentCounter ??= new PollingCounter("datagrams-sent", this, () => Interlocked.Read(ref _datagramsSent))

System.Runtime.Caching (7)

System\Runtime\Caching\Counters.cs (7)

74_counters[(int)CounterName.Entries] = CreatePollingCounter("entries", "Cache Entries", () => Interlocked.Read(ref _counterValues.Entries)); 75_counters[(int)CounterName.Hits] = CreatePollingCounter("hits", "Cache Hits", () => Interlocked.Read(ref _counterValues.Hits)); 76_counters[(int)CounterName.Misses] = CreatePollingCounter("misses", "Cache Misses", () => Interlocked.Read(ref _counterValues.Misses)); 77_counters[(int)CounterName.Trims] = CreatePollingCounter("trims", "Cache Trims", () => Interlocked.Read(ref _counterValues.Trims)); 80() => Interlocked.Read(ref _counterValues.Turnover)) 96double hits = Interlocked.Read(ref _counterValues.Hits); 97return (hits / (hits + Interlocked.Read(ref _counterValues.Misses))) * 100d;

System.Threading.RateLimiting (7)

System\Threading\RateLimiting\ConcurrencyLimiter.cs (2)

70TotalFailedLeases = Interlocked.Read(ref _failedLeasesCount), 71TotalSuccessfulLeases = Interlocked.Read(ref _successfulLeasesCount),

System\Threading\RateLimiting\NoopLimiter.cs (1)

26TotalSuccessfulLeases = Interlocked.Read(ref _totalSuccessfulLeases)

System\Threading\RateLimiting\SlidingWindowRateLimiter.cs (2)

111TotalFailedLeases = Interlocked.Read(ref _failedLeasesCount), 112TotalSuccessfulLeases = Interlocked.Read(ref _successfulLeasesCount),

System\Threading\RateLimiting\TokenBucketRateLimiter.cs (2)

98TotalFailedLeases = Interlocked.Read(ref _failedLeasesCount), 99TotalSuccessfulLeases = Interlocked.Read(ref _successfulLeasesCount),

System.Transactions.Local (2)

System\Transactions\TransactionManager.cs (2)

292return new TimeSpan(Interlocked.Read(ref s_defaultTimeoutTicks)); 336return new TimeSpan(Interlocked.Read(ref s_maximumTimeoutTicks));

System.Windows.Forms (1)

System\Windows\Forms\SystemVisualSettingsTracker.cs (1)

31=> Interlocked.Read(ref s_transitionVersion);