66 references to Read
Aspire.Microsoft.Data.SqlClient (1)
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Shared\DiagnosticSourceInstrumentation\DiagnosticSourceSubscriber.cs (1)
54if ((Interlocked.Read(ref this.disposed) == 0) &&
Aspire.Microsoft.EntityFrameworkCore.SqlServer (1)
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Shared\DiagnosticSourceInstrumentation\DiagnosticSourceSubscriber.cs (1)
54if ((Interlocked.Read(ref this.disposed) == 0) &&
BasicWebSite (1)
ActionDescriptorCreationCounter.cs (1)
16var callCount = Interlocked.Read(ref _callCount);
Client.ExpectedExceptions.IntegrationTests (2)
ExpectedExceptionTests.4.0.0.cs (1)
281if (Interlocked.Read(ref operationsQueued) >= operationCount)
ExpectedExceptionTests.4.1.0.cs (1)
535if (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;
TypeLoader.cs (2)
350if (Interlocked.Read(ref _haveScannedPublicTypes) == 0) 354if (Interlocked.Read(ref _haveScannedPublicTypes) == 0)
MSBuild (2)
TypeLoader.cs (2)
350if (Interlocked.Read(ref _haveScannedPublicTypes) == 0) 354if (Interlocked.Read(ref _haveScannedPublicTypes) == 0)
MSBuildTaskHost (2)
TypeLoader.cs (2)
262if (Interlocked.Read(ref _haveScannedPublicTypes) == 0) 266if (Interlocked.Read(ref _haveScannedPublicTypes) == 0)
System.Collections.Concurrent (2)
System\Collections\Concurrent\ConcurrentBag.cs (2)
207long initialEmptyToNonEmptyCounts = Interlocked.Read(ref _emptyToNonEmptyListTransitionCount); 227if (Interlocked.Read(ref _emptyToNonEmptyListTransitionCount) == initialEmptyToNonEmptyCounts)
System.Diagnostics.DiagnosticSource (1)
System\Diagnostics\RateLimiter.cs (1)
45long intervalStartTicks = Interlocked.Read(ref _intervalStartTicks);
System.Diagnostics.Process (1)
System\Diagnostics\Process.Linux.cs (1)
87long 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)
2113if (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)
53_tlsHandshakeRateCounter ??= new IncrementingPollingCounter("tls-handshake-rate", this, () => Interlocked.Read(ref _finishedTlsHandshakes)) 59_totalTlsHandshakesCounter ??= new PollingCounter("total-tls-handshakes", this, () => Interlocked.Read(ref _finishedTlsHandshakes)) 64_currentTlsHandshakesCounter ??= new PollingCounter("current-tls-handshakes", this, () => -Interlocked.Read(ref _finishedTlsHandshakes) + Interlocked.Read(ref _startedTlsHandshakes)) 69_failedTlsHandshakesCounter ??= new PollingCounter("failed-tls-handshakes", this, () => Interlocked.Read(ref _failedTlsHandshakes)) 74_sessionsOpenCounter ??= new PollingCounter("all-tls-sessions-open", this, () => Interlocked.Read(ref _sessionsOpen)) 79_sessionsOpenTls10Counter ??= new PollingCounter("tls10-sessions-open", this, () => Interlocked.Read(ref _sessionsOpenTls10)) 84_sessionsOpenTls11Counter ??= new PollingCounter("tls11-sessions-open", this, () => Interlocked.Read(ref _sessionsOpenTls11)) 89_sessionsOpenTls12Counter ??= new PollingCounter("tls12-sessions-open", this, () => Interlocked.Read(ref _sessionsOpenTls12)) 94_sessionsOpenTls13Counter ??= new PollingCounter("tls13-sessions-open", this, () => Interlocked.Read(ref _sessionsOpenTls13))
System.Net.Sockets (7)
System\Net\Sockets\SocketsTelemetry.cs (7)
266_currentOutgoingConnectAttemptsCounter ??= new PollingCounter("current-outgoing-connect-attempts", this, () => Interlocked.Read(ref _currentOutgoingConnectAttempts)) 270_outgoingConnectionsEstablishedCounter ??= new PollingCounter("outgoing-connections-established", this, () => Interlocked.Read(ref _outgoingConnectionsEstablished)) 274_incomingConnectionsEstablishedCounter ??= new PollingCounter("incoming-connections-established", this, () => Interlocked.Read(ref _incomingConnectionsEstablished)) 278_bytesReceivedCounter ??= new PollingCounter("bytes-received", this, () => Interlocked.Read(ref _bytesReceived)) 282_bytesSentCounter ??= new PollingCounter("bytes-sent", this, () => Interlocked.Read(ref _bytesSent)) 286_datagramsReceivedCounter ??= new PollingCounter("datagrams-received", this, () => Interlocked.Read(ref _datagramsReceived)) 290_datagramsSentCounter ??= new PollingCounter("datagrams-sent", this, () => Interlocked.Read(ref _datagramsSent))
System.Threading.RateLimiting (9)
System\Threading\RateLimiting\ConcurrencyLimiter.cs (2)
70TotalFailedLeases = Interlocked.Read(ref _failedLeasesCount), 71TotalSuccessfulLeases = Interlocked.Read(ref _successfulLeasesCount),
System\Threading\RateLimiting\FixedWindowRateLimiter.cs (2)
90TotalFailedLeases = Interlocked.Read(ref _failedLeasesCount), 91TotalSuccessfulLeases = Interlocked.Read(ref _successfulLeasesCount),
System\Threading\RateLimiting\NoopLimiter.cs (1)
26TotalSuccessfulLeases = Interlocked.Read(ref _totalSuccessfulLeases)
System\Threading\RateLimiting\SlidingWindowRateLimiter.cs (2)
104TotalFailedLeases = Interlocked.Read(ref _failedLeasesCount), 105TotalSuccessfulLeases = Interlocked.Read(ref _successfulLeasesCount),
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (2)
98TotalFailedLeases = Interlocked.Read(ref _failedLeasesCount), 99TotalSuccessfulLeases = Interlocked.Read(ref _successfulLeasesCount),
System.Transactions.Local (5)
System\Transactions\TransactionManager.cs (5)
305if (Interlocked.Read(ref s_defaultTimeoutTicks) != DefaultSettingsSection.Timeout.Ticks) 318return new TimeSpan(Interlocked.Read(ref s_defaultTimeoutTicks)); 329if (Interlocked.Read(ref s_defaultTimeoutTicks) != value.Ticks) 382long defaultTimeoutTicks = Interlocked.Read(ref s_defaultTimeoutTicks); 384if (Interlocked.Read(ref s_defaultTimeoutTicks) != defaultTimeoutTicks)