MergedCancellationToken

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

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

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

353if (m_mergeHelper.m_taskGroupState.CancellationState.MergedCancellationToken.IsCancellationRequested)

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

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

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

66leftStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken), 67rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken); 73leftStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken), 74rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken);

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

86ExchangeUtilities.HashRepartitionOrdered(leftStream, m_leftKeySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken), 87rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken); 92ExchangeUtilities.HashRepartition(leftStream, m_leftKeySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken), 93rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken);

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

68leftPartitionedStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken), 69rightPartitionedStream, outputRecipient, settings.CancellationState.MergedCancellationToken); 75leftPartitionedStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken), 76rightPartitionedStream, outputRecipient, settings.CancellationState.MergedCancellationToken);

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

88ExchangeUtilities.HashRepartitionOrdered(leftStream, m_leftKeySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken), 89rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken); 94ExchangeUtilities.HashRepartition(leftStream, m_leftKeySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken), 95rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken);

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

73leftStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken); 76leftHashStream, rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken); 82leftStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken); 85leftHashStream, rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken);

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

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

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

152if(querySettings.CancellationState.MergedCancellationToken.IsCancellationRequested)

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

167Contract.Assert(settings.CancellationState.MergedCancellationToken.CanBeCanceled);

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

119settings.CancellationState.MergedCancellationToken);

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

107settings.CancellationState.MergedCancellationToken);

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

76inputStream[i], m_defaultValue, i, partitionCount, sharedEmptyCount, sharedLatch, settings.CancellationState.MergedCancellationToken);

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

65inputStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken), 66recipient, settings.CancellationState.MergedCancellationToken); 72inputStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken), 73recipient, settings.CancellationState.MergedCancellationToken);

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

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

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

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

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

96inputStream[i], m_elementAction, settings.CancellationState.MergedCancellationToken);

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

81inputStream, m_keySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken), 83settings.CancellationState.MergedCancellationToken 90inputStream, m_keySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken), 92settings.CancellationState.MergedCancellationToken

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

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

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

89inputStream[i], m_predicate, operatorState, sharedBarrier, settings.CancellationState.MergedCancellationToken,

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

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

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

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

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

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

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

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

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

62settings.CancellationState.MergedCancellationToken);

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\QueryTaskGroupState.cs (1)

145if (m_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 (2)

57oce.CancellationToken == m_groupState.CancellationState.MergedCancellationToken 58&& m_groupState.CancellationState.MergedCancellationToken.IsCancellationRequested)

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

177cancelEx.CancellationToken == cancellationState.MergedCancellationToken 178&& cancellationState.MergedCancellationToken.IsCancellationRequested

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;