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