Exchange

102 references to Exchange

aspire (2)

Interaction\ConsoleInteractionService.cs (2)

83Interlocked.Exchange(ref _inStatus, 0); 125Interlocked.Exchange(ref _inStatus, 0);

Aspire.Dashboard (1)

ServiceClient\DashboardClient.cs (1)

790if (Interlocked.Exchange(ref _state, StateDisposed) is not StateDisposed)

Aspire.Hosting (1)

ApplicationModel\ResourceLoggerService.cs (1)

639if (Interlocked.Exchange(ref _disposed, 1) != 0)

Aspire.TestUtilities (1)

VerifyInitializer.cs (1)

21return Interlocked.Exchange(ref s_initialized, 1) == 0;

dotnet (1)

Commands\Test\MTP\TestApplication.cs (1)

45if (Interlocked.Exchange(ref _hasRun, 1) != 0)

dotnet-svcutil-lib (2)

FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\BufferedReceiveBinder.cs (2)

209Interlocked.Exchange(ref binder._pendingOperationSemaphore, 0); 251Interlocked.Exchange(ref binder._pendingOperationSemaphore, 0);

Microsoft.AspNetCore.Diagnostics.Middleware (1)

Buffering\IncomingRequestLogBuffer.cs (1)

113_ = Interlocked.Exchange(ref _activeBufferSize, 0);

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

Internal\Http\Http1ContentLengthMessageBody.cs (5)

39return new ReadResult(_readResult.Buffer, Interlocked.Exchange(ref _userCanceled, 0) == 1, isCompleted: true); 98if (!_readResult.IsCanceled || Interlocked.Exchange(ref _userCanceled, 0) == 1 || _cannotResetInputPipe) 126readResult = new ReadResult(_readResult.Buffer, Interlocked.Exchange(ref _userCanceled, 0) == 1, isCompleted: true); 146if (!_readResult.IsCanceled || Interlocked.Exchange(ref _userCanceled, 0) == 1 || _cannotResetInputPipe) 256Interlocked.Exchange(ref _userCanceled, 1);

Internal\Http\Http1UpgradeMessageBody.cs (4)

45Interlocked.Exchange(ref _userCanceled, 1); 68} while (readResult.IsCanceled && Interlocked.Exchange(ref _userCanceled, 0) == 0); 88} while (readResult.IsCanceled && Interlocked.Exchange(ref _userCanceled, 0) == 0); 99while (readResult.IsCanceled && Interlocked.Exchange(ref _userCanceled, 0) == 0)

Internal\Http2\Http2Connection.cs (2)

1437Interlocked.Exchange(ref _enhanceYourCalmCount, 0); 1863if (Interlocked.Exchange(ref _isClosed, 1) == 0)

Internal\Http3\Http3Connection.cs (1)

149if (Interlocked.Exchange(ref _stoppedAcceptingStreams, 1) == 0)

Internal\Http3\Http3ControlStream.cs (1)

123if (Interlocked.Exchange(ref _isClosed, 1) == 0)

Internal\Http3\Http3Stream.cs (1)

600if (Interlocked.Exchange(ref _isClosed, 1) == 0)

Internal\KestrelServerImpl.cs (1)

245if (Interlocked.Exchange(ref _stopping, 1) == 1)

Microsoft.Build (1)

BackEnd\BuildManager\BuildSubmission.cs (1)

109bool hasCompleted = (Interlocked.Exchange(ref CompletionInvoked, 1) == 1);

Microsoft.CodeAnalysis (2)

CodeGen\PrivateImplementationDetails.cs (1)

155var wasFrozen = Interlocked.Exchange(ref _frozen, 1);

ReferenceManager\CommonReferenceManager.State.cs (1)

449Interlocked.Exchange(ref _isBound, 1);

Microsoft.DotNet.HotReload.Watch (1)

Process\RunningProject.cs (1)

61=> Interlocked.Exchange(ref _isRestarting, 1) == 0;

Microsoft.Extensions.AI.Tests (1)

EnumeratedOnceEnumerable.cs (1)

17if (Interlocked.Exchange(ref _iterated, 1) != 0)

Microsoft.Extensions.Caching.Hybrid (1)

Internal\DefaultHybridCache.Debug.cs (1)

35=> flush ? Interlocked.Exchange(ref _outstandingBufferCount, 0) : Volatile.Read(ref _outstandingBufferCount);

Microsoft.Extensions.Diagnostics (1)

Metrics\DebugConsoleMetricListener.cs (1)

32if (instrument.IsObservable && Interlocked.Exchange(ref _timerStarted, 1) == 0)

Microsoft.Extensions.Diagnostics.ResourceMonitoring (3)

Linux\LinuxUtilizationProvider.cs (1)

338_ = Interlocked.Exchange(ref _measurementsUnavailable, 1);

Linux\Network\LinuxNetworkMetrics.cs (2)

98_ = Interlocked.Exchange(ref unavailableFlag, 0); 107_ = Interlocked.Exchange(ref unavailableFlag, 1);

