14 references to CancellationState
System.Linq.Parallel (14)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
76
_channelEnumerator = ExceptionAggregator.WrapQueryEnumerator(partitions[0], _taskGroupState.
CancellationState
).GetEnumerator();
System\Linq\Parallel\Merging\MergeEnumerator.cs (1)
68
Debug.Assert(_taskGroupState.
CancellationState
.TopLevelDisposedFlag.Value);
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
354
if (_mergeHelper._taskGroupState.
CancellationState
.MergedCancellationToken.IsCancellationRequested)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (1)
98
CancellationToken cancelToken = _taskGroupState.
CancellationState
.MergedCancellationToken;
System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (1)
137
if (!_groupState.
CancellationState
.MergedCancellationToken.IsCancellationRequested)
System\Linq\Parallel\Scheduling\SpoolingTask.cs (2)
226
CancellationToken cancelToken = _groupState.
CancellationState
.MergedCancellationToken;
315
CancellationToken cancelToken = _groupState.
CancellationState
.MergedCancellationToken;
System\Linq\Parallel\Scheduling\SpoolingTaskBase.cs (4)
52
oce.CancellationToken == _groupState.
CancellationState
.MergedCancellationToken
53
&& _groupState.
CancellationState
.MergedCancellationToken.IsCancellationRequested)
62
Debug.Assert(_groupState.
CancellationState
.InternalCancellationTokenSource != null);
63
_groupState.
CancellationState
.InternalCancellationTokenSource.Cancel();
System\Linq\Parallel\Utils\Sorting.cs (3)
225
CancellationToken cancelToken = _groupState.
CancellationState
.MergedCancellationToken;
282
QuickSort(0, indices.Length - 1, keys.InternalArray, indices, _groupState.
CancellationState
.MergedCancellationToken);
359
CancellationToken cancelToken = _groupState.
CancellationState
.MergedCancellationToken;