MergedCancellationToken

System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)

69MergeExecutor<TInputOutput>.MakeAsynchronousChannels(partitions.PartitionCount, options, consumerEvent, cancellationState.MergedCancellationToken);

System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)

354if (_mergeHelper._taskGroupState.CancellationState.MergedCancellationToken.IsCancellationRequested)

System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)

191outputStream[i] = new AssociativeAggregationOperatorEnumerator<TKey>(inputStream[i], this, i, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (4)

62leftStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken), 63rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken); 69leftStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken), 70rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (4)

81ExchangeUtilities.HashRepartitionOrdered(leftStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), 82rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken); 87ExchangeUtilities.HashRepartition(leftStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), 88rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (4)

64leftPartitionedStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken), 65rightPartitionedStream, outputRecipient, settings.CancellationState.MergedCancellationToken); 71leftPartitionedStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken), 72rightPartitionedStream, outputRecipient, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (6)

88ExchangeUtilities.HashRepartitionOrdered(leftStreamInt, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), 89rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken); 94ExchangeUtilities.HashRepartitionOrdered(leftStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), 95rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken); 101ExchangeUtilities.HashRepartition(leftStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), 102rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (4)

69leftStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken); 72leftHashStream, rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken); 78leftStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken); 81leftHashStream, rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Inlined\InlinedAggregationOperator.cs (1)

129outputStream[i] = CreateEnumerator<TKey>(i, partitionCount, inputStream[i], null, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)

144if (querySettings.CancellationState.MergedCancellationToken.IsCancellationRequested) 214if (querySettings.CancellationState.MergedCancellationToken.IsCancellationRequested)

System\Linq\Parallel\QueryOperators\QuerySettings.cs (1)

160Debug.Assert(settings.CancellationState.MergedCancellationToken.CanBeCanceled);

System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)

115settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)

94settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)

74inputStream[i], _defaultValue, i, partitionCount, sharedEmptyCount, sharedLatch, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (4)

61inputStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken), 62recipient, settings.CancellationState.MergedCancellationToken); 68inputStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken), 69recipient, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)

90outputStream[i] = new ElementAtQueryOperatorEnumerator(intKeyStream[i], _index, resultFoundFlag, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)

89settings.CancellationState.MergedCancellationToken, inputStream.KeyComparer, i);

System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)

92inputStream[i], _elementAction, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (4)

77inputStream, _keySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), 79settings.CancellationState.MergedCancellationToken 86inputStream, _keySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), 88settings.CancellationState.MergedCancellationToken

System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)

107outputStream[i] = new IndexedWhereQueryOperatorEnumerator(inputStreamInt[i], _predicate, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)

87inputStream[i], _predicate, operatorState, sharedBarrier, settings.CancellationState.MergedCancellationToken,

System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (1)

64outputStream[i] = new ReverseQueryOperatorEnumerator<TKey>(inputStream[i], settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)

155outputStream[i] = new SelectManyQueryOperatorEnumerator<TLeftKey>(inputStream[i], this, settings.CancellationState.MergedCancellationToken); 174outputStream[i] = new IndexedSelectManyQueryOperatorEnumerator(inputStream[i], this, settings.CancellationState.MergedCancellationToken);

System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)

120settings.CancellationState.MergedCancellationToken, inputStream.KeyComparer);

System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)

146settings.CancellationState.MergedCancellationToken, inputStream.KeyComparer);

System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)

58settings.CancellationState.MergedCancellationToken);

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

98CancellationToken cancelToken = _taskGroupState.CancellationState.MergedCancellationToken;

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

137if (!_groupState.CancellationState.MergedCancellationToken.IsCancellationRequested)

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

139if (_cancellationState.MergedCancellationToken.IsCancellationRequested)

System\Linq\Parallel\Scheduling\SpoolingTask.cs (2)

226CancellationToken cancelToken = _groupState.CancellationState.MergedCancellationToken; 315CancellationToken cancelToken = _groupState.CancellationState.MergedCancellationToken;

System\Linq\Parallel\Scheduling\SpoolingTaskBase.cs (2)

52oce.CancellationToken == _groupState.CancellationState.MergedCancellationToken 53&& _groupState.CancellationState.MergedCancellationToken.IsCancellationRequested)

System\Linq\Parallel\Utils\ExceptionAggregator.cs (2)

155if (cancelEx.CancellationToken == cancellationState.MergedCancellationToken 156&& cancellationState.MergedCancellationToken.IsCancellationRequested

System\Linq\Parallel\Utils\Sorting.cs (3)

225CancellationToken cancelToken = _groupState.CancellationState.MergedCancellationToken; 282QuickSort(0, indices.Length - 1, keys.InternalArray, indices, _groupState.CancellationState.MergedCancellationToken); 359CancellationToken cancelToken = _groupState.CancellationState.MergedCancellationToken;