Microsoft.Extensions.Diagnostics.Testing (1)

Logging\FakeLogCollector.LogEnumeration.cs (1)

193if (Interlocked.Exchange(ref _disposed, 1) == 1)

Microsoft.Extensions.FileProviders.Physical (1)

PhysicalFilesWatcher.cs (1)

1049if (Interlocked.Exchange(ref _disposed, 1) != 0)

Microsoft.Interop.JavaScript.JSImportGenerator (1)

Analyzers\JSImportExportDiagnosticsAnalyzer.cs (1)

92Interlocked.Exchange(ref foundMethod, 1);

Microsoft.Interop.LibraryImportGenerator (1)

Analyzers\LibraryImportDiagnosticsAnalyzer.cs (1)

74Interlocked.Exchange(ref foundLibraryImportMethod, 1);

Microsoft.Interop.LibraryImportGenerator.Downlevel (1)

DownlevelLibraryImportDiagnosticsAnalyzer.cs (1)

68Interlocked.Exchange(ref foundLibraryImportMethod, 1);

Microsoft.Maui (2)

Animations\Animation.cs (2)

155 if (0 == Interlocked.Exchange(ref _usingResource, 1)) 165 Interlocked.Exchange(ref _usingResource, 0);

Microsoft.Private.Windows.Core (2)

src\winforms\src\Microsoft.Private.Windows.Polyfills\System\Threading\InterlockedExtensions.cs (1)

36(uint)Interlocked.Exchange(ref Unsafe.As<uint, int>(ref location1), (int)value);

System\DisposableBase.cs (1)

27if (Interlocked.Exchange(ref _disposedValue, 1) == 1)

Microsoft.TemplateEngine.Edge (1)

BuiltInManagedProvider\GlobalSettings.cs (1)

198Interlocked.Exchange(ref _waitingInstances, 0);

PresentationFramework (1)

MS\Internal\Data\DataBindEngine.cs (1)

591Interlocked.Exchange(ref _cleanupRequests, 0);

Shared (1)

ServerSentEvents\SseParser_1.cs (1)

483if (Interlocked.Exchange(ref _used, 1) != 0)

System.Collections.Concurrent (2)

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

872Interlocked.Exchange(ref _tailIndex, --tail); 985Interlocked.Exchange(ref _headIndex, unchecked(head + 1));

System.Data.Odbc (1)

Common\System\Data\ProviderBase\DbConnectionPool.cs (1)

658Interlocked.Exchange(ref _pendingOpensWaiting, 0);

System.Data.OleDb (1)

System\Data\ProviderBase\DbConnectionPool.cs (1)

1025Interlocked.Exchange(ref _pendingOpensWaiting, 0);

System.Diagnostics.PerformanceCounter (2)

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

98if (_nativeInst != null && Interlocked.Exchange(ref _active, 0) != 0)

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

176if (Interlocked.Exchange(ref _disposed, 1) == 0)

System.IO.Pipelines (2)

System\IO\Pipelines\SequencePipeReader.cs (2)

46Interlocked.Exchange(ref _cancelNext, 1); 78bool isCancellationRequested = Interlocked.Exchange(ref _cancelNext, 0) == 1;

System.Linq.Parallel (3)

System\Linq\Parallel\Channels\AsynchronousChannel.cs (2)

305Interlocked.Exchange(ref _producerBufferIndex, (bufferIndex + 1) % _buffer.Length); 621Interlocked.Exchange(ref _consumerBufferIndex, (consumerBufferIndex + 1) % _buffer.Length);

System\Linq\Parallel\Scheduling\QueryTaskGroupState.cs (1)

89if (Interlocked.Exchange(ref _alreadyEnded, 1) == 0)

System.Net.Http (4)

System\Net\Http\SocketsHttpHandler\HttpConnection.cs (4)

139return Interlocked.Exchange(ref _readAheadTaskStatus, ReadAheadTask_CompletionReserved) == ReadAheadTask_Started; 198|| Interlocked.Exchange(ref _readAheadTaskStatus, ReadAheadTask_CompletionReserved) == ReadAheadTask_Started; 208Interlocked.Exchange(ref _readAheadTaskStatus, ReadAheadTask_Started) == ReadAheadTask_CompletionReserved) 281return Interlocked.Exchange(ref _readAheadTaskStatus, ReadAheadTask_Completed) == ReadAheadTask_Started;

System.Net.Http.WinHttpHandler (1)

System\Net\Http\WinHttpRequestState.cs (1)

199if (Interlocked.Exchange(ref _disposed, 1) != 0)

System.Net.ServerSentEvents (1)

System\Net\ServerSentEvents\SseParser_1.cs (1)

488if (Interlocked.Exchange(ref _used, 1) != 0)

System.Net.Sockets (1)

System\Net\Sockets\SocketAsyncEngine.Unix.cs (1)

