15 references to CancellationState
System.Core (15)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
79m_channelEnumerator = ExceptionAggregator.WrapQueryEnumerator(partitions[0], m_taskGroupState.CancellationState).GetEnumerator();
System\Linq\Parallel\Merging\MergeEnumerator.cs (1)
72Contract.Assert(m_taskGroupState.CancellationState.TopLevelDisposedFlag.Value);
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
353if (m_mergeHelper.m_taskGroupState.CancellationState.MergedCancellationToken.IsCancellationRequested)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (1)
102CancellationToken cancelToken = m_taskGroupState.CancellationState.MergedCancellationToken;
System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (1)
141if (!m_groupState.CancellationState.MergedCancellationToken.IsCancellationRequested)
System\Linq\Parallel\Scheduling\SpoolingTask.cs (2)
229CancellationToken cancelToken = m_groupState.CancellationState.MergedCancellationToken; 318CancellationToken cancelToken = m_groupState.CancellationState.MergedCancellationToken;
System\Linq\Parallel\Scheduling\SpoolingTaskBase.cs (3)
57oce.CancellationToken == m_groupState.CancellationState.MergedCancellationToken 58&& m_groupState.CancellationState.MergedCancellationToken.IsCancellationRequested) 67m_groupState.CancellationState.InternalCancellationTokenSource.Cancel();
System\Linq\Parallel\Utils\Sorting.cs (5)
73Contract.Assert(groupState.CancellationState.MergedCancellationToken != null); 77Contract.Assert(groupState.CancellationState.MergedCancellationToken != null); 230CancellationToken cancelToken = m_groupState.CancellationState.MergedCancellationToken; 290QuickSort(0, indices.Length - 1, keys.InternalArray, indices, m_groupState.CancellationState.MergedCancellationToken); 364CancellationToken cancelToken = m_groupState.CancellationState.MergedCancellationToken;