245if (Interlocked.Exchange(ref _hasOutstandingThreadRequest, 1) == 0)

System.Private.CoreLib (18)

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Interlocked.cs (3)

162(uint)Exchange(ref Unsafe.As<uint, int>(ref location1), (int)value); 182=> Unsafe.BitCast<int, float>(Exchange(ref Unsafe.As<float, int>(ref location1), Unsafe.BitCast<float, int>(value))); 274Exchange(

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\LowLevelLifoSemaphore.cs (1)

365int origWake = Interlocked.Exchange(ref _pendingWake, 1);

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\PortableThreadPool.cs (1)

484Interlocked.Exchange(ref _separated._hasOutstandingThreadRequest, 1) == 0)

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\PortableThreadPool.GateThread.cs (1)

239int numRunsMask = Interlocked.Exchange(ref threadPoolInstance._separated.gateThreadRunningState, GetRunningStateForNumRuns(MaxRuns));

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\PortableThreadPool.WorkerThread.cs (1)

133Interlocked.Exchange(ref threadPoolInstance._separated._hasOutstandingThreadRequest, 0) != 0)

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\SpinLock.cs (1)

519Interlocked.Exchange(ref _owner, LOCK_UNOWNED);

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (4)

2237Interlocked.Exchange(ref m_stateFlags, m_stateFlags | completionState); 2438int prevState = Interlocked.Exchange(ref m_stateFlags, m_stateFlags | (int)TaskStateFlags.Canceled); 3454Interlocked.Exchange(ref m_stateFlags, m_stateFlags | (int)TaskStateFlags.Canceled); 7086public bool TryStart() => Interlocked.Exchange(ref _enumerated, 1) == 0;

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task_T.cs (1)

378Interlocked.Exchange(ref m_stateFlags, m_stateFlags | (int)TaskStateFlags.RanToCompletion);

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskFactory.cs (1)

2297Interlocked.Exchange(ref _stateFlags, isSyncBlockingFlag | CompletedFlag) == isSyncBlockingFlag)

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\ThreadPoolWorkQueue.cs (3)

287Interlocked.Exchange(ref m_tailIndex, tail); 353Interlocked.Exchange(ref m_headIndex, head + 1); 372Interlocked.Exchange(ref m_headIndex, head);

System\Threading\Interlocked.cs (1)

75return Exchange(ref location1, value); // Must expand intrinsic

System.Private.Windows.Core (1)

System\DisposableBase.cs (1)

27if (Interlocked.Exchange(ref _disposedValue, 1) == 1)

System.Reflection.Metadata (1)

System\Reflection\Internal\Utilities\PinnedObject.cs (1)

43if (Interlocked.Exchange(ref _isValid, 0) != 0)

System.Runtime.Caching (11)

System\Runtime\Caching\CacheExpires.cs (2)

799if (Interlocked.Exchange(ref _inFlush, 1) == 0) 821Interlocked.Exchange(ref _inFlush, 0);

System\Runtime\Caching\CacheUsage.cs (2)

877if (Interlocked.Exchange(ref _inFlush, 1) == 0) 902Interlocked.Exchange(ref _inFlush, 0);

System\Runtime\Caching\MemoryCache.cs (1)

437if (Interlocked.Exchange(ref _disposed, 1) == 0)

System\Runtime\Caching\MemoryCacheStatistics.cs (5)

271if (Interlocked.Exchange(ref _inCacheManagerThread, 1) != 0) 331Interlocked.Exchange(ref _inCacheManagerThread, 0); 337if (Interlocked.Exchange(ref _disposed, 1) == 0) 385while (Interlocked.Exchange(ref _inCacheManagerThread, 1) != 0) 406Interlocked.Exchange(ref _inCacheManagerThread, 0);

System\Runtime\Caching\MemoryCacheStore.cs (1)

254if (Interlocked.Exchange(ref _disposed, 1) == 0)

System.ServiceModel.Primitives (2)

System\ServiceModel\Dispatcher\BufferedReceiveBinder.cs (2)

205Interlocked.Exchange(ref binder._pendingOperationSemaphore, 0); 247Interlocked.Exchange(ref binder._pendingOperationSemaphore, 0);

System.Transactions.Local (3)

System\Transactions\CommittableTransaction.cs (1)

128if (Interlocked.Exchange(ref _disposed, Transaction._disposedTrueValue) == Transaction._disposedTrueValue)

System\Transactions\Oletx\OletxDependentTransaction.cs (1)

43int localCompleted = Interlocked.Exchange(ref _completed, 1);

System\Transactions\Transaction.cs (1)

828if (Interlocked.Exchange(ref _disposed, Transaction._disposedTrueValue) == Transaction._disposedTrueValue)

System.Windows.Forms (2)

System\Windows\Forms\Application.ThreadContext.cs (1)

265if (Interlocked.Exchange(ref _disposed, 1) == 1)

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

189Interlocked.Exchange(ref _currentDesktopChangedCount, DesktopChangedCount);